See
<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/237/display/redirect?page=changes>
Changes:
[thw] [BEAM-2687] Skip test_pardo_timers for Python Flink VR
------------------------------------------
[...truncated 487.25 KB...]
ERROR: test_pardo (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 67, in
test_pardo
with self.create_pipeline() as p:
File "apache_beam/runners/portability/portable_runner_test.py", line 170, in
create_pipeline
return beam.Pipeline(self.get_runner(), self.create_options())
File
"<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py";,>
line 66, in create_options
options = super(FlinkRunnerTest, self).create_options()
File "apache_beam/runners/portability/portable_runner_test.py", line 166, in
create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 125, in
_get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 131, in
_create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "apache_beam/runners/portability/portable_runner_test.py", line 106, in
_start_local_runner_subprocess_job_service
cls._subprocess.returncode)
RuntimeError: Subprocess terminated unexpectedly with exit code 0.
======================================================================
ERROR: test_pardo_metrics (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 94, in
test_pardo_metrics
with self.create_pipeline() as p:
File "apache_beam/runners/portability/portable_runner_test.py", line 170, in
create_pipeline
return beam.Pipeline(self.get_runner(), self.create_options())
File
"<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py";,>
line 66, in create_options
options = super(FlinkRunnerTest, self).create_options()
File "apache_beam/runners/portability/portable_runner_test.py", line 166, in
create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 125, in
_get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 131, in
_create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "apache_beam/runners/portability/portable_runner_test.py", line 106, in
_start_local_runner_subprocess_job_service
cls._subprocess.returncode)
RuntimeError: Subprocess terminated unexpectedly with exit code 0.
======================================================================
ERROR: test_pardo_side_and_main_outputs (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 132, in
test_pardo_side_and_main_outputs
with self.create_pipeline() as p:
File "apache_beam/runners/portability/portable_runner_test.py", line 170, in
create_pipeline
return beam.Pipeline(self.get_runner(), self.create_options())
File
"<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py";,>
line 66, in create_options
options = super(FlinkRunnerTest, self).create_options()
File "apache_beam/runners/portability/portable_runner_test.py", line 166, in
create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 125, in
_get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 131, in
_create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "apache_beam/runners/portability/portable_runner_test.py", line 106, in
_start_local_runner_subprocess_job_service
cls._subprocess.returncode)
RuntimeError: Subprocess terminated unexpectedly with exit code 0.
======================================================================
ERROR: test_pardo_side_inputs (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 152, in
test_pardo_side_inputs
with self.create_pipeline() as p:
File "apache_beam/runners/portability/portable_runner_test.py", line 170, in
create_pipeline
return beam.Pipeline(self.get_runner(), self.create_options())
File
"<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py";,>
line 66, in create_options
options = super(FlinkRunnerTest, self).create_options()
File "apache_beam/runners/portability/portable_runner_test.py", line 166, in
create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 125, in
_get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 131, in
_create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "apache_beam/runners/portability/portable_runner_test.py", line 106, in
_start_local_runner_subprocess_job_service
cls._subprocess.returncode)
RuntimeError: Subprocess terminated unexpectedly with exit code 0.
======================================================================
ERROR: test_pardo_side_outputs (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 121, in
test_pardo_side_outputs
with self.create_pipeline() as p:
File "apache_beam/runners/portability/portable_runner_test.py", line 170, in
create_pipeline
return beam.Pipeline(self.get_runner(), self.create_options())
File
"<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py";,>
line 66, in create_options
options = super(FlinkRunnerTest, self).create_options()
File "apache_beam/runners/portability/portable_runner_test.py", line 166, in
create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 125, in
_get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 131, in
_create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "apache_beam/runners/portability/portable_runner_test.py", line 106, in
_start_local_runner_subprocess_job_service
cls._subprocess.returncode)
RuntimeError: Subprocess terminated unexpectedly with exit code 0.
======================================================================
ERROR: test_pardo_unfusable_side_inputs (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 229, in
test_pardo_unfusable_side_inputs
with self.create_pipeline() as p:
File "apache_beam/runners/portability/portable_runner_test.py", line 170, in
create_pipeline
return beam.Pipeline(self.get_runner(), self.create_options())
File
"<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py";,>
line 66, in create_options
options = super(FlinkRunnerTest, self).create_options()
File "apache_beam/runners/portability/portable_runner_test.py", line 166, in
create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 125, in
_get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 131, in
_create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "apache_beam/runners/portability/portable_runner_test.py", line 106, in
_start_local_runner_subprocess_job_service
cls._subprocess.returncode)
RuntimeError: Subprocess terminated unexpectedly with exit code 0.
======================================================================
ERROR: test_pardo_windowed_side_inputs (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 162, in
test_pardo_windowed_side_inputs
with self.create_pipeline() as p:
File "apache_beam/runners/portability/portable_runner_test.py", line 170, in
create_pipeline
return beam.Pipeline(self.get_runner(), self.create_options())
File
"<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py";,>
line 66, in create_options
options = super(FlinkRunnerTest, self).create_options()
File "apache_beam/runners/portability/portable_runner_test.py", line 166, in
create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 125, in
_get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 131, in
_create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "apache_beam/runners/portability/portable_runner_test.py", line 106, in
_start_local_runner_subprocess_job_service
cls._subprocess.returncode)
RuntimeError: Subprocess terminated unexpectedly with exit code 0.
======================================================================
ERROR: test_progress_metrics (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 443, in
test_progress_metrics
p = self.create_pipeline()
File "apache_beam/runners/portability/portable_runner_test.py", line 170, in
create_pipeline
return beam.Pipeline(self.get_runner(), self.create_options())
File
"<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py";,>
line 66, in create_options
options = super(FlinkRunnerTest, self).create_options()
File "apache_beam/runners/portability/portable_runner_test.py", line 166, in
create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 125, in
_get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 131, in
_create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "apache_beam/runners/portability/portable_runner_test.py", line 106, in
_start_local_runner_subprocess_job_service
cls._subprocess.returncode)
RuntimeError: Subprocess terminated unexpectedly with exit code 0.
======================================================================
ERROR: test_read (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File
"<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py";,>
line 74, in test_read
with self.create_pipeline() as p:
File "apache_beam/runners/portability/portable_runner_test.py", line 170, in
create_pipeline
return beam.Pipeline(self.get_runner(), self.create_options())
File
"<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py";,>
line 66, in create_options
options = super(FlinkRunnerTest, self).create_options()
File "apache_beam/runners/portability/portable_runner_test.py", line 166, in
create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 125, in
_get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 131, in
_create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "apache_beam/runners/portability/portable_runner_test.py", line 106, 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 326, in
test_windowing
with self.create_pipeline() as p:
File "apache_beam/runners/portability/portable_runner_test.py", line 170, in
create_pipeline
return beam.Pipeline(self.get_runner(), self.create_options())
File
"<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py";,>
line 66, in create_options
options = super(FlinkRunnerTest, self).create_options()
File "apache_beam/runners/portability/portable_runner_test.py", line 166, in
create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 125, in
_get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 131, in
_create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "apache_beam/runners/portability/portable_runner_test.py", line 106, in
_start_local_runner_subprocess_job_service
cls._subprocess.returncode)
RuntimeError: Subprocess terminated unexpectedly with exit code 0.
----------------------------------------------------------------------
Ran 25 tests in 60.644s
FAILED (errors=19, skipped=4)
> Task :beam-sdks-python:flinkCompatibilityMatrixStreaming FAILED
:beam-sdks-python:flinkCompatibilityMatrixStreaming (Thread[Task worker for ':'
Thread 5,5,main]) completed. Took 1 mins 2.281 secs.
FAILURE: Build completed with 2 failures.
1: Task failed with an exception.
-----------
* Where:
Build file
'<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build.gradle'>
line: 338
* What went wrong:
Execution failed for task ':beam-sdks-python:flinkCompatibilityMatrixBatch'.
> Process 'command 'sh'' finished with non-zero exit value 1
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to
get more log output. Run with --scan to get full insights.
==============================================================================
2: Task failed with an exception.
-----------
* Where:
Build file
'<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build.gradle'>
line: 338
* What went wrong:
Execution failed for task ':beam-sdks-python:flinkCompatibilityMatrixStreaming'.
> Process 'command 'sh'' finished with non-zero exit value 1
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to
get more log output. Run with --scan to get full insights.
==============================================================================
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with
Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See
https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 6m 49s
59 actionable tasks: 54 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/dksv6vtsoge32
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
