Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5121
---
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5121#discussion_r157606329
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java
---
@@ -61,9 +61,9 @@
*
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5121#discussion_r157606375
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java
---
@@ -61,9 +61,9 @@
*
Github user ggevay commented on a diff in the pull request:
https://github.com/apache/flink/pull/5121#discussion_r155927615
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java
---
@@ -34,17 +34,17 @@
* The run
Github user ankitiitb1069 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5121#discussion_r155877893
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java
---
@@ -34,17 +34,17 @@
* The
Github user ggevay commented on a diff in the pull request:
https://github.com/apache/flink/pull/5121#discussion_r154906923
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java
---
@@ -34,17 +34,17 @@
* The run
GitHub user ankitiitb1069 opened a pull request:
https://github.com/apache/flink/pull/5121
[FLINK-8116] Stale comments referring to Checkpointed interface
## What is the purpose of the change
This pull request replaces the stale comments referring to Checkpointed
interface
