[GitHub] [incubator-dolphinscheduler] Right-ydd opened a new issue #1298: Application id error in parsing log after Flink task starts

[GitBox <gi...@apache.org>]

Right-ydd opened a new issue #1298:  Application id error in parsing log after Flink task starts
URL: https://github.com/apache/incubator-dolphinscheduler/issues/1298
 
 
   *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:
   1. 创建带有Flink任务的GAG，   Create a GAG with a Flink task
   2. 手动执行运行 ，  Manual execution
   3. 查看任务状态 ，   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.
   

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services