This is an automated email from the ASF dual-hosted git repository.
damccorm pushed a commit to branch release-2.61.0
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/release-2.61.0 by this push:
new 025384bda66 Revert "Fixed the broken beam python on flink with
PortableRunner" (#33179)
025384bda66 is described below
commit 025384bda66670718354f198041f3f638597bf10
Author: Danny McCormick <[email protected]>
AuthorDate: Wed Nov 20 12:50:27 2024 -0500
Revert "Fixed the broken beam python on flink with PortableRunner" (#33179)
Co-authored-by: Yi Hu <[email protected]>
---
runners/flink/job-server-container/Dockerfile | 4 +---
website/www/site/content/en/documentation/runners/flink.md | 11 +++--------
2 files changed, 4 insertions(+), 11 deletions(-)
diff --git a/runners/flink/job-server-container/Dockerfile
b/runners/flink/job-server-container/Dockerfile
index 5f19aa0dc85..cbb73512400 100644
--- a/runners/flink/job-server-container/Dockerfile
+++ b/runners/flink/job-server-container/Dockerfile
@@ -28,6 +28,4 @@ COPY target/LICENSE /opt/apache/beam/
COPY target/NOTICE /opt/apache/beam/
WORKDIR /opt/apache/beam
-
-# Add a conditional check for a mounted volume. This allows passing flink
configs.
-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"]
+ENTRYPOINT ["./flink-job-server.sh"]
diff --git a/website/www/site/content/en/documentation/runners/flink.md
b/website/www/site/content/en/documentation/runners/flink.md
index af73751c256..e9522d76e83 100644
--- a/website/www/site/content/en/documentation/runners/flink.md
+++ b/website/www/site/content/en/documentation/runners/flink.md
@@ -207,17 +207,12 @@ To run a pipeline on an embedded Flink cluster:
{{< /paragraph >}}
{{< paragraph class="language-portable" >}}
-(1) Start the JobService endpoint: `docker run --net=host
apache/beam_flink1.18_job_server:latest`
+(1) Start the JobService endpoint: `docker run --net=host
apache/beam_flink1.10_job_server:latest`
{{< /paragraph >}}
{{< paragraph class="language-portable" >}}
The JobService is the central instance where you submit your Beam pipeline to.
-It creates a Flink job from your pipeline and executes it.
-You might encounter an error message like `Caused by: java.io.IOException:
Insufficient number of network buffers:...`.
-This can be resolved by providing a Flink configuration file to override the
default settings.
-You can find an example configuration file
[here](https://github.com/apache/beam/blob/master/runners/flink/src/test/resources/flink-conf.yaml).
-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:
-`docker run --net=host -v <your_flink_conf_dir>:/flink-conf beam-flink-runner
apache/beam_flink1.18_job_server:latest`
+The JobService will create a Flink job for the pipeline and execute the job.
{{< /paragraph >}}
{{< paragraph class="language-portable" >}}
@@ -248,7 +243,7 @@ To run on a separate [Flink
cluster](https://ci.apache.org/projects/flink/flink-
{{< /paragraph >}}
{{< paragraph class="language-portable" >}}
-(2) Start JobService with Flink Rest endpoint: `docker run --net=host
apache/beam_flink1.18_job_server:latest --flink-master=localhost:8081`.
+(2) Start JobService with Flink Rest endpoint: `docker run --net=host
apache/beam_flink1.10_job_server:latest --flink-master=localhost:8081`.
{{< /paragraph >}}
{{< paragraph class="language-portable" >}}
