[FLINK-2465] [streaming] SocketClientSink closes connection early This closes #972
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b08e30ad Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b08e30ad Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/b08e30ad Branch: refs/heads/master Commit: b08e30ad9a39ed9885f4daa05a08d13eb22ebb8c Parents: 0693c92 Author: ffbin <[email protected]> Authored: Mon Aug 3 15:50:26 2015 +0800 Committer: Stephan Ewen <[email protected]> Committed: Mon Aug 3 18:48:07 2015 +0200 ---------------------------------------------------------------------- .../flink/streaming/api/functions/sink/SocketClientSink.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/b08e30ad/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/sink/SocketClientSink.java ---------------------------------------------------------------------- diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/sink/SocketClientSink.java b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/sink/SocketClientSink.java index da8fd7f..adffe5e 100644 --- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/sink/SocketClientSink.java +++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/sink/SocketClientSink.java @@ -88,7 +88,7 @@ public class SocketClientSink<IN> extends RichSinkFunction<IN> { */ private void closeConnection(){ try { - dataOutputStream.flush(); + dataOutputStream.close(); client.close(); } catch (IOException e) { throw new RuntimeException("Error while closing connection with socket server at "
