You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by Weihua Hu <hu...@gmail.com> on 2022/06/16 13:10:05 UTC

Re: flink 1.10.1 flinkui 取消任务 任务一直处于cancalling中 很长时间才取消掉

Hi,
建议看一下 JobManager 的日志,检查下再 Canceling 时作业是在什么状态。也检查下 Task 是否使用 UDF ,在 UDF
close 时是否有耗时的操作。

Best,
Weihua


On Thu, Jun 16, 2022 at 3:11 PM 沈保源 <75...@qq.com.invalid> wrote:

> flink 1.10.1 flinkui 取消任务&nbsp; 任务一直处于cancalling中 很长时间才取消掉

Re: flink 1.10.1 flinkui 取消任务 任务一直处于cancalling中 很长时间才取消掉

Posted by Lijie Wang <wa...@gmail.com>.
Hi,方便的话,可以截一下一直处于 canceling 状态的 task 所在 TM 的栈,这样可以看出 task 线程卡在哪里了

Best,
Lijie

沈保源 <75...@qq.com.invalid> 于2022年6月17日周五 16:47写道:

> JobManager 的日志并没有什么东西,Task也没有使用udf,只是最简单的cep
> 模式组&nbsp;&nbsp;目前出现这种问题是在cep中,如果在这段时间内出现大量符合模式1
> 但是没有模式2的日志,当关闭时会出现这种情况,同时cep api 在这种情况下水位线延迟很高&nbsp; 是这个问题引起的吗?
> task出现了一个日志是Discovered coordinator xxxx:9092 (id: 2147483647 rack: null)
> for group merge_341
>
>
>
>
> ------------------&nbsp;原始邮件&nbsp;------------------
> 发件人: "Weihua Hu"<huweihua.ckl@gmail.com&gt;;
> 发送时间: 2022年6月16日(星期四) 晚上9:10
> 收件人: "user-zh"<user-zh@flink.apache.org&gt;;
> 主题: Re: flink 1.10.1 flinkui 取消任务 任务一直处于cancalling中 很长时间才取消掉
>
>
>
> Hi,
> 建议看一下 JobManager 的日志,检查下再 Canceling 时作业是在什么状态。也检查下 Task 是否使用 UDF ,在 UDF
> close 时是否有耗时的操作。
>
> Best,
> Weihua
>
>
> On Thu, Jun 16, 2022 at 3:11 PM 沈保源 <757434361@qq.com.invalid&gt; wrote:
>
> &gt; flink 1.10.1 flinkui 取消任务&amp;nbsp; 任务一直处于cancalling中 很长时间才取消掉

回复: flink 1.10.1 flinkui 取消任务 任务一直处于cancalling中 很长时间才取消掉

Posted by 沈保源 <75...@qq.com.INVALID>.
JobManager 的日志并没有什么东西,Task也没有使用udf,只是最简单的cep 模式组&nbsp;&nbsp;目前出现这种问题是在cep中,如果在这段时间内出现大量符合模式1 但是没有模式2的日志,当关闭时会出现这种情况,同时cep api 在这种情况下水位线延迟很高&nbsp; 是这个问题引起的吗? task出现了一个日志是Discovered coordinator xxxx:9092 (id: 2147483647 rack: null) for group merge_341




------------------&nbsp;原始邮件&nbsp;------------------
发件人: "Weihua Hu"<huweihua.ckl@gmail.com&gt;; 
发送时间: 2022年6月16日(星期四) 晚上9:10
收件人: "user-zh"<user-zh@flink.apache.org&gt;; 
主题: Re: flink 1.10.1 flinkui 取消任务 任务一直处于cancalling中 很长时间才取消掉



Hi,
建议看一下 JobManager 的日志,检查下再 Canceling 时作业是在什么状态。也检查下 Task 是否使用 UDF ,在 UDF
close 时是否有耗时的操作。

Best,
Weihua


On Thu, Jun 16, 2022 at 3:11 PM 沈保源 <757434361@qq.com.invalid&gt; wrote:

&gt; flink 1.10.1 flinkui 取消任务&amp;nbsp; 任务一直处于cancalling中 很长时间才取消掉