Skip to content
This repository was archived by the owner on May 8, 2025. It is now read-only.

Commit 9fabb5d

Browse files
authored
Upgrade beam to 2.22.0 and flink runner to 1.10.1 in without_job_server examples (#301)
1 parent 8da9956 commit 9fabb5d

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

examples/beam/without_job_server/beam_flink_cluster.yaml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ metadata:
44
name: beam-flink-cluster
55
spec:
66
image:
7-
name: flink:1.8.1
7+
name: flink:1.10.1
88
jobManager:
99
resources:
1010
limits:
@@ -16,7 +16,7 @@ spec:
1616
memory: "2Gi"
1717
sidecars:
1818
- name: beam-worker-pool
19-
image: apachebeam/python3.7_sdk:2.18.0
19+
image: apache/beam_python3.7_sdk:2.22.0
2020
args: ["--worker_pool"]
2121
flinkProperties:
2222
taskmanager.numberOfTaskSlots: "1"

examples/beam/without_job_server/beam_wordcount_py.yaml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@ spec:
1010
spec:
1111
containers:
1212
- name: beam-wordcount-py
13-
image: apachebeam/python3.7_sdk:2.18.0
13+
image: apache/beam_python3.7_sdk:2.22.0
1414
command: ["python3"]
1515
args:
1616
- "-m"

0 commit comments

Comments
 (0)