Flink 1.4.2 in Zeppelin Notebook

Hi! Has someone successfully integrated Flink 1.4.2 into Zeppelin notebook (using Flink in cluster mode, not local mode)? Best, Rico.

Duplicates in Flink

Hi! I still have an issue... I was now using 0.9.1 and the new KafkaConnector. But I still get duplicates in my flink prog. Here's the relevant part: final FlinkKafkaConsumer082 kafkaSrc = new FlinkKafkaConsumer082( kafkaTopicIn, new SimpleStringSchema(), properties);

Problem with Windowing

Hi! I have a problem that I cannot really track down. I'll try to describe the issue. My streaming flink program computes something. At the end I'm doing the follwing on my DataStream ds ds.window(2, TimeUnit.SECONDS) .groupBy(/*custom KeySelector converting input to a String representation*

optimal deployment model for Flink Streaming programs

Hi! We want to build an infrastructure for automated deployment of Flink Streaming programs to a dedicated environment. This includes automated tests (unit and integration) via Jenkins and in case of a successful build&test the program should be deployed to the execution environment. Since s