You are viewing a plain text version of this content. The canonical link for it is here.
Posted to builds@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2019/01/07 15:57:32 UTC
Build failed in Jenkins: beam_PostCommit_Python_VR_Flink #1254
See <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/1254/display/redirect?page=changes>
Changes:
[lukasz.gajowy] [BEAM-6188] Move SyntheticSourceOptions to upper level
[lukasz.gajowy] [BEAM-6188] Separate bundle splitting logic from the IO
[lukasz.gajowy] [BEAM-6188] Separate source delay logic from the IO
[lukasz.gajowy] [BEAM-6188] Move SyntheticBoundedSource to upper level
[lukasz.gajowy] [BEAM-6188] Add UnboundedSyntheticSource for streaming tests
[lukasz.gajowy] [BEAM-6188] Enable using UnboundedSyntheticSource in load tests
[lukasz.gajowy] [BEAM-6188] Remove unused code
[lukasz.gajowy] [BEAM-6188] Make watermark go to +inf if there are no more records
[lukasz.gajowy] [BEAM-6188] Remove deduping related code (deduping is not required)
------------------------------------------
[...truncated 241.24 KB...]
======================================================================
ERROR: test_pardo_side_inputs (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 157, in test_pardo_side_inputs
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 "<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 130, in create_options
options = super(FlinkRunnerTest, self).create_options()
File "apache_beam/runners/portability/portable_runner_test.py", line 160, in create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 124, in _get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 130, in _create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "apache_beam/runners/portability/portable_runner_test.py", line 105, in _start_local_runner_subprocess_job_service
cls._subprocess.returncode)
RuntimeError: Subprocess terminated unexpectedly with exit code 1.
======================================================================
ERROR: test_pardo_side_outputs (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 125, in test_pardo_side_outputs
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 "<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 130, in create_options
options = super(FlinkRunnerTest, self).create_options()
File "apache_beam/runners/portability/portable_runner_test.py", line 160, in create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 124, in _get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 130, in _create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "apache_beam/runners/portability/portable_runner_test.py", line 105, in _start_local_runner_subprocess_job_service
cls._subprocess.returncode)
RuntimeError: Subprocess terminated unexpectedly with exit code 1.
======================================================================
ERROR: test_pardo_state_only (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 277, in test_pardo_state_only
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 "<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 130, in create_options
options = super(FlinkRunnerTest, self).create_options()
File "apache_beam/runners/portability/portable_runner_test.py", line 160, in create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 124, in _get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 130, in _create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "apache_beam/runners/portability/portable_runner_test.py", line 105, in _start_local_runner_subprocess_job_service
cls._subprocess.returncode)
RuntimeError: Subprocess terminated unexpectedly with exit code 1.
======================================================================
ERROR: test_pardo_state_timers (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 349, in test_pardo_state_timers
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 "<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 130, in create_options
options = super(FlinkRunnerTest, self).create_options()
File "apache_beam/runners/portability/portable_runner_test.py", line 160, in create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 124, in _get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 130, in _create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "apache_beam/runners/portability/portable_runner_test.py", line 105, in _start_local_runner_subprocess_job_service
cls._subprocess.returncode)
RuntimeError: Subprocess terminated unexpectedly with exit code 1.
======================================================================
ERROR: test_pardo_timers (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 298, in test_pardo_timers
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 "<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 130, in create_options
options = super(FlinkRunnerTest, self).create_options()
File "apache_beam/runners/portability/portable_runner_test.py", line 160, in create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 124, in _get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 130, in _create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "apache_beam/runners/portability/portable_runner_test.py", line 105, in _start_local_runner_subprocess_job_service
cls._subprocess.returncode)
RuntimeError: Subprocess terminated unexpectedly with exit code 1.
======================================================================
ERROR: test_pardo_unfusable_side_inputs (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 239, in test_pardo_unfusable_side_inputs
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 "<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 130, in create_options
options = super(FlinkRunnerTest, self).create_options()
File "apache_beam/runners/portability/portable_runner_test.py", line 160, in create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 124, in _get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 130, in _create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "apache_beam/runners/portability/portable_runner_test.py", line 105, in _start_local_runner_subprocess_job_service
cls._subprocess.returncode)
RuntimeError: Subprocess terminated unexpectedly with exit code 1.
======================================================================
ERROR: test_pardo_windowed_side_inputs (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 168, in test_pardo_windowed_side_inputs
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 "<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 130, in create_options
options = super(FlinkRunnerTest, self).create_options()
File "apache_beam/runners/portability/portable_runner_test.py", line 160, in create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 124, in _get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 130, in _create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "apache_beam/runners/portability/portable_runner_test.py", line 105, in _start_local_runner_subprocess_job_service
cls._subprocess.returncode)
RuntimeError: Subprocess terminated unexpectedly with exit code 1.
======================================================================
ERROR: test_progress_metrics (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 563, in test_progress_metrics
p = self.create_pipeline()
File "apache_beam/runners/portability/portable_runner_test.py", line 167, 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 130, in create_options
options = super(FlinkRunnerTest, self).create_options()
File "apache_beam/runners/portability/portable_runner_test.py", line 160, in create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 124, in _get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 130, in _create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "apache_beam/runners/portability/portable_runner_test.py", line 105, in _start_local_runner_subprocess_job_service
cls._subprocess.returncode)
RuntimeError: Subprocess terminated unexpectedly with exit code 1.
======================================================================
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 147, 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 "<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 130, in create_options
options = super(FlinkRunnerTest, self).create_options()
File "apache_beam/runners/portability/portable_runner_test.py", line 160, in create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 124, in _get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 130, in _create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "apache_beam/runners/portability/portable_runner_test.py", line 105, in _start_local_runner_subprocess_job_service
cls._subprocess.returncode)
RuntimeError: Subprocess terminated unexpectedly with exit code 1.
======================================================================
ERROR: test_windowing (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 402, 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 "<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 130, in create_options
options = super(FlinkRunnerTest, self).create_options()
File "apache_beam/runners/portability/portable_runner_test.py", line 160, in create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 124, in _get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 130, in _create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "apache_beam/runners/portability/portable_runner_test.py", line 105, in _start_local_runner_subprocess_job_service
cls._subprocess.returncode)
RuntimeError: Subprocess terminated unexpectedly with exit code 1.
----------------------------------------------------------------------
Ran 27 tests in 2.725s
FAILED (errors=23, skipped=3)
> Task :beam-sdks-python:flinkCompatibilityMatrixStreamingDOCKER FAILED
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: 347
* What went wrong:
Execution failed for task ':beam-sdks-python:flinkCompatibilityMatrixBatchDOCKER'.
> Process 'command 'sh'' finished with non-zero exit value 1
* Try:
Run with --stacktrace option to get the stack trace. Run with --info or --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: 347
* What went wrong:
Execution failed for task ':beam-sdks-python:flinkCompatibilityMatrixStreamingDOCKER'.
> Process 'command 'sh'' finished with non-zero exit value 1
* Try:
Run with --stacktrace option to get the stack trace. Run with --info or --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.3/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 9m 9s
60 actionable tasks: 55 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/askpbjj42kmui
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Jenkins build is back to normal : beam_PostCommit_Python_VR_Flink
#1255
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/1255/display/redirect?page=changes>
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org