This is an automated email from the ASF dual-hosted git repository.
ibzib pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new 5a0ed84 [BEAM-7973] py: shut down Flink job server automatically
new 98e553b Merge pull request #9340 from ibzib/stop-flink-job-server
5a0ed84 is described below
commit 5a0ed84a41d58cc97dcc42ee7772e7971eb2a51f
Author: Kyle Weaver <[email protected]>
AuthorDate: Wed Aug 14 11:08:28 2019 -0700
[BEAM-7973] py: shut down Flink job server automatically
---
sdks/python/apache_beam/runners/portability/flink_runner.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/sdks/python/apache_beam/runners/portability/flink_runner.py
b/sdks/python/apache_beam/runners/portability/flink_runner.py
index 2c6116f..a904a3a 100644
--- a/sdks/python/apache_beam/runners/portability/flink_runner.py
+++ b/sdks/python/apache_beam/runners/portability/flink_runner.py
@@ -29,7 +29,7 @@ PUBLISHED_FLINK_VERSIONS = ['1.6', '1.7', '1.8']
class FlinkRunner(portable_runner.PortableRunner):
def default_job_server(self, options):
- return FlinkJarJobServer(options)
+ return job_server.StopOnExitJobServer(FlinkJarJobServer(options))
class FlinkRunnerOptions(pipeline_options.PipelineOptions):
