This is an automated email from the ASF dual-hosted git repository. martijnvisser pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/flink-connector-kudu.git
commit 9b99c1862cad3c26b0d287c1fb13e15b588b1392 Author: WangJ1an <826204...@qq.com> AuthorDate: Mon Jan 20 04:20:34 2020 +0800 Fix "the client has already been closed" bug (#75) Fix the problem "Caused by: java.lang.IllegalStateException: Cannot proceed, the client has already been closed" when running in Flink local mode --- .../java/org/apache/flink/connectors/kudu/batch/KuduInputFormat.java | 1 + 1 file changed, 1 insertion(+) diff --git a/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/batch/KuduInputFormat.java b/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/batch/KuduInputFormat.java index 3a35e6a..98877d8 100644 --- a/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/batch/KuduInputFormat.java +++ b/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/batch/KuduInputFormat.java @@ -98,6 +98,7 @@ public class KuduInputFormat<OUT> extends RichInputFormat<OUT, KuduInputSplit> { } if (kuduReader != null) { kuduReader.close(); + kuduReader = null; } }