Skip to content

Commit 025384b

Browse files
damccormAbacn
andauthored
Revert "Fixed the broken beam python on flink with PortableRunner" (#33179)
Co-authored-by: Yi Hu <[email protected]>
1 parent e3948fa commit 025384b

File tree

2 files changed

+4
-11
lines changed
  • runners/flink/job-server-container
  • website/www/site/content/en/documentation/runners

2 files changed

+4
-11
lines changed

runners/flink/job-server-container/Dockerfile

+1-3
Original file line numberDiff line numberDiff line change
@@ -28,6 +28,4 @@ COPY target/LICENSE /opt/apache/beam/
2828
COPY target/NOTICE /opt/apache/beam/
2929

3030
WORKDIR /opt/apache/beam
31-
32-
# Add a conditional check for a mounted volume. This allows passing flink configs.
33-
ENTRYPOINT ["/bin/sh", "-c", "if [ -d \"/flink-conf\" ]; then /opt/apache/beam/flink-job-server.sh --flink-conf-dir /flink-conf; else /opt/apache/beam/flink-job-server.sh; fi"]
31+
ENTRYPOINT ["./flink-job-server.sh"]

website/www/site/content/en/documentation/runners/flink.md

+3-8
Original file line numberDiff line numberDiff line change
@@ -207,17 +207,12 @@ To run a pipeline on an embedded Flink cluster:
207207
{{< /paragraph >}}
208208

209209
{{< paragraph class="language-portable" >}}
210-
(1) Start the JobService endpoint: `docker run --net=host apache/beam_flink1.18_job_server:latest`
210+
(1) Start the JobService endpoint: `docker run --net=host apache/beam_flink1.10_job_server:latest`
211211
{{< /paragraph >}}
212212

213213
{{< paragraph class="language-portable" >}}
214214
The JobService is the central instance where you submit your Beam pipeline to.
215-
It creates a Flink job from your pipeline and executes it.
216-
You might encounter an error message like `Caused by: java.io.IOException: Insufficient number of network buffers:...`.
217-
This can be resolved by providing a Flink configuration file to override the default settings.
218-
You can find an example configuration file [here](https://github.com/apache/beam/blob/master/runners/flink/src/test/resources/flink-conf.yaml).
219-
To start the Job Service endpoint with your custom configuration, mount a local directory containing your Flink configuration to the `/flink-conf` path in the Docker container:
220-
`docker run --net=host -v <your_flink_conf_dir>:/flink-conf beam-flink-runner apache/beam_flink1.18_job_server:latest`
215+
The JobService will create a Flink job for the pipeline and execute the job.
221216
{{< /paragraph >}}
222217

223218
{{< paragraph class="language-portable" >}}
@@ -248,7 +243,7 @@ To run on a separate [Flink cluster](https://ci.apache.org/projects/flink/flink-
248243
{{< /paragraph >}}
249244

250245
{{< paragraph class="language-portable" >}}
251-
(2) Start JobService with Flink Rest endpoint: `docker run --net=host apache/beam_flink1.18_job_server:latest --flink-master=localhost:8081`.
246+
(2) Start JobService with Flink Rest endpoint: `docker run --net=host apache/beam_flink1.10_job_server:latest --flink-master=localhost:8081`.
252247
{{< /paragraph >}}
253248

254249
{{< paragraph class="language-portable" >}}

0 commit comments

Comments
 (0)