[bahir-flink] branch master updated: Fix "the client has already been closed" bug (#75)

[lr...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

lresende pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/bahir-flink.git


The following commit(s) were added to refs/heads/master by this push:
     new ee4e8e6  Fix "the client has already been closed" bug (#75)
ee4e8e6 is described below

commit ee4e8e6b1672db1787dd12f1f981be63225e2591
Author: WangJ1an <82...@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;
         }
     }