| commit | ee4e8e6b1672db1787dd12f1f981be63225e2591 | [log] [tgz] |
|---|---|---|
| author | WangJ1an <826204781@qq.com> | Mon Jan 20 04:20:34 2020 +0800 |
| committer | Luciano Resende <lresende@apache.org> | Sun Jan 19 12:20:34 2020 -0800 |
| tree | 48a43f4a0262de9f1ab5640970f9cc29872ee412 | |
| parent | cf8bf2ba33364d03e08dad7490ce463adbb204ce [diff] |
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
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 @@ } if (kuduReader != null) { kuduReader.close(); + kuduReader = null; } }