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/31 00:19:28 UTC

Build failed in Jenkins: beam_PreCommit_Python2_PVR_Flink_Cron #117

See <https://builds.apache.org/job/beam_PreCommit_Python2_PVR_Flink_Cron/117/display/redirect?page=changes>

Changes:

[nlofeudo] Avoid polluting Stackdriver logs with noise during autoscaling events.

[nlofeudo] Spotless Java applied

[github] [Go SDK] Delete spammy log in datamgr.go

[kamil.wasilewski] [BEAM-4775] Extract code responsible for parsing MonitoringInfo

[kamil.wasilewski] [BEAM-4775] Expose metrics gathered by FnApiRunner in LocalJobServicer

[kamil.wasilewski] [BEAM-4775] Publish only user metrics in load tests

[kamil.wasilewski] [BEAM-4775] Use result property of MetricResult in load tests

[kirillkozlov] BigQuery should return row fields in the selected order

[robertwb] Cleanup metrics tests.

[github] Remove --flink-master-url alias.

[github] [BEAM-8474] A microbenchmark for Python FnApiRunner: (#9891)


------------------------------------------
[...truncated 792.46 KB...]
    return cls._start_local_runner_subprocess_job_service()
  File "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_pardo_windowed_side_inputs (__main__.FlinkRunnerTestOptimized)
----------------------------------------------------------------------
Traceback (most recent call last):
  File "apache_beam/runners/portability/fn_api_runner_test.py", line 153, in test_pardo_windowed_side_inputs
    with self.create_pipeline() as p:
  File "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_PreCommit_Python2_PVR_Flink_Cron/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_PreCommit_Python2_PVR_Flink_Cron/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 144, in create_options
    options = super(FlinkRunnerTest, self).create_options()
  File "apache_beam/runners/portability/portable_runner_test.py", line 179, in create_options
    options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
  File "apache_beam/runners/portability/portable_runner_test.py", line 143, in _get_job_endpoint
    cls._job_endpoint = cls._create_job_endpoint()
  File "apache_beam/runners/portability/portable_runner_test.py", line 149, in _create_job_endpoint
    return cls._start_local_runner_subprocess_job_service()
  File "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_PreCommit_Python2_PVR_Flink_Cron/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 160, in test_read
    with self.create_pipeline() as p:
  File "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_PreCommit_Python2_PVR_Flink_Cron/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_PreCommit_Python2_PVR_Flink_Cron/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 144, in create_options
    options = super(FlinkRunnerTest, self).create_options()
  File "apache_beam/runners/portability/portable_runner_test.py", line 179, in create_options
    options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
  File "apache_beam/runners/portability/portable_runner_test.py", line 143, in _get_job_endpoint
    cls._job_endpoint = cls._create_job_endpoint()
  File "apache_beam/runners/portability/portable_runner_test.py", line 149, in _create_job_endpoint
    return cls._start_local_runner_subprocess_job_service()
  File "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 "apache_beam/runners/portability/fn_api_runner_test.py", line 497, in test_reshuffle
    with self.create_pipeline() as p:
  File "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_PreCommit_Python2_PVR_Flink_Cron/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_PreCommit_Python2_PVR_Flink_Cron/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 144, in create_options
    options = super(FlinkRunnerTest, self).create_options()
  File "apache_beam/runners/portability/portable_runner_test.py", line 179, in create_options
    options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
  File "apache_beam/runners/portability/portable_runner_test.py", line 143, in _get_job_endpoint
    cls._job_endpoint = cls._create_job_endpoint()
  File "apache_beam/runners/portability/portable_runner_test.py", line 149, in _create_job_endpoint
    return cls._start_local_runner_subprocess_job_service()
  File "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 "apache_beam/runners/portability/fn_api_runner_test.py", line 442, in test_sdf
    with self.create_pipeline() as p:
  File "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_PreCommit_Python2_PVR_Flink_Cron/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_PreCommit_Python2_PVR_Flink_Cron/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 144, in create_options
    options = super(FlinkRunnerTest, self).create_options()
  File "apache_beam/runners/portability/portable_runner_test.py", line 179, in create_options
    options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
  File "apache_beam/runners/portability/portable_runner_test.py", line 143, in _get_job_endpoint
    cls._job_endpoint = cls._create_job_endpoint()
  File "apache_beam/runners/portability/portable_runner_test.py", line 149, in _create_job_endpoint
    return cls._start_local_runner_subprocess_job_service()
  File "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 "apache_beam/runners/portability/fn_api_runner_test.py", line 367, in test_windowed_pardo_state_timers
    self._run_pardo_state_timers(True)
  File "apache_beam/runners/portability/fn_api_runner_test.py", line 413, in _run_pardo_state_timers
    with self.create_pipeline() as p:
  File "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_PreCommit_Python2_PVR_Flink_Cron/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_PreCommit_Python2_PVR_Flink_Cron/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 144, in create_options
    options = super(FlinkRunnerTest, self).create_options()
  File "apache_beam/runners/portability/portable_runner_test.py", line 179, in create_options
    options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
  File "apache_beam/runners/portability/portable_runner_test.py", line 143, in _get_job_endpoint
    cls._job_endpoint = cls._create_job_endpoint()
  File "apache_beam/runners/portability/portable_runner_test.py", line 149, in _create_job_endpoint
    return cls._start_local_runner_subprocess_job_service()
  File "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 "apache_beam/runners/portability/fn_api_runner_test.py", line 534, in test_windowing
    with self.create_pipeline() as p:
  File "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_PreCommit_Python2_PVR_Flink_Cron/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_PreCommit_Python2_PVR_Flink_Cron/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 144, in create_options
    options = super(FlinkRunnerTest, self).create_options()
  File "apache_beam/runners/portability/portable_runner_test.py", line 179, in create_options
    options.view_as(PortableOptions).job_endpoint = self._get_job_endpoint()
  File "apache_beam/runners/portability/portable_runner_test.py", line 143, in _get_job_endpoint
    cls._job_endpoint = cls._create_job_endpoint()
  File "apache_beam/runners/portability/portable_runner_test.py", line 149, in _create_job_endpoint
    return cls._start_local_runner_subprocess_job_service()
  File "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)
----------------------------------------------------------------------
Traceback (most recent call last):
  File "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 "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 "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 "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 "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_PreCommit_Python2_PVR_Flink_Cron/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 "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 "apache_beam/runners/portability/portable_runner_test.py", line 143, in _get_job_endpoint\n    cls._job_endpoint = cls._create_job_endpoint()\n  File "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 "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)
----------------------------------------------------------------------
Traceback (most recent call last):
  File "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 "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 "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 "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 "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_PreCommit_Python2_PVR_Flink_Cron/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_PreCommit_Python2_PVR_Flink_Cron/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 "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 "apache_beam/runners/portability/portable_runner_test.py", line 143, in _get_job_endpoint\n    cls._job_endpoint = cls._create_job_endpoint()\n  File "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 "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 65.345s

FAILED (failures=6, errors=50, skipped=14)

> Task :sdks:python:test-suites:portable:py2:flinkCompatibilityMatrixStreamingPreOptimizeLOOPBACK FAILED

FAILURE: Build completed with 3 failures.

1: Task failed with an exception.
-----------
* Where:
Script '<https://builds.apache.org/job/beam_PreCommit_Python2_PVR_Flink_Cron/ws/src/sdks/python/test-suites/portable/common.gradle'> line: 54

* What went wrong:
Execution failed for task ':sdks:python:test-suites:portable:py2: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_PreCommit_Python2_PVR_Flink_Cron/ws/src/sdks/python/test-suites/portable/common.gradle'> line: 54

* What went wrong:
Execution failed for task ':sdks:python:test-suites:portable:py2: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_PreCommit_Python2_PVR_Flink_Cron/ws/src/sdks/python/test-suites/portable/common.gradle'> line: 54

* What went wrong:
Execution failed for task ':sdks:python:test-suites:portable:py2: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 29s
58 actionable tasks: 41 executed, 17 from cache

Publishing build scan...
https://gradle.com/s/jwkgttf7hik2w

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_PreCommit_Python2_PVR_Flink_Cron #118

Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PreCommit_Python2_PVR_Flink_Cron/118/display/redirect?page=changes>


---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org