Skip to content
This repository was archived by the owner on Sep 2, 2022. It is now read-only.

Commit 1deb568

Browse files
committed
Add required fields to job cluster samples
1 parent f3226e1 commit 1deb568

File tree

2 files changed

+4
-0
lines changed

2 files changed

+4
-0
lines changed

config/samples/flinkoperator_v1beta1_flinkjobcluster.yaml

+2
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@ spec:
2020
image:
2121
name: flink:1.8.2
2222
jobManager:
23+
accessScope: Cluster
2324
ports:
2425
ui: 8081
2526
resources:
@@ -37,5 +38,6 @@ spec:
3738
className: org.apache.flink.streaming.examples.wordcount.WordCount
3839
args: ["--input", "./README.txt"]
3940
parallelism: 2
41+
restartPolicy: Never
4042
flinkProperties:
4143
taskmanager.numberOfTaskSlots: "1"

config/samples/flinkoperator_v1beta1_remotejobjar.yaml

+2
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,7 @@ spec:
2424
image:
2525
name: flink:1.8.2
2626
jobManager:
27+
accessScope: Cluster
2728
ports:
2829
ui: 8081
2930
resources:
@@ -53,6 +54,7 @@ spec:
5354
- "cp"
5455
- "gs://my-bucket/wordcount.jar"
5556
- "/cache/wordcount.jar"
57+
restartPolicy: Never
5658
gcpConfig:
5759
serviceAccount:
5860
secretName: "gcp-service-account"

0 commit comments

Comments
 (0)