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 2020/01/15 21:51:39 UTC
Build failed in Jenkins: beam_PostCommit_Python_VR_Spark #2056
See <https://builds.apache.org/job/beam_PostCommit_Python_VR_Spark/2056/display/redirect?page=changes>
Changes:
[hannahjiang] [BEAM-9084] cleaning up docker image tag
[hannahjiang] [BEAM-9084] fix Java spotless
------------------------------------------
[...truncated 119.41 KB...]
cls._job_endpoint = cls._create_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 154, in _create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "apache_beam/runners/portability/portable_runner_test.py", line 129, in _start_local_runner_subprocess_job_service
cls._subprocess.returncode)
RuntimeError: Subprocess terminated unexpectedly with exit code 1.
======================================================================
ERROR: test_pardo_state_timers (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 374, in test_pardo_state_timers
self._run_pardo_state_timers(False)
File "apache_beam/runners/portability/fn_api_runner_test.py", line 423, in _run_pardo_state_timers
with self.create_pipeline() as p:
File "apache_beam/runners/portability/portable_runner_test.py", line 196, in create_pipeline
return beam.Pipeline(self.get_runner(), self.create_options())
File "<https://builds.apache.org/job/beam_PostCommit_Python_VR_Spark/ws/src/sdks/python/apache_beam/runners/portability/spark_runner_test.py",> line 91, in create_options
options = super(SparkRunnerTest, self).create_options()
File "apache_beam/runners/portability/portable_runner_test.py", line 184, in create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 148, in _get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 154, in _create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "apache_beam/runners/portability/portable_runner_test.py", line 129, in _start_local_runner_subprocess_job_service
cls._subprocess.returncode)
RuntimeError: Subprocess terminated unexpectedly with exit code 1.
======================================================================
ERROR: test_pardo_state_with_custom_key_coder (__main__.SparkRunnerTest)
Tests that state requests work correctly when the key coder is an
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/portable_runner_test.py", line 231, in test_pardo_state_with_custom_key_coder
with self.create_pipeline() as p:
File "apache_beam/runners/portability/portable_runner_test.py", line 196, in create_pipeline
return beam.Pipeline(self.get_runner(), self.create_options())
File "<https://builds.apache.org/job/beam_PostCommit_Python_VR_Spark/ws/src/sdks/python/apache_beam/runners/portability/spark_runner_test.py",> line 91, in create_options
options = super(SparkRunnerTest, self).create_options()
File "apache_beam/runners/portability/portable_runner_test.py", line 184, in create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 148, in _get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 154, in _create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "apache_beam/runners/portability/portable_runner_test.py", line 129, in _start_local_runner_subprocess_job_service
cls._subprocess.returncode)
RuntimeError: Subprocess terminated unexpectedly with exit code 1.
======================================================================
ERROR: test_pardo_timers (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 326, in test_pardo_timers
with self.create_pipeline() as p:
File "apache_beam/runners/portability/portable_runner_test.py", line 196, in create_pipeline
return beam.Pipeline(self.get_runner(), self.create_options())
File "<https://builds.apache.org/job/beam_PostCommit_Python_VR_Spark/ws/src/sdks/python/apache_beam/runners/portability/spark_runner_test.py",> line 91, in create_options
options = super(SparkRunnerTest, self).create_options()
File "apache_beam/runners/portability/portable_runner_test.py", line 184, in create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 148, in _get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 154, in _create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "apache_beam/runners/portability/portable_runner_test.py", line 129, 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__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 244, in test_pardo_unfusable_side_inputs
with self.create_pipeline() as p:
File "apache_beam/runners/portability/portable_runner_test.py", line 196, in create_pipeline
return beam.Pipeline(self.get_runner(), self.create_options())
File "<https://builds.apache.org/job/beam_PostCommit_Python_VR_Spark/ws/src/sdks/python/apache_beam/runners/portability/spark_runner_test.py",> line 91, in create_options
options = super(SparkRunnerTest, self).create_options()
File "apache_beam/runners/portability/portable_runner_test.py", line 184, in create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 148, in _get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 154, in _create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "apache_beam/runners/portability/portable_runner_test.py", line 129, 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__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 161, in test_pardo_windowed_side_inputs
with self.create_pipeline() as p:
File "apache_beam/runners/portability/portable_runner_test.py", line 196, in create_pipeline
return beam.Pipeline(self.get_runner(), self.create_options())
File "<https://builds.apache.org/job/beam_PostCommit_Python_VR_Spark/ws/src/sdks/python/apache_beam/runners/portability/spark_runner_test.py",> line 91, in create_options
options = super(SparkRunnerTest, self).create_options()
File "apache_beam/runners/portability/portable_runner_test.py", line 184, in create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 148, in _get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 154, in _create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "apache_beam/runners/portability/portable_runner_test.py", line 129, in _start_local_runner_subprocess_job_service
cls._subprocess.returncode)
RuntimeError: Subprocess terminated unexpectedly with exit code 1.
======================================================================
ERROR: test_read (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 583, in test_read
with self.create_pipeline() as p:
File "apache_beam/runners/portability/portable_runner_test.py", line 196, in create_pipeline
return beam.Pipeline(self.get_runner(), self.create_options())
File "<https://builds.apache.org/job/beam_PostCommit_Python_VR_Spark/ws/src/sdks/python/apache_beam/runners/portability/spark_runner_test.py",> line 91, in create_options
options = super(SparkRunnerTest, self).create_options()
File "apache_beam/runners/portability/portable_runner_test.py", line 184, in create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 148, in _get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 154, in _create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "apache_beam/runners/portability/portable_runner_test.py", line 129, in _start_local_runner_subprocess_job_service
cls._subprocess.returncode)
RuntimeError: Subprocess terminated unexpectedly with exit code 1.
======================================================================
ERROR: test_reshuffle (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 553, in test_reshuffle
with self.create_pipeline() as p:
File "apache_beam/runners/portability/portable_runner_test.py", line 196, in create_pipeline
return beam.Pipeline(self.get_runner(), self.create_options())
File "<https://builds.apache.org/job/beam_PostCommit_Python_VR_Spark/ws/src/sdks/python/apache_beam/runners/portability/spark_runner_test.py",> line 91, in create_options
options = super(SparkRunnerTest, self).create_options()
File "apache_beam/runners/portability/portable_runner_test.py", line 184, in create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 148, in _get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 154, in _create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "apache_beam/runners/portability/portable_runner_test.py", line 129, in _start_local_runner_subprocess_job_service
cls._subprocess.returncode)
RuntimeError: Subprocess terminated unexpectedly with exit code 1.
======================================================================
ERROR: test_windowed_pardo_state_timers (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 377, in test_windowed_pardo_state_timers
self._run_pardo_state_timers(True)
File "apache_beam/runners/portability/fn_api_runner_test.py", line 423, in _run_pardo_state_timers
with self.create_pipeline() as p:
File "apache_beam/runners/portability/portable_runner_test.py", line 196, in create_pipeline
return beam.Pipeline(self.get_runner(), self.create_options())
File "<https://builds.apache.org/job/beam_PostCommit_Python_VR_Spark/ws/src/sdks/python/apache_beam/runners/portability/spark_runner_test.py",> line 91, in create_options
options = super(SparkRunnerTest, self).create_options()
File "apache_beam/runners/portability/portable_runner_test.py", line 184, in create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 148, in _get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 154, in _create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "apache_beam/runners/portability/portable_runner_test.py", line 129, in _start_local_runner_subprocess_job_service
cls._subprocess.returncode)
RuntimeError: Subprocess terminated unexpectedly with exit code 1.
======================================================================
ERROR: test_windowing (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 590, in test_windowing
with self.create_pipeline() as p:
File "apache_beam/runners/portability/portable_runner_test.py", line 196, in create_pipeline
return beam.Pipeline(self.get_runner(), self.create_options())
File "<https://builds.apache.org/job/beam_PostCommit_Python_VR_Spark/ws/src/sdks/python/apache_beam/runners/portability/spark_runner_test.py",> line 91, in create_options
options = super(SparkRunnerTest, self).create_options()
File "apache_beam/runners/portability/portable_runner_test.py", line 184, in create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 148, in _get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "apache_beam/runners/portability/portable_runner_test.py", line 154, in _create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "apache_beam/runners/portability/portable_runner_test.py", line 129, in _start_local_runner_subprocess_job_service
cls._subprocess.returncode)
RuntimeError: Subprocess terminated unexpectedly with exit code 1.
======================================================================
FAIL: test_assert_that (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 105, in test_assert_that
assert_that(p | beam.Create(['a', 'b']), equal_to(['a']))
AssertionError: "Failed assert" does not match "Subprocess terminated unexpectedly with exit code 1."
======================================================================
FAIL: test_error_message_includes_stage (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 632, in test_error_message_includes_stage
self.assertIn('StageC', message)
AssertionError: 'StageC' not found in 'Subprocess terminated unexpectedly with exit code 1.'
======================================================================
FAIL: test_error_traceback_includes_user_code (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 654, in test_error_traceback_includes_user_code
self.assertIn('first', message)
AssertionError: 'first' not found in 'Traceback (most recent call last):\n File "apache_beam/runners/portability/fn_api_runner_test.py", line 647, in test_error_traceback_includes_user_code\n with self.create_pipeline() as p:\n File "apache_beam/runners/portability/portable_runner_test.py", line 196, in create_pipeline\n return beam.Pipeline(self.get_runner(), self.create_options())\n File "<https://builds.apache.org/job/beam_PostCommit_Python_VR_Spark/ws/src/sdks/python/apache_beam/runners/portability/spark_runner_test.py",> line 91, in create_options\n options = super(SparkRunnerTest, self).create_options()\n File "apache_beam/runners/portability/portable_runner_test.py", line 184, in create_options\n options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()\n File "apache_beam/runners/portability/portable_runner_test.py", line 148, in _get_job_endpoint\n cls._job_endpoint = cls._create_job_endpoint()\n File "apache_beam/runners/portability/portable_runner_test.py", line 154, in _create_job_endpoint\n return cls._start_local_runner_subprocess_job_service()\n File "apache_beam/runners/portability/portable_runner_test.py", line 129, in _start_local_runner_subprocess_job_service\n cls._subprocess.returncode)\nRuntimeError: Subprocess terminated unexpectedly with exit code 1.\n'
----------------------------------------------------------------------
Ran 38 tests in 6.709s
FAILED (failures=3, errors=24, skipped=10)
> Task :sdks:python:test-suites:portable:py2:sparkValidatesRunner FAILED
FAILURE: Build failed with an exception.
* Where:
Build file '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Spark/ws/src/sdks/python/test-suites/portable/py2/build.gradle'> line: 221
* What went wrong:
Execution failed for task ':sdks:python:test-suites:portable:py2:sparkValidatesRunner'.
> 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 6.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/5.2.1/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 3m 30s
60 actionable tasks: 48 executed, 12 from cache
Publishing build scan...
https://gradle.com/s/5grqjog42pkow
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_Spark
#2057
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Python_VR_Spark/2057/display/redirect?page=changes>
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org