Skip to content

Commit

Permalink
Polished the doc
Browse files Browse the repository at this point in the history
  • Loading branch information
liferoad committed Nov 8, 2024
1 parent 97fa43b commit 4b7bcd8
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions website/www/site/content/en/documentation/runners/flink.md
Original file line number Diff line number Diff line change
Expand Up @@ -212,11 +212,11 @@ To run a pipeline on an embedded Flink cluster:

{{< paragraph class="language-portable" >}}
The JobService is the central instance where you submit your Beam pipeline to.
The JobService will create a Flink job for the pipeline and execute the job.
Note that you might see the error message like `Caused by: java.io.IOException: Insufficient number of network buffers:...`,
which can be fixed by passing a Flink configuration file to change the default ones.
One example can be found [here](https://github.com/apache/beam/blob/master/runners/flink/src/test/resources/flink-conf.yaml).
Then start the JobService endpoint by mounting a local configuration directory to `/flink`:
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`
{{< /paragraph >}}

Expand Down

0 comments on commit 4b7bcd8

Please sign in to comment.