Merge branch 'hotfix_1.8_v3.9.x_26062' into 1.8_release_3.9.x

gituser · gituser · commit 92bd85ca8517 · 2020-05-25T14:14:42.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`