[
https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaogang zhou updated FLINK-29545:
----------------------------------
Description:
the task dag is like attached file. when the task is started to consume from
earliest offset, it will stop when the first checkpoint triggers.
is it normal?, for sink is busy 0 and the second operator has 100 backpressure
and check the checkpoint summary, we can find some of the sub task is n/a.
can anybody help me on this issue?
thanks
was:
the task dag is like attached file. when the task is started to consume from
earliest offset, it will stop when the first checkpoint trigger.
> kafka consuming stop when trigger first checkpoint
> --------------------------------------------------
>
> Key: FLINK-29545
> URL: https://issues.apache.org/jira/browse/FLINK-29545
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Checkpointing, Runtime / Network
> Affects Versions: 1.13.3
> Reporter: xiaogang zhou
> Priority: Critical
> Attachments: backpressure 100 busy 0.png, task acknowledge na.png,
> task dag.png
>
>
> the task dag is like attached file. when the task is started to consume from
> earliest offset, it will stop when the first checkpoint triggers.
>
> is it normal?, for sink is busy 0 and the second operator has 100 backpressure
>
> and check the checkpoint summary, we can find some of the sub task is n/a.
>
> can anybody help me on this issue?
>
> thanks
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
