[
https://issues.apache.org/jira/browse/BEAM-5331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16605632#comment-16605632
]
Thomas Weise commented on BEAM-5331:
------------------------------------
./gradlew -p sdks/python flinkCompatibilityMatrixStreaming
{code:java}
======================================================================
ERROR: test_read (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File
"/Users/tweise/src/beam/sdks/python/apache_beam/runners/portability/flink_runner_test.py",
line 76, in test_read
with self.create_pipeline() as p:
File "apache_beam/runners/portability/portable_runner_test.py", line 167, in
create_pipeline
return beam.Pipeline(self.get_runner(), self.create_options())
File
"/Users/tweise/src/beam/sdks/python/apache_beam/runners/portability/flink_runner_test.py",
line 67, in create_options
options = super(FlinkRunnerTest, self).create_options()
File "apache_beam/runners/portability/portable_runner_test.py", line 163, in
create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 122, in
_get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 128, in
_create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "apache_beam/runners/portability/portable_runner_test.py", line 103, in
_start_local_runner_subprocess_job_service
cls._subprocess.returncode)
RuntimeError: Subprocess terminated unexpectedly with exit code 0.
======================================================================
ERROR: test_windowing (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 266, in
test_windowing
with self.create_pipeline() as p:
File "apache_beam/runners/portability/portable_runner_test.py", line 167, in
create_pipeline
return beam.Pipeline(self.get_runner(), self.create_options())
File
"/Users/tweise/src/beam/sdks/python/apache_beam/runners/portability/flink_runner_test.py",
line 67, in create_options
options = super(FlinkRunnerTest, self).create_options()
File "apache_beam/runners/portability/portable_runner_test.py", line 163, in
create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 122, in
_get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 128, in
_create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "apache_beam/runners/portability/portable_runner_test.py", line 103, in
_start_local_runner_subprocess_job_service
cls._subprocess.returncode)
RuntimeError: Subprocess terminated unexpectedly with exit code 0.
----------------------------------------------------------------------
Ran 22 tests in 972.062s
FAILED (errors=18, skipped=2){code}
> Flink portable runner Python validate runner failures
> ------------------------------------------------------
>
> Key: BEAM-5331
> URL: https://issues.apache.org/jira/browse/BEAM-5331
> Project: Beam
> Issue Type: Task
> Components: runner-flink
> Reporter: Thomas Weise
> Priority: Major
> Labels: portability
>
> Currently 2 Python validate runner tests fail on Flink (in streaming mode).
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
