You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by GitBox <gi...@apache.org> on 2022/11/01 03:18:46 UTC

[GitHub] [dolphinscheduler] RuiFG commented on issue #10904: [Feature][Flink] Flink on kubernetes

RuiFG commented on issue #10904:
URL: https://github.com/apache/dolphinscheduler/issues/10904#issuecomment-1297970125

   I'd like to join this discussion.
   
   # init
   1. write Dockerfile to workspace and add extra data
   2. pull flink base image
   3. build job image with current workspace
   4. push job image to the docker registry
   # handle
   1. check kubernetes has the same app name
   2. start flink application mode through `ShellCommandExecutor`
   3. waiting for kubernetes deployment ready
   4. listening kubernetes event and process(`logHandler` `errorHandler`...)
   # cancel
   1. cancel flink job through the flink client(use kubernetesClient exec, so we don't have to care about `kubernetes.rest-service.exposed.type`.)
   
   FlinkParameters for kubernetes need add the parameter(`extJarLibs`) , becausewe must import libs into the docker image when building it.


-- 
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: commits-unsubscribe@dolphinscheduler.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org