Skip to content

Commit

Permalink
Fix flink sql kill yarn application and getJobStatus fail
Browse files Browse the repository at this point in the history
  • Loading branch information
ChengJie1053 committed Dec 14, 2023
1 parent d914fbd commit c79bb47
Show file tree
Hide file tree
Showing 3 changed files with 8 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -631,7 +631,7 @@ class TaskExecutionServiceImpl
if (null != task) {
sendToEntrance(task, ResponseTaskLog(logUpdateEvent.taskId, logUpdateEvent.log))
} else {
logger.error("Task cannot null! logupdateEvent: " + logUpdateEvent.taskId)
logger.warn("Task cannot null! logupdateEvent: " + logUpdateEvent.taskId)
}
} else if (null != lastTask) {
val executor = executorManager.getReportExecutor
Expand Down Expand Up @@ -733,7 +733,7 @@ class TaskExecutionServiceImpl
if (null != executor) {
executor.getTaskById(taskId)
} else {
logger.error(s"Executor of taskId : $taskId is not cached.")
logger.warn(s"Executor of taskId : $taskId is not cached.")
null
}
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -236,6 +236,11 @@ class FlinkSQLComputationExecutor(
super.close()
}

override def tryShutdown(): Boolean = {
Utils.tryAndWarn(close())
super.tryShutdown()
}

}

class FlinkSQLStatusListener(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -47,7 +47,7 @@
<loggers>
<root level="INFO">
<appender-ref ref="stderr"/>
<appender-ref ref="Console"/>
<appender-ref ref="RollingFile"/>
<appender-ref ref="Send"/>
</root>
<logger name="org.apache.hadoop.hive.ql.exec.StatsTask" level="info" additivity="true">
Expand Down

0 comments on commit c79bb47

Please sign in to comment.