[GitHub] flink issue #5492: [FLINK-5728] [kafka] Let FlinkKafkaProducers flush on che...
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...
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...
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5492 LGTM! I will merge as soon as travis is green ---