(flink-connector-kudu) 14/44: Fix "the client has already been closed" bug (#75)

[martijnvisser]

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;
         }
     }