Skip to content

Commit e310555

Browse files
committed
Revert "datachecker 支持 qualitis v10"
This reverts commit 62ceaf1.
1 parent 33f6def commit e310555

File tree

1 file changed

+2
-3
lines changed
  • dss-appconn/appconns/dss-datachecker-appconn/src/main/java/com/webank/wedatasphere/dss/appconn/datachecker/connector

1 file changed

+2
-3
lines changed

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

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -102,8 +102,7 @@ public boolean validateTableStatusFunction(Properties props, Logger log, DataChe
102102
return false;
103103
}
104104
}
105-
boolean systemCheck = Boolean.valueOf(props.getProperty(DataChecker.QUALITIS_SWITCH));
106-
if (systemCheck && dopsDS == null) {
105+
if (dopsDS == null) {
107106
dopsDS = DataDruidFactory.getDopsInstance(props, log);//通过alibaba的druid数据库连接池获取JOB数据库连接
108107
if (dopsDS == null) {
109108
log.error("Error getting Druid DataSource instance");
@@ -133,7 +132,7 @@ public boolean validateTableStatusFunction(Properties props, Logger log, DataChe
133132
QualitisUtil qualitisUtil = new QualitisUtil(props);
134133
try (Connection jobConn = jobDS.getConnection();
135134
Connection bdpConn = bdpDS.getConnection();
136-
Connection dopsConn = dopsDS != null ? dopsDS.getConnection() : null) {
135+
Connection dopsConn=dopsDS.getConnection()) {
137136
List<Boolean> allCheckRes = dataObjectList
138137
.parallelStream()
139138
.map(proObjectMap -> {

0 commit comments

Comments
 (0)