[jira] [Commented] (FLINK-12002) Adaptive Parallelism of Job Vertex Execution

[ https://issues.apache.org/jira/browse/FLINK-12002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883723#comment-16883723 ] ryantaocer commented on FLINK-12002: Thanks for your helpful comments [~till.rohrman

[jira] [Comment Edited] (FLINK-12229) Implement Lazy Scheduling Strategy

[ https://issues.apache.org/jira/browse/FLINK-12229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833241#comment-16833241 ] ryantaocer edited comment on FLINK-12229 at 5/5/19 8:10 AM:

[jira] [Comment Edited] (FLINK-12229) Implement Lazy Scheduling Strategy

[ https://issues.apache.org/jira/browse/FLINK-12229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833241#comment-16833241 ] ryantaocer edited comment on FLINK-12229 at 5/5/19 6:40 AM:

[jira] [Commented] (FLINK-12229) Implement Lazy Scheduling Strategy

[ https://issues.apache.org/jira/browse/FLINK-12229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833241#comment-16833241 ] ryantaocer commented on FLINK-12229: Maybe we could introduce a new scheduling trigg

[jira] [Commented] (FLINK-12070) Make blocking result partitions consumable multiple times

[ https://issues.apache.org/jira/browse/FLINK-12070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16830003#comment-16830003 ] ryantaocer commented on FLINK-12070: [~StephanEwen] thank you for the response!  I a

[jira] [Comment Edited] (FLINK-12070) Make blocking result partitions consumable multiple times

[ https://issues.apache.org/jira/browse/FLINK-12070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16820940#comment-16820940 ] ryantaocer edited comment on FLINK-12070 at 4/18/19 10:19 AM:

[jira] [Comment Edited] (FLINK-12070) Make blocking result partitions consumable multiple times

[ https://issues.apache.org/jira/browse/FLINK-12070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16820940#comment-16820940 ] ryantaocer edited comment on FLINK-12070 at 4/18/19 10:18 AM:

[jira] [Commented] (FLINK-12070) Make blocking result partitions consumable multiple times

[ https://issues.apache.org/jira/browse/FLINK-12070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16820940#comment-16820940 ] ryantaocer commented on FLINK-12070: !image-2019-04-18-17-38-24-949.png! Thanks [~S

[jira] [Updated] (FLINK-12070) Make blocking result partitions consumable multiple times

[ https://issues.apache.org/jira/browse/FLINK-12070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ryantaocer updated FLINK-12070: --- Attachment: image-2019-04-18-17-38-24-949.png > Make blocking result partitions consumable multiple

[jira] [Comment Edited] (FLINK-12070) Make blocking result partitions consumable multiple times

[ https://issues.apache.org/jira/browse/FLINK-12070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818682#comment-16818682 ] ryantaocer edited comment on FLINK-12070 at 4/16/19 6:51 AM: -

[jira] [Comment Edited] (FLINK-12070) Make blocking result partitions consumable multiple times

[ https://issues.apache.org/jira/browse/FLINK-12070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818682#comment-16818682 ] ryantaocer edited comment on FLINK-12070 at 4/16/19 6:48 AM: -

[jira] [Commented] (FLINK-12070) Make blocking result partitions consumable multiple times

[ https://issues.apache.org/jira/browse/FLINK-12070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818682#comment-16818682 ] ryantaocer commented on FLINK-12070: It's so cool to unify the network buffered and

[jira] [Updated] (FLINK-11309) Make SpillableSubpartition repeatably read to enable

[ https://issues.apache.org/jira/browse/FLINK-11309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ryantaocer updated FLINK-11309: --- Summary: Make SpillableSubpartition repeatably read to enable (was: Batch Job Failover Using Restar

[jira] [Updated] (FLINK-11177) Node health manager

[ https://issues.apache.org/jira/browse/FLINK-11177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ryantaocer updated FLINK-11177: --- Description: * A NodeHealthManager module aims to monitor the health states of nodes including mach

[jira] [Updated] (FLINK-11177) Node health manager

[ https://issues.apache.org/jira/browse/FLINK-11177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ryantaocer updated FLINK-11177: --- Summary: Node health manager (was: TM health manager) > Node health manager > --- >

[jira] [Updated] (FLINK-11177) Node health manager

[ https://issues.apache.org/jira/browse/FLINK-11177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ryantaocer updated FLINK-11177: --- Summary: Node health manager (was: Node health track) > Node health manager > --- >

[jira] [Updated] (FLINK-11177) Node health tracker

[ https://issues.apache.org/jira/browse/FLINK-11177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ryantaocer updated FLINK-11177: --- Description: * A NodeHealthManager module to monitor the status of nodes including machine states a

[jira] [Updated] (FLINK-11177) TM health manager

[ https://issues.apache.org/jira/browse/FLINK-11177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ryantaocer updated FLINK-11177: --- Summary: TM health manager (was: Node health manager) > TM health manager > - > >

[jira] [Updated] (FLINK-11177) Node health track

[ https://issues.apache.org/jira/browse/FLINK-11177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ryantaocer updated FLINK-11177: --- Summary: Node health track (was: Node health tracker) > Node health track > - > >

[jira] [Created] (FLINK-12053) Calculation of parallelism based on metrics/signals

ryantaocer created FLINK-12053: -- Summary: Calculation of parallelism based on metrics/signals Key: FLINK-12053 URL: https://issues.apache.org/jira/browse/FLINK-12053 Project: Flink Issue Type: S

[jira] [Updated] (FLINK-12002) Adaptive Parallelism of Job Vertex Execution

[ https://issues.apache.org/jira/browse/FLINK-12002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ryantaocer updated FLINK-12002: --- Component/s: (was: Runtime / Operators) Runtime / Coordination > Adaptive Paral

[jira] [Created] (FLINK-12052) Redistributed unevenly sized result partitions

ryantaocer created FLINK-12052: -- Summary: Redistributed unevenly sized result partitions Key: FLINK-12052 URL: https://issues.apache.org/jira/browse/FLINK-12052 Project: Flink Issue Type: Sub-ta

[jira] [Updated] (FLINK-12002) Adaptive Parallelism of Job Vertex Execution

[ https://issues.apache.org/jira/browse/FLINK-12002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ryantaocer updated FLINK-12002: --- Description: In Flink the parallelism of job is a pre-specified parameter, which is usually  an empi

[jira] [Updated] (FLINK-12002) Adaptive Parallelism of Job Vertex Execution

[ https://issues.apache.org/jira/browse/FLINK-12002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ryantaocer updated FLINK-12002: --- Description: In Flink the parallelism of job is a pre-specified parameter, which is usually  an empi

[jira] [Created] (FLINK-12002) Adaptive Parallelism of Job Vertex Execution

ryantaocer created FLINK-12002: -- Summary: Adaptive Parallelism of Job Vertex Execution Key: FLINK-12002 URL: https://issues.apache.org/jira/browse/FLINK-12002 Project: Flink Issue Type: Improvem

[jira] [Assigned] (FLINK-10572) Enable Per-job level failover strategy.

[ https://issues.apache.org/jira/browse/FLINK-10572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ryantaocer reassigned FLINK-10572: -- Assignee: ryantaocer (was: JIN SUN) > Enable Per-job level failover strategy. > ---

[jira] [Assigned] (FLINK-10288) Failover Strategy improvement

[ https://issues.apache.org/jira/browse/FLINK-10288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ryantaocer reassigned FLINK-10288: -- Assignee: ryantaocer (was: JIN SUN) > Failover Strategy improvement > --

[jira] [Assigned] (FLINK-10643) Bubble execution: Resource aware job execution

[ https://issues.apache.org/jira/browse/FLINK-10643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ryantaocer reassigned FLINK-10643: -- Assignee: ryantaocer (was: JIN SUN) > Bubble execution: Resource aware job execution > -

[jira] [Assigned] (FLINK-10205) Batch Job: InputSplit Fault tolerant for DataSourceTask

[ https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ryantaocer reassigned FLINK-10205: -- Assignee: ryantaocer (was: JIN SUN) > Batch Job: InputSplit Fault tolerant for DataSourceTas

[jira] [Assigned] (FLINK-10656) Refactor org.apache.flink.runtime.io.network.api.reader.ReaderBase

[ https://issues.apache.org/jira/browse/FLINK-10656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ryantaocer reassigned FLINK-10656: -- Assignee: ryantaocer (was: JIN SUN) > Refactor org.apache.flink.runtime.io.network.api.reade

[jira] [Assigned] (FLINK-10576) Introduce Machine/Node/TM health management

[ https://issues.apache.org/jira/browse/FLINK-10576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ryantaocer reassigned FLINK-10576: -- Assignee: ryantaocer (was: JIN SUN) > Introduce Machine/Node/TM health management >

[jira] [Assigned] (FLINK-10298) Batch Job Failover Strategy

[ https://issues.apache.org/jira/browse/FLINK-10298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ryantaocer reassigned FLINK-10298: -- Assignee: ryantaocer (was: JIN SUN) > Batch Job Failover Strategy >

[jira] [Assigned] (FLINK-10573) Support task revocation

[ https://issues.apache.org/jira/browse/FLINK-10573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ryantaocer reassigned FLINK-10573: -- Assignee: ryantaocer (was: JIN SUN) > Support task revocation > --- > >

[jira] [Assigned] (FLINK-10574) Update documents of new batch job failover strategy

[ https://issues.apache.org/jira/browse/FLINK-10574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ryantaocer reassigned FLINK-10574: -- Assignee: ryantaocer (was: JIN SUN) > Update documents of new batch job failover strategy >

[jira] [Assigned] (FLINK-11177) Node health tracker

[ https://issues.apache.org/jira/browse/FLINK-11177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ryantaocer reassigned FLINK-11177: -- Assignee: ryantaocer > Node health tracker > --- > > Key: FLI

[jira] [Assigned] (FLINK-10644) Batch Job: Speculative execution

[ https://issues.apache.org/jira/browse/FLINK-10644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ryantaocer reassigned FLINK-10644: -- Assignee: ryantaocer (was: JIN SUN) > Batch Job: Speculative execution > ---

[jira] [Created] (FLINK-11177) Node health tracker

ryantaocer created FLINK-11177: -- Summary: Node health tracker Key: FLINK-11177 URL: https://issues.apache.org/jira/browse/FLINK-11177 Project: Flink Issue Type: Sub-task Components: Jo

[jira] [Commented] (FLINK-10644) Batch Job: Speculative execution

[ https://issues.apache.org/jira/browse/FLINK-10644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16680808#comment-16680808 ] ryantaocer commented on FLINK-10644: An initial design doc: https://docs.google.com