开发者社区 问答 正文

Flink 中作业部署方式K8s application mode的说明和示例分别是什么?

Flink 中作业部署方式K8s application mode的说明和示例分别是什么?

展开
收起
游客qzzytmszf3zhq 2021-12-07 15:14:02 789 分享 版权
1 条回答
写回答
取消 提交回答
  • 说明:使用该方式执行作业时,作业会提交到 K8s 集群,以 application mode 的方式执行。

    示例:

    ./bin/flink run-application --target kubernetes-application --parallelism 8 -Dkubernetes.cluster-id**= -Dtaskmanager.memory.process.size=4096m -Dkubernetes.taskmanager.cpu=2 -Dtaskmanager.numberOfTaskSlots=4 -Dkubernetes.container.image=** \

    --pyModule table_api_demo --pyFiles file:///path/to/table_api_demo.py

    2021-12-07 15:14:14
    赞同 展开评论