[GitHub] flink issue #5858: [FLINK-9183] [Documentation] Kafka consumer docs to warn ...

2018-04-16 Thread juhoautio
Github user juhoautio commented on the issue: https://github.com/apache/flink/pull/5858 IMHO would be good to have this in 1.5 docs when it goes out. Current master seems to aim at 1.6. ---

[GitHub] flink pull request #5858: [FLINK-9183] [Documentation] Kafka consumer docs t...

2018-04-16 Thread juhoautio
GitHub user juhoautio opened a pull request: https://github.com/apache/flink/pull/5858 [FLINK-9183] [Documentation] Kafka consumer docs to warn about idle partitions https://issues.apache.org/jira/browse/FLINK-9183 Another sub-task was added as a reminder to remove

[GitHub] flink issue #5634: [FLINK-5479] [kafka] Idleness detection for periodic per-...

2018-04-13 Thread juhoautio
Github user juhoautio commented on the issue: https://github.com/apache/flink/pull/5634 @tzulitai did you ever test your code? I tried it and it allowed watermarks to proceed but apparently too aggressively, as it caused a lot of data loss. I'm looking for a quick fix