[
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
Description:
public UserInfo map(String s) throws Exception {
if (StringUtils.isBlank(s)){
return null;
}
JSONObject alterTable = KafkaOnHDFSAsHiveShell.alterTableorCount(this.doday,
this.shellPath, this.logPath + "/" + this.tableName + "_" + this.doday +
".log", this.dbName, this.tableName, this.part, true);
JSONObject count = KafkaOnHDFSAsHiveShell.alterTableorCount(this.doday,
this.shellPath, this.logPath + "/" + this.tableName + "_" + this.doday +
".log", this.dbName, this.tableName, this.part, false);
{color:#FF0000}//There is no response at this point{color}
{color:#FF0000}//alterTableorCount() is Methods to
{color}{color:#FF0000}Execute the Linux shell command{color}
if (!alterTable.isEmpty()) {
if (alterTable.containsKey("msg") && alterTable.containsKey("value")) {
System.out.println(alterTable.getString("msg"));
}
}
if (!count.isEmpty()) {
if (count.containsKey("msg") && count.containsKey("value")) {
System.out.println(count.getString("msg"));
System.out.println(count.getString("value"));
}
}
//将传入的Json格式转为实体类
return JSONObject.parseObject(s, UserInfo.class);
}
}
was:
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)
> 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: Runtime / Task
> 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: Major
> Labels: test
> Fix For: 1.9.1
>
> Attachments: flink-root-taskexecutor-1-dqapp121002.log
>
>
> public UserInfo map(String s) throws Exception {
> if (StringUtils.isBlank(s)){
> return null;
> }
> JSONObject alterTable = KafkaOnHDFSAsHiveShell.alterTableorCount(this.doday,
> this.shellPath, this.logPath + "/" + this.tableName + "_" + this.doday +
> ".log", this.dbName, this.tableName, this.part, true);
> JSONObject count = KafkaOnHDFSAsHiveShell.alterTableorCount(this.doday,
> this.shellPath, this.logPath + "/" + this.tableName + "_" + this.doday +
> ".log", this.dbName, this.tableName, this.part, false);
> {color:#FF0000}//There is no response at this point{color}
> {color:#FF0000}//alterTableorCount() is Methods to
> {color}{color:#FF0000}Execute the Linux shell command{color}
> if (!alterTable.isEmpty()) {
> if (alterTable.containsKey("msg") && alterTable.containsKey("value")) {
> System.out.println(alterTable.getString("msg"));
> }
> }
> if (!count.isEmpty()) {
> if (count.containsKey("msg") && count.containsKey("value")) {
> System.out.println(count.getString("msg"));
> System.out.println(count.getString("value"));
> }
> }
> //将传入的Json格式转为实体类
> return JSONObject.parseObject(s, UserInfo.class);
> }
> }
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
