Stream Iterations

Hi All, I have a use case for which I need some suggestions. It's a streaming application with kafka source and then groupBy, keyBy and perform some calculations. The output of each calculation has to be a side input for the next calculation and also it needs to be sent to a sink. Right now I'm

[jira] [Created] (FLINK-5365) Mesos AppMaster/TaskManager should obey sigterm

Eron Wright created FLINK-5365: --- Summary: Mesos AppMaster/TaskManager should obey sigterm Key: FLINK-5365 URL: https://issues.apache.org/jira/browse/FLINK-5365 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5364) Rework JAAS configuration to support user-supplied entries

Eron Wright created FLINK-5364: --- Summary: Rework JAAS configuration to support user-supplied entries Key: FLINK-5364 URL: https://issues.apache.org/jira/browse/FLINK-5364 Project: Flink Issue

[jira] [Created] (FLINK-5363) Fire timers when window state is currently empty

Aljoscha Krettek created FLINK-5363: --- Summary: Fire timers when window state is currently empty Key: FLINK-5363 URL: https://issues.apache.org/jira/browse/FLINK-5363 Project: Flink Issue

[jira] [Created] (FLINK-5362) Implement methods to access BipartiteGraph properties

Ivan Mushketyk created FLINK-5362: - Summary: Implement methods to access BipartiteGraph properties Key: FLINK-5362 URL: https://issues.apache.org/jira/browse/FLINK-5362 Project: Flink Issue