File tree 3 files changed +5
-5
lines changed
3 files changed +5
-5
lines changed Original file line number Diff line number Diff line change 16
16
spec :
17
17
containers :
18
18
- name : spark-beam-jobserver
19
- image : apache/beam_spark_job_server:2.32 .0
19
+ image : apache/beam_spark_job_server:2.33 .0
20
20
imagePullPolicy : Always
21
21
ports :
22
22
- containerPort : 8099
@@ -49,10 +49,10 @@ spec:
49
49
type : NodePort
50
50
ports :
51
51
- port : 8099
52
- nodePort : 30090
52
+ nodePort : 32090
53
53
name : job-service
54
54
- port : 8098
55
- nodePort : 30091
55
+ nodePort : 32091
56
56
name : artifacts
57
57
# type: ClusterIP
58
58
# ports:
Original file line number Diff line number Diff line change @@ -23,7 +23,7 @@ def run():
23
23
"--artifact_endpoint=10.0.2.15:30091" ,
24
24
"--save_main_session" ,
25
25
"--environment_type=DOCKER" ,
26
- "--environment_config=docker.io/apache/beam_python3.7_sdk:2.32 .0"
26
+ "--environment_config=docker.io/apache/beam_python3.7_sdk:2.33 .0"
27
27
28
28
])
29
29
Original file line number Diff line number Diff line change 43
43
### Run Example
44
44
- Install Apache beam python library
45
45
```
46
- pip install apache-beam==2.30 .0
46
+ pip install apache-beam==2.33 .0
47
47
```
48
48
- Get the IP and input it into example.py for --job_endpoint and --artifact_endpoint. No need to change to the port number
49
49
```
You can’t perform that action at this time.
0 commit comments