[
https://issues.apache.org/jira/browse/FLINK-16907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
辛羿彤 updated FLINK-16907:
------------------------
Fix Version/s: 1.9.1
Flags: Important
Description:
2020-04-01 16:44:02,516 WARN org.apache.flink.runtime.taskmanager.Task - Task
'Source: Custom Source -> Map -> Sink: Unnamed (1/1)' did not react to
cancelling signal for 30 seconds, but is stuck in method:
org.apache.flink.streaming.runtime.tasks.SourceStreamTask.runAlternativeMailboxLoop(SourceStreamTask.java:149)
org.apache.flink.streaming.runtime.tasks.SourceStreamTask.processInput(SourceStreamTask.java:122)
org.apache.flink.streaming.runtime.tasks.StreamTask.run(StreamTask.java:301)
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:406)
org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:705)
org.apache.flink.runtime.taskmanager.Task.run(Task.java:530)
java.lang.Thread.run(Thread.java:748)
2020-04-01 16:44:32,517 WARN org.apache.flink.runtime.taskmanager.Task - Task
'Source: Custom Source -> Map -> Sink: Unnamed (1/1)' did not react to
cancelling signal for 30 seconds, but is stuck in method:
org.apache.flink.streaming.runtime.tasks.SourceStreamTask.runAlternativeMailboxLoop(SourceStreamTask.java:149)
org.apache.flink.streaming.runtime.tasks.SourceStreamTask.processInput(SourceStreamTask.java:122)
org.apache.flink.streaming.runtime.tasks.StreamTask.run(StreamTask.java:301)
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:406)
org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:705)
org.apache.flink.runtime.taskmanager.Task.run(Task.java:530)
java.lang.Thread.run(Thread.java:748)
was:
接入kafka数据时在map方法卡住无响应
Google Translate: I get stuck in the map method when accessing kafka data.
Priority: Blocker (was: Major)
> did not react to cancelling signal for 30 seconds, but is stuck in method:
> --------------------------------------------------------------------------
>
> Key: FLINK-16907
> URL: https://issues.apache.org/jira/browse/FLINK-16907
> Project: Flink
> Issue Type: Bug
> Components: API / DataStream
> Affects Versions: 1.9.1
> Environment: Hadoop version: 3.1.1.3.1.0.0-78
> flink-1.9.1
> hdp-3.1.0.0-78-kafka
> Reporter: 辛羿彤
> Priority: Blocker
> Labels: test
> Fix For: 1.9.1
>
>
> 2020-04-01 16:44:02,516 WARN org.apache.flink.runtime.taskmanager.Task - Task
> 'Source: Custom Source -> Map -> Sink: Unnamed (1/1)' did not react to
> cancelling signal for 30 seconds, but is stuck in method:
> org.apache.flink.streaming.runtime.tasks.SourceStreamTask.runAlternativeMailboxLoop(SourceStreamTask.java:149)
> org.apache.flink.streaming.runtime.tasks.SourceStreamTask.processInput(SourceStreamTask.java:122)
> org.apache.flink.streaming.runtime.tasks.StreamTask.run(StreamTask.java:301)
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:406)
> org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:705)
> org.apache.flink.runtime.taskmanager.Task.run(Task.java:530)
> java.lang.Thread.run(Thread.java:748)
> 2020-04-01 16:44:32,517 WARN org.apache.flink.runtime.taskmanager.Task - Task
> 'Source: Custom Source -> Map -> Sink: Unnamed (1/1)' did not react to
> cancelling signal for 30 seconds, but is stuck in method:
> org.apache.flink.streaming.runtime.tasks.SourceStreamTask.runAlternativeMailboxLoop(SourceStreamTask.java:149)
> org.apache.flink.streaming.runtime.tasks.SourceStreamTask.processInput(SourceStreamTask.java:122)
> org.apache.flink.streaming.runtime.tasks.StreamTask.run(StreamTask.java:301)
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:406)
> org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:705)
> org.apache.flink.runtime.taskmanager.Task.run(Task.java:530)
> java.lang.Thread.run(Thread.java:748)
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
