3043442162 commented on issue #16886: URL: https://github.com/apache/dolphinscheduler/issues/16886#issuecomment-2543920014
Design detail: The current FlinkTask has shell and flink api submissions, and I plan to change shell type FlinkTask to support k8s Execution process analysis: FlinkTask inherits the AbstractYarnTask and implements its own getScript method. AbstractYarnTask invokes FlinkTask's initSctipt method to generate a script, which is executed by ShellCommandExecutor  当前的FlinkTask 有shell和flink api两种提交方式，我预计改动shell类型的FlinkTask，以使得其支持k8s 执行流程分析： FlinkTask继承了AbstractYarnTask，并实现了自己的getScript方法。AbstractYarnTask会调用FlinkTask的initSctipt方法生成脚本，该脚本会由ShellCommandExecutor执行。 -- 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. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
