-
Notifications
You must be signed in to change notification settings - Fork 5k
Application id error in parsing log after Flink task starts #1298
Copy link
Copy link
Closed
Labels
bugSomething isn't workingSomething isn't working
Description
*For better global communication, please give priority to using English description, thx! *
Describe the bug
Flink流处理任务启动后 dolphinscheduler中的任务状态变为完成,但是Flink任务,还在运行并未执行完毕或关闭
After the Flink stream processing task is started, the task status in the dolphinscheduler becomes complete, but the Flink task is still running or not closed.
`private String findAppId(String line) {
Matcher matcher = APPLICATION_REGEX.matcher(line);
// 此处应去掉checkFindApp(line) 判断条件
// The checkFindApp(line) condition should be removed here.
if (matcher.find() && checkFindApp(line)) {
return matcher.group();
}
return null;
}`
To Reproduce
Steps to reproduce the behavior, for example:
- 创建带有Flink任务的GAG, Create a GAG with a Flink task
- 手动执行运行 , Manual execution
- 查看任务状态 , View task status
Expected behavior
A clear and concise description of what you expected to happen.
Screenshots
If applicable, add screenshots to help explain your problem.
Which version of Dolphin Scheduler:
-dev
Additional context
Add any other context about the problem here.
**Requirement or improvement
- Please describe about your requirements or improvement suggestions.
Reactions are currently unavailable
Metadata
Metadata
Assignees
Labels
bugSomething isn't workingSomething isn't working