flink-on-k8s-operator icon indicating copy to clipboard operation
flink-on-k8s-operator copied to clipboard

Published 20 hours ago • verified publisher icon tkestack

feat:nativeFlinkSessionCluster

Open kinderyj opened this issue 5 years ago • 0 comments
trafficstars

Title: This new feature is to support flink native k8s cluster. Prerequisites： Version >= 1.10 of Apache Flink Why this feature:
Currently, there are jobManager, taskManager and job in the Spec of FlinkCluster and can create session cluster and per job cluster. But it does't support the flink's native setup on k8s feature(in Flink 1.10). Solution: In the Spec of FlinkCluster, we introduce a new property, which called "nativeSessionClusterJob". With this property, only a job will be created. This job is used to create a native session cluster, the whole process to create the native session cluster is done by the Flink kernel itself.

kinderyj avatar Apr 25 '20 15:04 kinderyj