[GitHub] flink issue #5492: [FLINK-5728] [kafka] Let FlinkKafkaProducers flush on che...

2018-02-16 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5492 I merged this, could you please close the PR? 👍 ---

[GitHub] flink issue #5492: [FLINK-5728] [kafka] Let FlinkKafkaProducers flush on che...

2018-02-15 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5492 Had to change this line to use `StreamingRuntimeContext.class` because the Producer would now actually call this:

[GitHub] flink issue #5492: [FLINK-5728] [kafka] Let FlinkKafkaProducers flush on che...

2018-02-15 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5492 LGTM! I will merge as soon as travis is green ---