[
https://issues.apache.org/jira/browse/FLINK-18577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245108#comment-17245108
]
Arvid Heise commented on FLINK-18577:
-------------------------------------
Sorry for the late reply. Jira is not the best place to ask - user mailing list
is more appropriate: https://flink.apache.org/community.html#mailing-lists
For your question, the task is currently blocking on the checkpoint log, which
is used to synchronize the task thread with the source thread of legacy
sources. It's normal and there is nothing that you can do if you haven't
implemented the source itself.
> Mail.run Blocked By the Legacy Source Thread
> --------------------------------------------
>
> Key: FLINK-18577
> URL: https://issues.apache.org/jira/browse/FLINK-18577
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Task
> Affects Versions: 1.11.0
> Reporter: zhangyunyun
> Priority: Major
>
> I found the Bocked log in the "Thread Dump", It like this:
> ```
> "Source: [Kafka:FILEBEAT_LOG] -> Flat Map -> Timestamps/Watermarks ->
> [CategoryFill] (4/12)" Id=95 BLOCKED on java.lang.Object@297f1806 owned by
> "Legacy Source Thread - Source: [Kafka:FILEBEAT_LOG] -> Flat Map ->
> Timestamps/Watermarks -> [CategoryFill] (4/12)" Id=178
> at
> org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:91)
> - blocked on java.lang.Object@297f1806
> at org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:78)
> at
> org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMail(MailboxProcessor.java:282)
> at
> org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxStep(MailboxProcessor.java:190)
> at
> org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:181)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:558)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:530)
> at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:721)
> ```
> Is there somethine wrong with my code? What should I do?
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
