[jira] [Created] (FLINK-2495) Add a null point check in API DataStream.union

Huang Wei created FLINK-2495: Summary: Add a null point check in API DataStream.union Key: FLINK-2495 URL: https://issues.apache.org/jira/browse/FLINK-2495 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2496) Expose Task Manager configuration to Runtime Context

Sachin Goel created FLINK-2496: -- Summary: Expose Task Manager configuration to Runtime Context Key: FLINK-2496 URL: https://issues.apache.org/jira/browse/FLINK-2496 Project: Flink Issue Type: Bu

[jira] [Created] (FLINK-2497) Rework streaming iteration flow control

Gyula Fora created FLINK-2497: - Summary: Rework streaming iteration flow control Key: FLINK-2497 URL: https://issues.apache.org/jira/browse/FLINK-2497 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-2498) GroupReduceITCase failure

Sachin Goel created FLINK-2498: -- Summary: GroupReduceITCase failure Key: FLINK-2498 URL: https://issues.apache.org/jira/browse/FLINK-2498 Project: Flink Issue Type: Bug Reporter: Sac

[jira] [Created] (FLINK-2499) start-cluster.sh can start multiple TaskManager on the same node

Chen He created FLINK-2499: -- Summary: start-cluster.sh can start multiple TaskManager on the same node Key: FLINK-2499 URL: https://issues.apache.org/jira/browse/FLINK-2499 Project: Flink Issue Typ

[jira] [Created] (FLINK-2500) Some reviews to improve code quality

Huang Wei created FLINK-2500: Summary: Some reviews to improve code quality Key: FLINK-2500 URL: https://issues.apache.org/jira/browse/FLINK-2500 Project: Flink Issue Type: Improvement

Parameter Server for Flink

Hi all I've been working on a Parameter Server for Flink and I have some basic functionality up, which supports registering a key, plus setting, updating and fetching a parameter. The idea is to start a Parameter Server somewhere and pass the address and port in a configuration for another actor s