【解决分库分表插件任务完成时最后一个数据源连接未关闭问题】【26062】

kanata163 · kanata163 · commit ef4488ccb2c7 · 2020-05-20T14:53:38.000+08:00
diff --git a/flinkx-rdb/flinkx-rdb-reader/src/main/java/com.dtstack.flinkx.rdb.inputformat/DistributedJdbcInputFormat.java b/flinkx-rdb/flinkx-rdb-reader/src/main/java/com.dtstack.flinkx.rdb.inputformat/DistributedJdbcInputFormat.java
@@ -206,7 +206,7 @@ protected void closeCurrentSource(){
 
     @Override
     protected void closeInternal() throws IOException {
-
+        closeCurrentSource();
     }
 
     @Override

Original file line number	Diff line number	Diff line change
`@@ -206,7 +206,7 @@ protected void closeCurrentSource(){`
`206`	`206`
`207`	`207`	`@Override`
`208`	`208`	`protected void closeInternal() throws IOException {`
`209`		`-`
	`209`	`+ closeCurrentSource();`
`210`	`210`	`}`
`211`	`211`
`212`	`212`	`@Override`