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/10/30 21:58:48 UTC
Build failed in Jenkins: beam_PostCommit_Python35_VR_Flink #272
See <https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/272/display/redirect?page=changes>
Changes:
[github] [BEAM-8474] A microbenchmark for Python FnApiRunner: (#9891)
------------------------------------------
[...truncated 861.35 KB...]
Traceback (most recent call last):
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/fn_api_runner_test.py",> line 153, in test_pardo_windowed_side_inputs
with self.create_pipeline() as p:
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 188, in create_pipeline
return beam.Pipeline(self.get_runner(), self.create_options())
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 340, in create_options
options = super(FlinkRunnerTestOptimized, self).create_options()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 144, in create_options
options = super(FlinkRunnerTest, self).create_options()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 179, in create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 143, in _get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 149, in _create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 124, in _start_local_runner_subprocess_job_service
cls._subprocess.returncode)
RuntimeError: Subprocess terminated unexpectedly with exit code 1.
======================================================================
ERROR: test_read (__main__.FlinkRunnerTestOptimized)
----------------------------------------------------------------------
Traceback (most recent call last):
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 160, in test_read
with self.create_pipeline() as p:
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 188, in create_pipeline
return beam.Pipeline(self.get_runner(), self.create_options())
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 340, in create_options
options = super(FlinkRunnerTestOptimized, self).create_options()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 144, in create_options
options = super(FlinkRunnerTest, self).create_options()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 179, in create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 143, in _get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 149, in _create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 124, in _start_local_runner_subprocess_job_service
cls._subprocess.returncode)
RuntimeError: Subprocess terminated unexpectedly with exit code 1.
======================================================================
ERROR: test_reshuffle (__main__.FlinkRunnerTestOptimized)
----------------------------------------------------------------------
Traceback (most recent call last):
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/fn_api_runner_test.py",> line 497, in test_reshuffle
with self.create_pipeline() as p:
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 188, in create_pipeline
return beam.Pipeline(self.get_runner(), self.create_options())
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 340, in create_options
options = super(FlinkRunnerTestOptimized, self).create_options()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 144, in create_options
options = super(FlinkRunnerTest, self).create_options()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 179, in create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 143, in _get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 149, in _create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 124, in _start_local_runner_subprocess_job_service
cls._subprocess.returncode)
RuntimeError: Subprocess terminated unexpectedly with exit code 1.
======================================================================
ERROR: test_sdf (__main__.FlinkRunnerTestOptimized)
----------------------------------------------------------------------
Traceback (most recent call last):
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/fn_api_runner_test.py",> line 442, in test_sdf
with self.create_pipeline() as p:
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 188, in create_pipeline
return beam.Pipeline(self.get_runner(), self.create_options())
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 340, in create_options
options = super(FlinkRunnerTestOptimized, self).create_options()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 144, in create_options
options = super(FlinkRunnerTest, self).create_options()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 179, in create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 143, in _get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 149, in _create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 124, 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__.FlinkRunnerTestOptimized)
----------------------------------------------------------------------
Traceback (most recent call last):
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/fn_api_runner_test.py",> line 367, in test_windowed_pardo_state_timers
self._run_pardo_state_timers(True)
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/fn_api_runner_test.py",> line 413, in _run_pardo_state_timers
with self.create_pipeline() as p:
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 188, in create_pipeline
return beam.Pipeline(self.get_runner(), self.create_options())
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 340, in create_options
options = super(FlinkRunnerTestOptimized, self).create_options()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 144, in create_options
options = super(FlinkRunnerTest, self).create_options()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 179, in create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 143, in _get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 149, in _create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 124, in _start_local_runner_subprocess_job_service
cls._subprocess.returncode)
RuntimeError: Subprocess terminated unexpectedly with exit code 1.
======================================================================
ERROR: test_windowing (__main__.FlinkRunnerTestOptimized)
----------------------------------------------------------------------
Traceback (most recent call last):
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/fn_api_runner_test.py",> line 534, in test_windowing
with self.create_pipeline() as p:
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 188, in create_pipeline
return beam.Pipeline(self.get_runner(), self.create_options())
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 340, in create_options
options = super(FlinkRunnerTestOptimized, self).create_options()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 144, in create_options
options = super(FlinkRunnerTest, self).create_options()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 179, in create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 143, in _get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 149, in _create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 124, in _start_local_runner_subprocess_job_service
cls._subprocess.returncode)
RuntimeError: Subprocess terminated unexpectedly with exit code 1.
======================================================================
FAIL: test_assert_that (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
RuntimeError: Subprocess terminated unexpectedly with exit code 1.
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/fn_api_runner_test.py",> line 97, 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__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/fn_api_runner_test.py",> line 575, 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__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/fn_api_runner_test.py",> line 597, in test_error_traceback_includes_user_code
self.assertIn('first', message)
AssertionError: 'first' not found in 'Traceback (most recent call last):\n File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/fn_api_runner_test.py",> line 590, in test_error_traceback_includes_user_code\n with self.create_pipeline() as p:\n File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 188, in create_pipeline\n return beam.Pipeline(self.get_runner(), self.create_options())\n File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 144, in create_options\n options = super(FlinkRunnerTest, self).create_options()\n File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 179, in create_options\n options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()\n File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 143, in _get_job_endpoint\n cls._job_endpoint = cls._create_job_endpoint()\n File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 149, in _create_job_endpoint\n return cls._start_local_runner_subprocess_job_service()\n File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 124, in _start_local_runner_subprocess_job_service\n cls._subprocess.returncode)\nRuntimeError: Subprocess terminated unexpectedly with exit code 1.\n'
======================================================================
FAIL: test_assert_that (__main__.FlinkRunnerTestOptimized)
----------------------------------------------------------------------
RuntimeError: Subprocess terminated unexpectedly with exit code 1.
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/fn_api_runner_test.py",> line 97, 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__.FlinkRunnerTestOptimized)
----------------------------------------------------------------------
Traceback (most recent call last):
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/fn_api_runner_test.py",> line 575, 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__.FlinkRunnerTestOptimized)
----------------------------------------------------------------------
Traceback (most recent call last):
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/fn_api_runner_test.py",> line 597, in test_error_traceback_includes_user_code
self.assertIn('first', message)
AssertionError: 'first' not found in 'Traceback (most recent call last):\n File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/fn_api_runner_test.py",> line 590, in test_error_traceback_includes_user_code\n with self.create_pipeline() as p:\n File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 188, in create_pipeline\n return beam.Pipeline(self.get_runner(), self.create_options())\n File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 340, in create_options\n options = super(FlinkRunnerTestOptimized, self).create_options()\n File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 144, in create_options\n options = super(FlinkRunnerTest, self).create_options()\n File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 179, in create_options\n options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()\n File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 143, in _get_job_endpoint\n cls._job_endpoint = cls._create_job_endpoint()\n File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 149, in _create_job_endpoint\n return cls._start_local_runner_subprocess_job_service()\n File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 124, in _start_local_runner_subprocess_job_service\n cls._subprocess.returncode)\nRuntimeError: Subprocess terminated unexpectedly with exit code 1.\n'
----------------------------------------------------------------------
Ran 70 tests in 166.012s
FAILED (failures=6, errors=50, skipped=14)
> Task :sdks:python:test-suites:portable:py35:flinkCompatibilityMatrixStreamingPreOptimizeLOOPBACK FAILED
FAILURE: Build completed with 3 failures.
1: Task failed with an exception.
-----------
* Where:
Script '<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/test-suites/portable/common.gradle'> line: 54
* What went wrong:
Execution failed for task ':sdks:python:test-suites:portable:py35:flinkCompatibilityMatrixBatchLOOPBACK'.
> 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:
Script '<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/test-suites/portable/common.gradle'> line: 54
* What went wrong:
Execution failed for task ':sdks:python:test-suites:portable:py35:flinkCompatibilityMatrixStreamingLOOPBACK'.
> 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.
==============================================================================
3: Task failed with an exception.
-----------
* Where:
Script '<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/test-suites/portable/common.gradle'> line: 54
* What went wrong:
Execution failed for task ':sdks:python:test-suites:portable:py35:flinkCompatibilityMatrixStreamingPreOptimizeLOOPBACK'.
> 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 13m 37s
58 actionable tasks: 41 executed, 17 from cache
Publishing build scan...
https://gradle.com/s/iznixhsd2agw6
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_Python35_VR_Flink
#274
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/274/display/redirect?page=changes>
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Build failed in Jenkins: beam_PostCommit_Python35_VR_Flink #273
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/273/display/redirect>
Changes:
------------------------------------------
[...truncated 860.89 KB...]
Traceback (most recent call last):
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/fn_api_runner_test.py",> line 153, in test_pardo_windowed_side_inputs
with self.create_pipeline() as p:
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 188, in create_pipeline
return beam.Pipeline(self.get_runner(), self.create_options())
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 340, in create_options
options = super(FlinkRunnerTestOptimized, self).create_options()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 144, in create_options
options = super(FlinkRunnerTest, self).create_options()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 179, in create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 143, in _get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 149, in _create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 124, in _start_local_runner_subprocess_job_service
cls._subprocess.returncode)
RuntimeError: Subprocess terminated unexpectedly with exit code 1.
======================================================================
ERROR: test_read (__main__.FlinkRunnerTestOptimized)
----------------------------------------------------------------------
Traceback (most recent call last):
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 160, in test_read
with self.create_pipeline() as p:
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 188, in create_pipeline
return beam.Pipeline(self.get_runner(), self.create_options())
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 340, in create_options
options = super(FlinkRunnerTestOptimized, self).create_options()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 144, in create_options
options = super(FlinkRunnerTest, self).create_options()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 179, in create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 143, in _get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 149, in _create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 124, in _start_local_runner_subprocess_job_service
cls._subprocess.returncode)
RuntimeError: Subprocess terminated unexpectedly with exit code 1.
======================================================================
ERROR: test_reshuffle (__main__.FlinkRunnerTestOptimized)
----------------------------------------------------------------------
Traceback (most recent call last):
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/fn_api_runner_test.py",> line 497, in test_reshuffle
with self.create_pipeline() as p:
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 188, in create_pipeline
return beam.Pipeline(self.get_runner(), self.create_options())
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 340, in create_options
options = super(FlinkRunnerTestOptimized, self).create_options()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 144, in create_options
options = super(FlinkRunnerTest, self).create_options()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 179, in create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 143, in _get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 149, in _create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 124, in _start_local_runner_subprocess_job_service
cls._subprocess.returncode)
RuntimeError: Subprocess terminated unexpectedly with exit code 1.
======================================================================
ERROR: test_sdf (__main__.FlinkRunnerTestOptimized)
----------------------------------------------------------------------
Traceback (most recent call last):
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/fn_api_runner_test.py",> line 442, in test_sdf
with self.create_pipeline() as p:
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 188, in create_pipeline
return beam.Pipeline(self.get_runner(), self.create_options())
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 340, in create_options
options = super(FlinkRunnerTestOptimized, self).create_options()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 144, in create_options
options = super(FlinkRunnerTest, self).create_options()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 179, in create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 143, in _get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 149, in _create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 124, 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__.FlinkRunnerTestOptimized)
----------------------------------------------------------------------
Traceback (most recent call last):
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/fn_api_runner_test.py",> line 367, in test_windowed_pardo_state_timers
self._run_pardo_state_timers(True)
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/fn_api_runner_test.py",> line 413, in _run_pardo_state_timers
with self.create_pipeline() as p:
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 188, in create_pipeline
return beam.Pipeline(self.get_runner(), self.create_options())
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 340, in create_options
options = super(FlinkRunnerTestOptimized, self).create_options()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 144, in create_options
options = super(FlinkRunnerTest, self).create_options()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 179, in create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 143, in _get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 149, in _create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 124, in _start_local_runner_subprocess_job_service
cls._subprocess.returncode)
RuntimeError: Subprocess terminated unexpectedly with exit code 1.
======================================================================
ERROR: test_windowing (__main__.FlinkRunnerTestOptimized)
----------------------------------------------------------------------
Traceback (most recent call last):
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/fn_api_runner_test.py",> line 534, in test_windowing
with self.create_pipeline() as p:
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 188, in create_pipeline
return beam.Pipeline(self.get_runner(), self.create_options())
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 340, in create_options
options = super(FlinkRunnerTestOptimized, self).create_options()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 144, in create_options
options = super(FlinkRunnerTest, self).create_options()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 179, in create_options
options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 143, in _get_job_endpoint
cls._job_endpoint = cls._create_job_endpoint()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 149, in _create_job_endpoint
return cls._start_local_runner_subprocess_job_service()
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 124, in _start_local_runner_subprocess_job_service
cls._subprocess.returncode)
RuntimeError: Subprocess terminated unexpectedly with exit code 1.
======================================================================
FAIL: test_assert_that (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
RuntimeError: Subprocess terminated unexpectedly with exit code 1.
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/fn_api_runner_test.py",> line 97, 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__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/fn_api_runner_test.py",> line 575, 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__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/fn_api_runner_test.py",> line 597, in test_error_traceback_includes_user_code
self.assertIn('first', message)
AssertionError: 'first' not found in 'Traceback (most recent call last):\n File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/fn_api_runner_test.py",> line 590, in test_error_traceback_includes_user_code\n with self.create_pipeline() as p:\n File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 188, in create_pipeline\n return beam.Pipeline(self.get_runner(), self.create_options())\n File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 144, in create_options\n options = super(FlinkRunnerTest, self).create_options()\n File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 179, in create_options\n options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()\n File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 143, in _get_job_endpoint\n cls._job_endpoint = cls._create_job_endpoint()\n File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 149, in _create_job_endpoint\n return cls._start_local_runner_subprocess_job_service()\n File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 124, in _start_local_runner_subprocess_job_service\n cls._subprocess.returncode)\nRuntimeError: Subprocess terminated unexpectedly with exit code 1.\n'
======================================================================
FAIL: test_assert_that (__main__.FlinkRunnerTestOptimized)
----------------------------------------------------------------------
RuntimeError: Subprocess terminated unexpectedly with exit code 1.
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/fn_api_runner_test.py",> line 97, 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__.FlinkRunnerTestOptimized)
----------------------------------------------------------------------
Traceback (most recent call last):
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/fn_api_runner_test.py",> line 575, 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__.FlinkRunnerTestOptimized)
----------------------------------------------------------------------
Traceback (most recent call last):
File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/fn_api_runner_test.py",> line 597, in test_error_traceback_includes_user_code
self.assertIn('first', message)
AssertionError: 'first' not found in 'Traceback (most recent call last):\n File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/fn_api_runner_test.py",> line 590, in test_error_traceback_includes_user_code\n with self.create_pipeline() as p:\n File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 188, in create_pipeline\n return beam.Pipeline(self.get_runner(), self.create_options())\n File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 340, in create_options\n options = super(FlinkRunnerTestOptimized, self).create_options()\n File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 144, in create_options\n options = super(FlinkRunnerTest, self).create_options()\n File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 179, in create_options\n options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()\n File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 143, in _get_job_endpoint\n cls._job_endpoint = cls._create_job_endpoint()\n File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 149, in _create_job_endpoint\n return cls._start_local_runner_subprocess_job_service()\n File "<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py",> line 124, in _start_local_runner_subprocess_job_service\n cls._subprocess.returncode)\nRuntimeError: Subprocess terminated unexpectedly with exit code 1.\n'
----------------------------------------------------------------------
Ran 70 tests in 59.720s
FAILED (failures=6, errors=50, skipped=14)
> Task :sdks:python:test-suites:portable:py35:flinkCompatibilityMatrixStreamingPreOptimizeLOOPBACK FAILED
FAILURE: Build completed with 3 failures.
1: Task failed with an exception.
-----------
* Where:
Script '<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/test-suites/portable/common.gradle'> line: 54
* What went wrong:
Execution failed for task ':sdks:python:test-suites:portable:py35:flinkCompatibilityMatrixBatchLOOPBACK'.
> 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:
Script '<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/test-suites/portable/common.gradle'> line: 54
* What went wrong:
Execution failed for task ':sdks:python:test-suites:portable:py35:flinkCompatibilityMatrixStreamingLOOPBACK'.
> 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.
==============================================================================
3: Task failed with an exception.
-----------
* Where:
Script '<https://builds.apache.org/job/beam_PostCommit_Python35_VR_Flink/ws/src/sdks/python/test-suites/portable/common.gradle'> line: 54
* What went wrong:
Execution failed for task ':sdks:python:test-suites:portable:py35:flinkCompatibilityMatrixStreamingPreOptimizeLOOPBACK'.
> 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 4m 21s
58 actionable tasks: 41 executed, 17 from cache
Publishing build scan...
https://gradle.com/s/4wnrgghks7e7w
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