Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5112
---
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5112#discussion_r159949798
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/experimental/CollectSink.java
---
@@ -28,8 +29,12 @@
import java.net.Socket;
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5112#discussion_r159942085
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/experimental/package-info.java
---
@@ -0,0 +1,25 @@
+/*
+ * Licensed to
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5112#discussion_r159941955
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/experimental/CollectSink.java
---
@@ -28,8 +29,12 @@
import
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5112#discussion_r159494408
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/streaming/experimental/CollectITCase.java
---
@@ -7,7 +7,7 @@
* "License"); you may not
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5112#discussion_r159494457
--- Diff:
flink-streaming-scala/src/main/scala/org/apache/flink/streaming/experimental/package.scala
---
@@ -16,23 +16,25 @@
* limitations under
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5112#discussion_r159384609
--- Diff:
flink-streaming-scala/src/main/scala/org/apache/flink/streaming/experimental/package.scala
---
@@ -16,23 +16,25 @@
* limitations under
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5112#discussion_r159384731
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/streaming/experimental/CollectITCase.java
---
@@ -7,7 +7,7 @@
* "License"); you may not
