[jira] [Commented] (FLINK-14163) Execution#producedPartitions is possibly not assigned when used

[ https://issues.apache.org/jira/browse/FLINK-14163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014845#comment-17014845 ] Zhu Zhu commented on FLINK-14163: - +1 to fix it with a simple check first. As long as we

[jira] [Commented] (FLINK-15249) Improve PipelinedRegions calculation with Union Set

[ https://issues.apache.org/jira/browse/FLINK-15249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014900#comment-17014900 ] Zhu Zhu commented on FLINK-15249: - Hi [~nppoly], I tried your patch with a testing topol

[jira] [Updated] (FLINK-15249) Improve PipelinedRegions calculation with Union Set

[ https://issues.apache.org/jira/browse/FLINK-15249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-15249: Attachment: RegionFailoverPerfTest.java > Improve PipelinedRegions calculation with Union Set > --

[jira] [Created] (FLINK-15582) Enable batch scheduling tests in LegacySchedulerBatchSchedulingTest for DefaultScheduler as well

Zhu Zhu created FLINK-15582: --- Summary: Enable batch scheduling tests in LegacySchedulerBatchSchedulingTest for DefaultScheduler as well Key: FLINK-15582 URL: https://issues.apache.org/jira/browse/FLINK-15582

[jira] [Commented] (FLINK-15582) Enable batch scheduling tests in LegacySchedulerBatchSchedulingTest for DefaultScheduler as well

[ https://issues.apache.org/jira/browse/FLINK-15582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014975#comment-17014975 ] Zhu Zhu commented on FLINK-15582: - [~trohrmann] this is a pre-requisite for removing Leg

[jira] [Assigned] (FLINK-15582) Enable batch scheduling tests in LegacySchedulerBatchSchedulingTest for DefaultScheduler as well

[ https://issues.apache.org/jira/browse/FLINK-15582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-15582: --- Assignee: Zhu Zhu > Enable batch scheduling tests in LegacySchedulerBatchSchedulingTest for > Defa

[jira] [Updated] (FLINK-15582) Enable batch scheduling tests in LegacySchedulerBatchSchedulingTest for DefaultScheduler as well

[ https://issues.apache.org/jira/browse/FLINK-15582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-15582: Affects Version/s: 1.11.0 > Enable batch scheduling tests in LegacySchedulerBatchSchedulingTest for > Def

[jira] [Closed] (FLINK-15307) Subclasses of FailoverStrategy are easily confused with implementation classes of RestartStrategy

[ https://issues.apache.org/jira/browse/FLINK-15307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-15307. --- Resolution: Fixed Fixed via: master: 5984e7e363c87ebef4e6a9b501ca36d9d20fe798 > Subclasses of FailoverStra

[jira] [Updated] (FLINK-15582) Enable batch scheduling tests in LegacySchedulerBatchSchedulingTest for DefaultScheduler as well

[ https://issues.apache.org/jira/browse/FLINK-15582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-15582: Fix Version/s: (was: 1.10.0) 1.11.0 > Enable batch scheduling tests in LegacySchedu

[jira] [Issue Comment Deleted] (FLINK-15582) Enable batch scheduling tests in LegacySchedulerBatchSchedulingTest for DefaultScheduler as well

[ https://issues.apache.org/jira/browse/FLINK-15582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-15582: Comment: was deleted (was: [~trohrmann] this is a pre-requisite for removing LegacyScheduler but I think

[jira] [Closed] (FLINK-14701) Slot leaks if SharedSlotOversubscribedException happens

[ https://issues.apache.org/jira/browse/FLINK-14701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-14701. --- Fix Version/s: (was: 1.9.2) (was: 1.10.0) Resolution: Won't Fix This issue

[jira] [Updated] (FLINK-14701) Slot leaks if SharedSlotOversubscribedException happens

[ https://issues.apache.org/jira/browse/FLINK-14701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14701: Affects Version/s: (was: 1.10.0) > Slot leaks if SharedSlotOversubscribedException happens > -

[jira] [Reopened] (FLINK-14701) Slot leaks if SharedSlotOversubscribedException happens

[ https://issues.apache.org/jira/browse/FLINK-14701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reopened FLINK-14701: - Assignee: Zhu Zhu Reopen this issue since it's still a issue in 1.9 and we should fix it. > Slot leak

[jira] [Issue Comment Deleted] (FLINK-14701) Slot leaks if SharedSlotOversubscribedException happens

[ https://issues.apache.org/jira/browse/FLINK-14701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14701: Comment: was deleted (was: This issue does not exist anymore since SharedSlotOversubscribedException is r

[jira] [Updated] (FLINK-14701) Slot leaks if SharedSlotOversubscribedException happens

[ https://issues.apache.org/jira/browse/FLINK-14701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14701: Fix Version/s: (was: 1.11.0) > Slot leaks if SharedSlotOversubscribedException happens > -

[jira] [Updated] (FLINK-14701) Slot leaks if SharedSlotOversubscribedException happens

[ https://issues.apache.org/jira/browse/FLINK-14701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14701: Fix Version/s: 1.11.0 1.9.2 > Slot leaks if SharedSlotOversubscribedException happens >

[jira] [Created] (FLINK-15626) Remove legacy scheduler

Zhu Zhu created FLINK-15626: --- Summary: Remove legacy scheduler Key: FLINK-15626 URL: https://issues.apache.org/jira/browse/FLINK-15626 Project: Flink Issue Type: New Feature Components: R

[jira] [Updated] (FLINK-15626) Remove legacy scheduler

[ https://issues.apache.org/jira/browse/FLINK-15626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-15626: Priority: Critical (was: Blocker) > Remove legacy scheduler > --- > >

[jira] [Updated] (FLINK-15626) Remove legacy scheduler

[ https://issues.apache.org/jira/browse/FLINK-15626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-15626: Priority: Blocker (was: Major) > Remove legacy scheduler > --- > > Ke

[jira] [Updated] (FLINK-15582) Enable batch scheduling tests in LegacySchedulerBatchSchedulingTest for DefaultScheduler as well

[ https://issues.apache.org/jira/browse/FLINK-15582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-15582: Parent: FLINK-15626 Issue Type: Sub-task (was: Improvement) > Enable batch scheduling tests in Le

[jira] [Updated] (FLINK-15626) Remove legacy scheduler

[ https://issues.apache.org/jira/browse/FLINK-15626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-15626: Issue Type: Task (was: New Feature) > Remove legacy scheduler > --- > >

[jira] [Created] (FLINK-15629) Remove LegacyScheduler class and the consequently unused codes after this removal

Zhu Zhu created FLINK-15629: --- Summary: Remove LegacyScheduler class and the consequently unused codes after this removal Key: FLINK-15629 URL: https://issues.apache.org/jira/browse/FLINK-15629 Project: Flin

[jira] [Created] (FLINK-15651) JarHandlerTest.testRunJar fails on travis

Zhu Zhu created FLINK-15651: --- Summary: JarHandlerTest.testRunJar fails on travis Key: FLINK-15651 URL: https://issues.apache.org/jira/browse/FLINK-15651 Project: Flink Issue Type: Bug Com

[jira] [Updated] (FLINK-15632) Zookeeper HA service could not work for active kubernetes integration

[ https://issues.apache.org/jira/browse/FLINK-15632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-15632: Priority: Critical (was: Major) > Zookeeper HA service could not work for active kubernetes integration >

[jira] [Assigned] (FLINK-15632) Zookeeper HA service could not work for active kubernetes integration

[ https://issues.apache.org/jira/browse/FLINK-15632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-15632: --- Assignee: Yang Wang > Zookeeper HA service could not work for active kubernetes integration > -

[jira] [Commented] (FLINK-15632) Zookeeper HA service could not work for active kubernetes integration

[ https://issues.apache.org/jira/browse/FLINK-15632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018827#comment-17018827 ] Zhu Zhu commented on FLINK-15632: - Thanks for reporting this issue [~fly_in_gis]. I have

[jira] [Created] (FLINK-15668) Remove AlsoRunWithLegacyScheduler

Zhu Zhu created FLINK-15668: --- Summary: Remove AlsoRunWithLegacyScheduler Key: FLINK-15668 URL: https://issues.apache.org/jira/browse/FLINK-15668 Project: Flink Issue Type: Sub-task Compon

[jira] [Updated] (FLINK-14701) Slot leaks if SharedSlotOversubscribedException happens

[ https://issues.apache.org/jira/browse/FLINK-14701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14701: Priority: Critical (was: Minor) > Slot leaks if SharedSlotOversubscribedException happens > -

[jira] [Updated] (FLINK-15626) Remove legacy scheduler

[ https://issues.apache.org/jira/browse/FLINK-15626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-15626: Description: This umbrella ticket is to track the tickets to remove the legacy scheduler and related comp

[jira] [Updated] (FLINK-15626) Remove legacy scheduler

[ https://issues.apache.org/jira/browse/FLINK-15626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-15626: Description: This umbrella ticket is to track the tickets to remove the legacy scheduler and related comp

[jira] [Commented] (FLINK-15626) Remove legacy scheduler

[ https://issues.apache.org/jira/browse/FLINK-15626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17019254#comment-17019254 ] Zhu Zhu commented on FLINK-15626: - cc [~trohrmann] [~gjy] > Remove legacy scheduler > -

[jira] [Updated] (FLINK-15626) Remove legacy scheduler

[ https://issues.apache.org/jira/browse/FLINK-15626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-15626: Description: This umbrella ticket is to track the tickets to remove the legacy scheduler and related comp

[jira] [Updated] (FLINK-15626) Remove legacy scheduler

[ https://issues.apache.org/jira/browse/FLINK-15626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-15626: Description: This umbrella ticket is to track the tickets to remove the legacy scheduler and related comp

[jira] [Updated] (FLINK-15626) Remove legacy scheduler

[ https://issues.apache.org/jira/browse/FLINK-15626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-15626: Description: This umbrella ticket is to track the tickets to remove the legacy scheduler and related comp

[jira] [Closed] (FLINK-15632) Zookeeper HA service could not work for active kubernetes integration

[ https://issues.apache.org/jira/browse/FLINK-15632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-15632. --- Resolution: Fixed Fixed via: master: 003ceb9a78f90803b2a765e007e4487eead00e06 be4b713c4de8ecd6ba52fe930dfbe

[jira] [Updated] (FLINK-14701) Slot leaks if SharedSlotOversubscribedException happens

[ https://issues.apache.org/jira/browse/FLINK-14701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14701: Fix Version/s: (was: 1.9.3) 1.9.2 > Slot leaks if SharedSlotOversubscribedException

[jira] [Comment Edited] (FLINK-14701) Slot leaks if SharedSlotOversubscribedException happens

[ https://issues.apache.org/jira/browse/FLINK-14701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17021741#comment-17021741 ] Zhu Zhu edited comment on FLINK-14701 at 1/23/20 3:51 AM: -- Hi [

[jira] [Commented] (FLINK-14701) Slot leaks if SharedSlotOversubscribedException happens

[ https://issues.apache.org/jira/browse/FLINK-14701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17021741#comment-17021741 ] Zhu Zhu commented on FLINK-14701: - Hi Hequn, it is still a critical issue (slot leak) fo

[jira] [Commented] (FLINK-15813) Set default value of jobmanager.execution.failover-strategy to region

[ https://issues.apache.org/jira/browse/FLINK-15813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17028690#comment-17028690 ] Zhu Zhu commented on FLINK-15813: - I think we can do this after we have done step #3 in

[jira] [Commented] (FLINK-15917) Root Exception not shown in Web UI

[ https://issues.apache.org/jira/browse/FLINK-15917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17031365#comment-17031365 ] Zhu Zhu commented on FLINK-15917: - If we define the root exception in the Web UI to be t

[jira] [Assigned] (FLINK-17020) Introduce GlobalDataExchangeMode for JobGraph Generation

[ https://issues.apache.org/jira/browse/FLINK-17020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-17020: --- Assignee: Zhu Zhu > Introduce GlobalDataExchangeMode for JobGraph Generation >

[jira] [Commented] (FLINK-15813) Set default value of jobmanager.execution.failover-strategy to region

[ https://issues.apache.org/jira/browse/FLINK-15813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17083359#comment-17083359 ] Zhu Zhu commented on FLINK-15813: - Sorry but I mean the planned step #3 (https://jira.a

[jira] [Commented] (FLINK-17075) Add task status reconciliation between TM and JM

[ https://issues.apache.org/jira/browse/FLINK-17075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17083845#comment-17083845 ] Zhu Zhu commented on FLINK-17075: - >From the current implementation of {{TaskExecutor#up

[jira] [Assigned] (FLINK-17014) Implement PipelinedRegionSchedulingStrategy

[ https://issues.apache.org/jira/browse/FLINK-17014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-17014: --- Assignee: Zhu Zhu > Implement PipelinedRegionSchedulingStrategy > -

[jira] [Commented] (FLINK-17075) Add task status reconciliation between TM and JM

[ https://issues.apache.org/jira/browse/FLINK-17075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17083989#comment-17083989 ] Zhu Zhu commented on FLINK-17075: - I mean to not add a limit to the retry count. If the

[jira] [Comment Edited] (FLINK-17075) Add task status reconciliation between TM and JM

[ https://issues.apache.org/jira/browse/FLINK-17075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17083989#comment-17083989 ] Zhu Zhu edited comment on FLINK-17075 at 4/15/20, 10:30 AM:

[jira] [Comment Edited] (FLINK-17075) Add task status reconciliation between TM and JM

[ https://issues.apache.org/jira/browse/FLINK-17075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17083989#comment-17083989 ] Zhu Zhu edited comment on FLINK-17075 at 4/15/20, 10:30 AM:

[jira] [Commented] (FLINK-17075) Add task status reconciliation between TM and JM

[ https://issues.apache.org/jira/browse/FLINK-17075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17084588#comment-17084588 ] Zhu Zhu commented on FLINK-17075: - We can do retries for final states notification only,

[jira] [Updated] (FLINK-14234) All partition consumable events should be notified to SchedulingStrategy (SchedulerNG)

[ https://issues.apache.org/jira/browse/FLINK-14234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14234: Fix Version/s: (was: 1.11.0) > All partition consumable events should be notified to SchedulingStrateg

[jira] [Commented] (FLINK-17075) Add task status reconciliation between TM and JM

[ https://issues.apache.org/jira/browse/FLINK-17075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17084675#comment-17084675 ] Zhu Zhu commented on FLINK-17075: - Regarding the approach to report task states via hear

[jira] [Assigned] (FLINK-17021) Blink Planner set GlobalDataExchangeMode

[ https://issues.apache.org/jira/browse/FLINK-17021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-17021: --- Assignee: Zhu Zhu > Blink Planner set GlobalDataExchangeMode >

[jira] [Commented] (FLINK-17075) Add task status reconciliation between TM and JM

[ https://issues.apache.org/jira/browse/FLINK-17075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17086706#comment-17086706 ] Zhu Zhu commented on FLINK-17075: - Thanks for the explanation! I think the heartbeat way

[jira] [Assigned] (FLINK-17257) AbstractYarnClusterTest does not compile with Hadoop 2.10

[ https://issues.apache.org/jira/browse/FLINK-17257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-17257: --- Assignee: Xintong Song > AbstractYarnClusterTest does not compile with Hadoop 2.10 > --

[jira] [Closed] (FLINK-17257) AbstractYarnClusterTest does not compile with Hadoop 2.10

[ https://issues.apache.org/jira/browse/FLINK-17257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-17257. --- Resolution: Fixed Fixed via fe78c9b41333996c80c6ef8a65d1351a6d24af7e > AbstractYarnClusterTest does not com

[jira] [Closed] (FLINK-17014) Implement PipelinedRegionSchedulingStrategy

[ https://issues.apache.org/jira/browse/FLINK-17014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-17014. --- Resolution: Fixed Implemented via 67835fe8b72601dbb046683c04cc9a4cedf77db3 99cbaa929ff9f2f5c387cbf4f76a0166f

[jira] [Assigned] (FLINK-17295) Refactor the ExecutionAttemptID to consist of ExecutionVertexID and attemptNumber

[ https://issues.apache.org/jira/browse/FLINK-17295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-17295: --- Assignee: Yangze Guo > Refactor the ExecutionAttemptID to consist of ExecutionVertexID and > attem

[jira] [Assigned] (FLINK-13639) Consider refactoring of IntermediateResultPartitionID to consist of IntermediateDataSetID and partitionIndex

[ https://issues.apache.org/jira/browse/FLINK-13639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-13639: --- Assignee: Yangze Guo > Consider refactoring of IntermediateResultPartitionID to consist of > Inter

[jira] [Assigned] (FLINK-17300) Log the lineage information between ExecutionAttemptID and AllocationID

[ https://issues.apache.org/jira/browse/FLINK-17300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-17300: --- Assignee: Yangze Guo > Log the lineage information between ExecutionAttemptID and AllocationID > --

[jira] [Assigned] (FLINK-17298) Log the lineage information between SlotRequestID and AllocationID

[ https://issues.apache.org/jira/browse/FLINK-17298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-17298: --- Assignee: Yangze Guo > Log the lineage information between SlotRequestID and AllocationID > ---

[jira] [Assigned] (FLINK-17297) Log the lineage information between ExecutionAttemptID and SlotRequestID

[ https://issues.apache.org/jira/browse/FLINK-17297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-17297: --- Assignee: Yangze Guo > Log the lineage information between ExecutionAttemptID and SlotRequestID > -

[jira] [Assigned] (FLINK-17017) Implement Bulk Slot Allocation in SchedulerImpl

[ https://issues.apache.org/jira/browse/FLINK-17017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-17017: --- Assignee: Zhu Zhu > Implement Bulk Slot Allocation in SchedulerImpl > -

[jira] [Created] (FLINK-17330) Avoid scheduling deadlocks caused by intra-logical-region ALL-to-ALL blocking edges

Zhu Zhu created FLINK-17330: --- Summary: Avoid scheduling deadlocks caused by intra-logical-region ALL-to-ALL blocking edges Key: FLINK-17330 URL: https://issues.apache.org/jira/browse/FLINK-17330 Project: Fl

[jira] [Updated] (FLINK-17330) Avoid scheduling deadlocks caused by intra-logical-region ALL-to-ALL blocking edges

[ https://issues.apache.org/jira/browse/FLINK-17330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17330: Description: Imagine a job like this: A -- (pipelined FORWARD) --> B -- (blocking ALL-to-ALL) --> D A -- (

[jira] [Updated] (FLINK-17330) Avoid scheduling deadlocks caused by intra-logical-region ALL-to-ALL blocking edges

[ https://issues.apache.org/jira/browse/FLINK-17330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17330: Description: Imagine a job like this: A -- (pipelined FORWARD) --> B -- (blocking ALL-to-ALL) --> D A -- (

[jira] [Updated] (FLINK-17330) Avoid scheduling deadlocks caused by intra-logical-region ALL-to-ALL blocking edges

[ https://issues.apache.org/jira/browse/FLINK-17330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17330: Description: Imagine a job like this: A -- (pipelined FORWARD) --> B -- (blocking ALL-to-ALL) --> D A -- (

[jira] [Commented] (FLINK-17330) Avoid scheduling deadlocks caused by intra-logical-region ALL-to-ALL blocking edges

[ https://issues.apache.org/jira/browse/FLINK-17330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17090210#comment-17090210 ] Zhu Zhu commented on FLINK-17330: - cc [~gjy] [~trohrmann] Sorry this case was neglected

[jira] [Updated] (FLINK-17330) Avoid scheduling deadlocks caused by intra-logical-region ALL-to-ALL blocking edges

[ https://issues.apache.org/jira/browse/FLINK-17330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17330: Description: Imagine a job like this: A -- (pipelined FORWARD) --> B -- (blocking ALL-to-ALL) --> D A -- (

[jira] [Updated] (FLINK-17330) Avoid scheduling deadlocks caused by cyclic input dependencies between regions

[ https://issues.apache.org/jira/browse/FLINK-17330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17330: Summary: Avoid scheduling deadlocks caused by cyclic input dependencies between regions (was: Avoid sched

[jira] [Commented] (FLINK-17330) Avoid scheduling deadlocks caused by cyclic input dependencies between regions

[ https://issues.apache.org/jira/browse/FLINK-17330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17091251#comment-17091251 ] Zhu Zhu commented on FLINK-17330: - >> Would it work to say that in the first version we

[jira] [Closed] (FLINK-17020) Introduce GlobalDataExchangeMode for JobGraph Generation

[ https://issues.apache.org/jira/browse/FLINK-17020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-17020. --- Resolution: Fixed Implemented via ef4daeba7881cecc1548e387ab68d829f998dc67 > Introduce GlobalDataExchangeMo

[jira] [Commented] (FLINK-17330) Avoid scheduling deadlocks caused by cyclic input dependencies between regions

[ https://issues.apache.org/jira/browse/FLINK-17330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17091338#comment-17091338 ] Zhu Zhu commented on FLINK-17330: - Thanks for the explanation an d suggestion! This fix

[jira] [Closed] (FLINK-17021) Blink Planner set GlobalDataExchangeMode

[ https://issues.apache.org/jira/browse/FLINK-17021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-17021. --- Resolution: Fixed implemented via deb1268d26124b9b1eb1a2699f1a8d8afd1cac48 > Blink Planner set GlobalDataEx

[jira] [Updated] (FLINK-17021) Blink Planner set GlobalDataExchangeMode

[ https://issues.apache.org/jira/browse/FLINK-17021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17021: Description: Blink planner config option "table.exec.shuffle-mode" should be extended to set GlobalDataEx

[jira] [Closed] (FLINK-13639) Consider refactoring of IntermediateResultPartitionID to consist of IntermediateDataSetID and partitionIndex

[ https://issues.apache.org/jira/browse/FLINK-13639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-13639. --- Fix Version/s: 1.11.0 Resolution: Fixed Implemented via c4b44e9d4a7af9e841f785fcf0e4831f4cd5afe9 > C

[jira] [Updated] (FLINK-13639) Consider refactoring of IntermediateResultPartitionID to consist of IntermediateDataSetID and partitionIndex

[ https://issues.apache.org/jira/browse/FLINK-13639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-13639: Affects Version/s: 1.11.0 > Consider refactoring of IntermediateResultPartitionID to consist of > Interme

[jira] [Updated] (FLINK-17018) DefaultExecutionSlotAllocator allocates slots in bulks

[ https://issues.apache.org/jira/browse/FLINK-17018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17018: Summary: DefaultExecutionSlotAllocator allocates slots in bulks (was: Use Bulk Slot Allocation in Default

[jira] [Updated] (FLINK-17018) DefaultExecutionSlotAllocator allocates slots in bulks ignoring slot sharing

[ https://issues.apache.org/jira/browse/FLINK-17018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17018: Summary: DefaultExecutionSlotAllocator allocates slots in bulks ignoring slot sharing (was: DefaultExecut

[jira] [Updated] (FLINK-17018) DefaultExecutionSlotAllocator allocates slots in bulks

[ https://issues.apache.org/jira/browse/FLINK-17018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17018: Description: The DefaultExecutionSlotAllocator should allocate slot in bulks, that means the bulks of slo

[jira] [Updated] (FLINK-17018) DefaultExecutionSlotAllocator allocates slots in bulks ignoring slot sharing

[ https://issues.apache.org/jira/browse/FLINK-17018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17018: Description: The DefaultExecutionSlotAllocator should allocate slot in bulks, that means the bulks of slo

[jira] [Commented] (FLINK-17645) REAPER_THREAD.start() in SafetyNetCloseableRegistry failed, causing the repeated failover.

[ https://issues.apache.org/jira/browse/FLINK-17645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17107902#comment-17107902 ] Zhu Zhu commented on FLINK-17645: - [~sewen] I think this specific fix is valid because t

[jira] [Created] (FLINK-17714) Support custom RestartBackoffTimeStrategy

Zhu Zhu created FLINK-17714: --- Summary: Support custom RestartBackoffTimeStrategy Key: FLINK-17714 URL: https://issues.apache.org/jira/browse/FLINK-17714 Project: Flink Issue Type: Wish Co

[jira] [Created] (FLINK-17726) Scheduler should take care of tasks directly canceled by TaskManager

Zhu Zhu created FLINK-17726: --- Summary: Scheduler should take care of tasks directly canceled by TaskManager Key: FLINK-17726 URL: https://issues.apache.org/jira/browse/FLINK-17726 Project: Flink I

[jira] [Created] (FLINK-17758) Remove AdaptedRestartPipelinedRegionStrategyNG

Zhu Zhu created FLINK-17758: --- Summary: Remove AdaptedRestartPipelinedRegionStrategyNG Key: FLINK-17758 URL: https://issues.apache.org/jira/browse/FLINK-17758 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-17758) Remove AdaptedRestartPipelinedRegionStrategyNG

[ https://issues.apache.org/jira/browse/FLINK-17758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17758: Component/s: Runtime / Coordination > Remove AdaptedRestartPipelinedRegionStrategyNG > ---

[jira] [Created] (FLINK-17759) Remove RestartIndividualStrategy

Zhu Zhu created FLINK-17759: --- Summary: Remove RestartIndividualStrategy Key: FLINK-17759 URL: https://issues.apache.org/jira/browse/FLINK-17759 Project: Flink Issue Type: Sub-task Compone

[jira] [Created] (FLINK-17760) Rework tests to not rely on legacy scheduling logics in ExecutionGraph anymore

Zhu Zhu created FLINK-17760: --- Summary: Rework tests to not rely on legacy scheduling logics in ExecutionGraph anymore Key: FLINK-17760 URL: https://issues.apache.org/jira/browse/FLINK-17760 Project: Flink

[jira] [Assigned] (FLINK-17758) Remove AdaptedRestartPipelinedRegionStrategyNG

[ https://issues.apache.org/jira/browse/FLINK-17758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-17758: --- Assignee: Zhu Zhu > Remove AdaptedRestartPipelinedRegionStrategyNG > --

[jira] [Assigned] (FLINK-17759) Remove RestartIndividualStrategy

[ https://issues.apache.org/jira/browse/FLINK-17759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-17759: --- Assignee: Zhu Zhu > Remove RestartIndividualStrategy > > >

[jira] [Commented] (FLINK-15813) Set default value of jobmanager.execution.failover-strategy to region

[ https://issues.apache.org/jira/browse/FLINK-15813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110088#comment-17110088 ] Zhu Zhu commented on FLINK-15813: - Sure. I will open a PR for it. > Set default value o

[jira] [Commented] (FLINK-15813) Set default value of jobmanager.execution.failover-strategy to region

[ https://issues.apache.org/jira/browse/FLINK-15813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110134#comment-17110134 ] Zhu Zhu commented on FLINK-15813: - [~gjy] you are right. I made a mistake. We can move o

[jira] [Comment Edited] (FLINK-15813) Set default value of jobmanager.execution.failover-strategy to region

[ https://issues.apache.org/jira/browse/FLINK-15813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110134#comment-17110134 ] Zhu Zhu edited comment on FLINK-15813 at 5/18/20, 10:50 AM:

[jira] [Closed] (FLINK-17758) Remove AdaptedRestartPipelinedRegionStrategyNG

[ https://issues.apache.org/jira/browse/FLINK-17758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-17758. --- Fix Version/s: 1.11.0 Resolution: Fixed Done via fd051c9964a6193034dcf15c51f78b6b7f0bae90 > Remove A

[jira] [Closed] (FLINK-17759) Remove RestartIndividualStrategy

[ https://issues.apache.org/jira/browse/FLINK-17759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-17759. --- Fix Version/s: 1.11.0 Resolution: Fixed Done via 729ed6e4fd5c90622aa5df021232e5b554a5bbf6 > Remove R

[jira] [Updated] (FLINK-17758) Remove AdaptedRestartPipelinedRegionStrategyNG

[ https://issues.apache.org/jira/browse/FLINK-17758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17758: Affects Version/s: 1.11.0 > Remove AdaptedRestartPipelinedRegionStrategyNG > -

[jira] [Updated] (FLINK-17759) Remove RestartIndividualStrategy

[ https://issues.apache.org/jira/browse/FLINK-17759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17759: Affects Version/s: 1.11.0 > Remove RestartIndividualStrategy > > >

[jira] [Updated] (FLINK-17758) Remove AdaptedRestartPipelinedRegionStrategyNG

[ https://issues.apache.org/jira/browse/FLINK-17758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17758: Affects Version/s: (was: 1.11.0) 1.10.0 > Remove AdaptedRestartPipelinedRegionS

[jira] [Updated] (FLINK-17759) Remove RestartIndividualStrategy

[ https://issues.apache.org/jira/browse/FLINK-17759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17759: Affects Version/s: (was: 1.10.0) 1.11.0 > Remove RestartIndividualStrategy > --

[jira] [Updated] (FLINK-17758) Remove AdaptedRestartPipelinedRegionStrategyNG

[ https://issues.apache.org/jira/browse/FLINK-17758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17758: Affects Version/s: (was: 1.10.0) 1.11.0 > Remove AdaptedRestartPipelinedRegionS

[jira] [Updated] (FLINK-17759) Remove RestartIndividualStrategy

[ https://issues.apache.org/jira/browse/FLINK-17759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17759: Affects Version/s: (was: 1.11.0) 1.10.0 > Remove RestartIndividualStrategy > --

[jira] [Updated] (FLINK-16430) FLIP-119 Pipelined Region Scheduling

[ https://issues.apache.org/jira/browse/FLINK-16430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-16430: Fix Version/s: (was: 1.11.0) 1.12.0 > FLIP-119 Pipelined Region Scheduling > --

<    3   4   5   6   7   8   9   10   11   12   >