[fix-36591][logminer]disConnect增加非空判断

yanghuaiGit · yanghuaiGit · commit 1979c48adce3 · 2021-04-28T13:42:08.000+08:00
diff --git a/flinkx-oraclelogminer/flinkx-oraclelogminer-reader/src/main/java/com/dtstack/flinkx/oraclelogminer/format/LogMinerConnection.java b/flinkx-oraclelogminer/flinkx-oraclelogminer-reader/src/main/java/com/dtstack/flinkx/oraclelogminer/format/LogMinerConnection.java
@@ -220,7 +220,9 @@ public void disConnect() {
         closeResources(logMinerData, logMinerSelectStmt, connection);
 
         //queryDataForRollbackConnection 也需要关闭资源
-        queryDataForRollbackConnection.disConnect();
+        if(Objects.nonNull(queryDataForRollbackConnection)){
+            queryDataForRollbackConnection.disConnect();
+        }
     }
 
     /**

Original file line number	Diff line number	Diff line change
`@@ -220,7 +220,9 @@ public void disConnect() {`
`220`	`220`	`closeResources(logMinerData, logMinerSelectStmt, connection);`
`221`	`221`
`222`	`222`	`//queryDataForRollbackConnection 也需要关闭资源`
`223`		`- queryDataForRollbackConnection.disConnect();`
	`223`	`+ if(Objects.nonNull(queryDataForRollbackConnection)){`
	`224`	`+ queryDataForRollbackConnection.disConnect();`
	`225`	`+ }`
`224`	`226`	`}`
`225`	`227`
`226`	`228`	`/**`