[FLINK-16907] did not react to cancelling signal for 30 seconds, but is stuck in method:

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Later
• Affects Version/s: 1.9.1
• Component/s: Runtime / Task
• Labels: test

Environment

Hadoop version: 3.1.1.3.1.0.0-78
flink-1.9.1
hdp-3.1.0.0-78-kafka

• Flags: Important
• Assignee: Unassigned
• Reporter: 辛羿彤
• Created: 01/Apr/20 08:12
• Updated: 03/Apr/20 14:10
• Resolved: 02/Apr/20 12:55

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);

//There is no response at this point

//alterTableorCount() is Methods  to  Execute the Linux shell command

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);
}
}