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: [email protected]
For additional commands, e-mail: [email protected]
