[jira] [Created] (FLINK-8571) Provide an enhanced KeyedStream implementation to use ForwardPartitioner

Nagarjun Guraja created FLINK-8571: -- Summary: Provide an enhanced KeyedStream implementation to use ForwardPartitioner Key: FLINK-8571 URL: https://issues.apache.org/jira/browse/FLINK-8571 Project:

[jira] [Created] (FLINK-8570) Provide a hook in Flink KafkaConsumer(source function) implementation to override assignment of kafka partitions to individual task nodes

Nagarjun Guraja created FLINK-8570: -- Summary: Provide a hook in Flink KafkaConsumer(source function) implementation to override assignment of kafka partitions to individual task nodes Key: FLINK-8570 URL:

[jira] [Created] (FLINK-8569) Provide a hook to override the default KeyGroupRangeAssignment

Nagarjun Guraja created FLINK-8569: -- Summary: Provide a hook to override the default KeyGroupRangeAssignment Key: FLINK-8569 URL: https://issues.apache.org/jira/browse/FLINK-8569 Project: Flink

[jira] [Created] (FLINK-4650) Frequent task manager disconnects from JobManager

Nagarjun Guraja created FLINK-4650: -- Summary: Frequent task manager disconnects from JobManager Key: FLINK-4650 URL: https://issues.apache.org/jira/browse/FLINK-4650 Project: Flink Issue

[jira] [Created] (FLINK-4596) Class not found exception when RESTART_STRATEGY is configured with fully qualified class name in the yaml

Nagarjun Guraja created FLINK-4596: -- Summary: Class not found exception when RESTART_STRATEGY is configured with fully qualified class name in the yaml Key: FLINK-4596 URL:

[jira] [Created] (FLINK-4515) org.apache.flink.runtime.jobmanager.JobInfo class is not backwards compatible with 1.1 released version

Nagarjun Guraja created FLINK-4515: -- Summary: org.apache.flink.runtime.jobmanager.JobInfo class is not backwards compatible with 1.1 released version Key: FLINK-4515 URL: