You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2015/08/03 20:50:23 UTC
[3/8] flink git commit: [FLINK-2465] [streaming] SocketClientSink
closes connection early
[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 <86...@qq.com>
Authored: Mon Aug 3 15:50:26 2015 +0800
Committer: Stephan Ewen <se...@apache.org>
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 "