Skip to content

Commit 9450632

Browse files
committed
Revert "datachecker 支持 qualitis v8"
This reverts commit 4dc0dd0.
1 parent 6d9534b commit 9450632

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

dss-appconn/appconns/dss-datachecker-appconn/src/main/java/com/webank/wedatasphere/dss/appconn/datachecker/DataChecker.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -81,7 +81,7 @@ public void run() {
8181
begineCheck(dataCheckerAction);
8282
}catch (Exception ex){
8383
dataCheckerAction.setState(RefExecutionState.Failed);
84-
throw ex;
84+
throw new RuntimeException("get DataChecker result failed", ex);
8585
}
8686

8787
}
@@ -93,7 +93,7 @@ public void begineCheck(DataCheckerExecutionAction action){
9393
}catch (Exception ex){
9494
dataCheckerAction.setState(RefExecutionState.Failed);
9595
logger.error("datacheck error",ex);
96-
throw ex;
96+
throw new RuntimeException("get DataChecker result failed", ex);
9797
}
9898
if(success) {
9999
dataCheckerAction.setState(RefExecutionState.Success);

dss-appconn/appconns/dss-datachecker-appconn/src/main/java/com/webank/wedatasphere/dss/appconn/datachecker/connector/DataCheckerDao.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -243,7 +243,7 @@ private boolean getDataCheckResult(Map<String, String> proObjectMap,
243243
boolean qualitisCheck = checkQualitisData(objectNum, dataObject, log, action, props, dopsConn, qualitisUtil);
244244
if(!qualitisCheck){
245245
//如果是qualitis校验失败,则直接终止任务
246-
throw new RuntimeException("does not pass qualitis check(qualitis校验未通过)");
246+
action.setState(RefExecutionState.Failed);
247247
}
248248
return qualitisCheck;
249249
}

0 commit comments

Comments
 (0)