Re: Query on RestartPipelinedRegionFailoverStrategy

Hi Prabhu, Whether the tasks are in the same region depends on the DistributionPattern between upstream and downstream Operators. For example, if the DistributionPattern from A to B is ALL_TO_ALL, all subtasks for A and B will be in the same range. Otherwise, if the DistributionPattern is POINTWIS

Re: Query on RestartPipelinedRegionFailoverStrategy

Yes i expected the same. But all the tasks goes into one region and RestartPipelinedRegionFailoverStrategy restarts all of them. I see this strategy does not make any difference from RestartAllFailoverStrategy in stream execution mode. It could only help in Batch execution mode where Blocking resul

Re: Query on RestartPipelinedRegionFailoverStrategy

Hi Prabhu, If the edge between a -> b -> c -> d -> e all are point-wise, In theory, it should form two regions. Best regards, Weijie Prabhu Joseph 于2023年5月15日周一 09:58写道： > Hi, I am testing the Flink Fine-Grained Recovery >

Query on RestartPipelinedRegionFailoverStrategy

Hi, I am testing the Flink Fine-Grained Recovery from Task Failures on Flink 1.17 and am facing some issues where I need some advice. Have a jobgraph below with 5 operators, and all connections b