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

Commit

Permalink
Add required fields to job cluster samples
Browse files Browse the repository at this point in the history
  • Loading branch information
jaegoo.kim committed Feb 24, 2022
1 parent f3226e1 commit 7fff52b
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 0 deletions.
2 changes: 2 additions & 0 deletions config/samples/flinkoperator_v1beta1_flinkjobcluster.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -20,6 +20,7 @@ spec:
image:
name: flink:1.8.2
jobManager:
accessScope: Cluster
ports:
ui: 8081
resources:
Expand All @@ -37,5 +38,6 @@ spec:
className: org.apache.flink.streaming.examples.wordcount.WordCount
args: ["--input", "./README.txt"]
parallelism: 2
restartPolicy: Never
flinkProperties:
taskmanager.numberOfTaskSlots: "1"
2 changes: 2 additions & 0 deletions config/samples/flinkoperator_v1beta1_remotejobjar.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,7 @@ spec:
image:
name: flink:1.8.2
jobManager:
accessScope: Cluster
ports:
ui: 8081
resources:
Expand Down Expand Up @@ -53,6 +54,7 @@ spec:
- "cp"
- "gs://my-bucket/wordcount.jar"
- "/cache/wordcount.jar"
restartPolicy: Never
gcpConfig:
serviceAccount:
secretName: "gcp-service-account"
Expand Down

0 comments on commit 7fff52b

Please sign in to comment.