You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2018/11/19 10:12:31 UTC
[flink] branch release-1.5 updated: [FLINK-10925][py] Check for
null when closing socket
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-1.5
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.5 by this push:
new ff9e06b [FLINK-10925][py] Check for null when closing socket
ff9e06b is described below
commit ff9e06b56edc35f8d4db2af760336df4a7d317d5
Author: kkolman <ko...@gmail.com>
AuthorDate: Mon Nov 19 11:11:14 2018 +0100
[FLINK-10925][py] Check for null when closing socket
---
.../apache/flink/python/api/streaming/plan/PythonPlanStreamer.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/flink-libraries/flink-python/src/main/java/org/apache/flink/python/api/streaming/plan/PythonPlanStreamer.java b/flink-libraries/flink-python/src/main/java/org/apache/flink/python/api/streaming/plan/PythonPlanStreamer.java
index d25f3d5..3e6a068 100644
--- a/flink-libraries/flink-python/src/main/java/org/apache/flink/python/api/streaming/plan/PythonPlanStreamer.java
+++ b/flink-libraries/flink-python/src/main/java/org/apache/flink/python/api/streaming/plan/PythonPlanStreamer.java
@@ -126,7 +126,9 @@ public class PythonPlanStreamer {
process.destroy();
} finally {
try {
- server.close();
+ if (server != null) {
+ server.close();
+ }
} catch (IOException e) {
LOG.error("Failed to close socket.", e);
}