[jira] [Commented] (FLINK-11127) Make metrics query service establish connection to JobManager

[ https://issues.apache.org/jira/browse/FLINK-11127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16724737#comment-16724737 ] Nagarjun Guraja commented on FLINK-11127: - [~spoganshev] I am wondering, modifyi

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

[ https://issues.apache.org/jira/browse/FLINK-8570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nagarjun Guraja updated FLINK-8570: --- Description: This hook can be leveraged in coassigning and managing the association between Ke

[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: F

[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: https:

[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] [Commented] (FLINK-4650) Frequent task manager disconnects from JobManager

[ https://issues.apache.org/jira/browse/FLINK-4650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15530607#comment-15530607 ] Nagarjun Guraja commented on FLINK-4650: Hey [~uce]... We talked about this briefl

[jira] [Commented] (FLINK-3409) Integrate STOP with Savepoints

[ https://issues.apache.org/jira/browse/FLINK-3409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15530225#comment-15530225 ] Nagarjun Guraja commented on FLINK-3409: First version could be: Flink stops auto

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

[ https://issues.apache.org/jira/browse/FLINK-4650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15511311#comment-15511311 ] Nagarjun Guraja commented on FLINK-4650: [~StephanEwen] I haven't spent lot of tim

[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 Typ

[jira] [Updated] (FLINK-4596) RESTART_STRATEGY is not really pluggable

[ https://issues.apache.org/jira/browse/FLINK-4596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nagarjun Guraja updated FLINK-4596: --- Description: Standalone cluster config accepts an implementation(class) as part of the yaml c

[jira] [Updated] (FLINK-4596) RESTART_STRATEGY is not really pluggable

[ https://issues.apache.org/jira/browse/FLINK-4596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nagarjun Guraja updated FLINK-4596: --- Summary: RESTART_STRATEGY is not really pluggable (was: Class not found exception when RESTAR

[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: https://issues.apache.org/jira/browse/F

[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: https://issues.apache.org/jira/browse/FLI