Merge pull request #305 from spotify/stefaniem/add-region-kubernetes-ops

Add region and kubernetes cluster options
spotify · Jul 27, 2023 · c1f105d · c1f105d
2 parents 31b7063 + e0f03a7
commit c1f105d
Show file tree

Hide file tree

Showing 4 changed files with 103 additions and 67 deletions.
diff --git a/gen/pb-go/flyteidl-flink/flink.pb.go b/gen/pb-go/flyteidl-flink/flink.pb.go
diff --git a/gen/pb-go/flyteidl-flink/flink.pb.validate.go b/gen/pb-go/flyteidl-flink/flink.pb.validate.go
diff --git a/gen/pb-protodoc/flyteidl-flink/flink.proto.rst b/gen/pb-protodoc/flyteidl-flink/flink.proto.rst
@@ -226,6 +226,8 @@ Custom Proto for Flink Plugin.
     "image": "...",
     "flinkVersion": "...",
     "parallelism": "...",
+    "kubernetesClusterName": "...",
+    "kubernetesClusterRegion": "...",
     "jflyte": "{...}"
   }
 
@@ -279,6 +281,16 @@ flinkVersion
 parallelism
   (`int32 <https://developers.google.com/protocol-buffers/docs/proto#scalar>`_) 
 
+.. _api_field_flyteidl_flink.FlinkJob.kubernetesClusterName:
+
+kubernetesClusterName
+  (`string <https://developers.google.com/protocol-buffers/docs/proto#scalar>`_) 
+
+.. _api_field_flyteidl_flink.FlinkJob.kubernetesClusterRegion:
+
+kubernetesClusterRegion
+  (`string <https://developers.google.com/protocol-buffers/docs/proto#scalar>`_) 
+
 .. _api_field_flyteidl_flink.FlinkJob.jflyte:
 
 jflyte
@@ -293,7 +305,7 @@ jflyte
 flyteidl_flink.JobExecutionInfo
 -------------------------------
 
-`[flyteidl_flink.JobExecutionInfo proto] <https://github.com/lyft/flyteidl/blob/master/protos/flyteidl-flink/flink.proto#L72>`_
+`[flyteidl_flink.JobExecutionInfo proto] <https://github.com/lyft/flyteidl/blob/master/protos/flyteidl-flink/flink.proto#L74>`_
 
 
 .. code-block:: json
@@ -314,7 +326,7 @@ id
 flyteidl_flink.JobManagerExecutionInfo
 --------------------------------------
 
-`[flyteidl_flink.JobManagerExecutionInfo proto] <https://github.com/lyft/flyteidl/blob/master/protos/flyteidl-flink/flink.proto#L74>`_
+`[flyteidl_flink.JobManagerExecutionInfo proto] <https://github.com/lyft/flyteidl/blob/master/protos/flyteidl-flink/flink.proto#L76>`_
 
 
 .. code-block:: json
@@ -335,7 +347,7 @@ ingressURLs
 flyteidl_flink.FlinkExecutionInfo
 ---------------------------------
 
-`[flyteidl_flink.FlinkExecutionInfo proto] <https://github.com/lyft/flyteidl/blob/master/protos/flyteidl-flink/flink.proto#L76>`_
+`[flyteidl_flink.FlinkExecutionInfo proto] <https://github.com/lyft/flyteidl/blob/master/protos/flyteidl-flink/flink.proto#L78>`_
 
 
 .. code-block:: json

diff --git a/protos/flyteidl-flink/flink.proto b/protos/flyteidl-flink/flink.proto
@@ -64,6 +64,8 @@ message FlinkJob {
   string image = 8;
   string flinkVersion = 9;
   int32 parallelism = 10 [ (validate.rules).int32.gte = 0 ];
+  string kubernetesClusterName = 11;
+  string kubernetesClusterRegion = 12;
 
   // if using experiment flytekit-java this will contain all artifacts required
   // to run the task