Hi Talat, For most streaming pipelines, we have to restart the whole pipeline no matter the scheduler used because they're a single pipelined region. One limitation of AdaptiveScheduler is the lack of support for local recovery. This will be addressed in Flink 1.18 [1].
[1] https://issues.apache.org/jira/browse/FLINK-21450 Best, D. On Tue, Apr 11, 2023 at 4:35 AM Weihua Hu <huweihua....@gmail.com> wrote: > Hi, > > AFAIK, the reactive mode always restarts the whole pipeline now. > > Best, > Weihua > > > On Tue, Apr 11, 2023 at 8:38 AM Talat Uyarer via user < > user@flink.apache.org> wrote: > >> Hi All, >> >> We use Flink 1.13 with reactive mode for our streaming jobs. When we have >> an issue/exception on our pipeline. Flink rescheduled all tasks. Is there >> any way to reschedule only task that had exceptions ? >> >> Thanks >> >
