See <https://builds.apache.org/job/beam_PostCommit_Python_PVR_Flink_Gradle/83/display/redirect?page=changes>
Changes: [scott] Revert "Merge pull request #6446: Upgrade gradle wrapper to latest ------------------------------------------ [...truncated 566.48 KB...] File "apache_beam/runners/portability/fn_api_runner_test.py", line 275, in test_combine_per_key assert_that(res, equal_to([('a', 1.5), ('b', 3.0)])) File "apache_beam/pipeline.py", line 414, in __exit__ self.run().wait_until_finish() File "apache_beam/runners/portability/portable_runner.py", line 209, in wait_until_finish 'Pipeline %s failed in state %s.' % (self._job_id, self._state)) RuntimeError: Pipeline test_combine_per_key_1537475903.47_18adc6dd-1d72-4eeb-970a-0d27a8721be8 failed in state FAILED. ====================================================================== ERROR: test_create (__main__.FlinkRunnerTest) ---------------------------------------------------------------------- Traceback (most recent call last): File "apache_beam/runners/portability/fn_api_runner_test.py", line 63, in test_create assert_that(p | beam.Create(['a', 'b']), equal_to(['a', 'b'])) File "apache_beam/pipeline.py", line 414, in __exit__ self.run().wait_until_finish() File "apache_beam/runners/portability/portable_runner.py", line 209, in wait_until_finish 'Pipeline %s failed in state %s.' % (self._job_id, self._state)) RuntimeError: Pipeline test_create_1537475903.87_d5eb1bcc-9c5d-4e35-ac57-e165d57d5f43 failed in state FAILED. ====================================================================== ERROR: test_flatten (__main__.FlinkRunnerTest) ---------------------------------------------------------------------- Traceback (most recent call last): File "apache_beam/runners/portability/fn_api_runner_test.py", line 268, in test_flatten assert_that(res, equal_to(['a', 'b', 'c', 'd'])) File "apache_beam/pipeline.py", line 414, in __exit__ self.run().wait_until_finish() File "apache_beam/runners/portability/portable_runner.py", line 209, in wait_until_finish 'Pipeline %s failed in state %s.' % (self._job_id, self._state)) RuntimeError: Pipeline test_flatten_1537475904.41_7d333cd4-ff75-4dfd-8289-9941b11b99c1 failed in state FAILED. ====================================================================== ERROR: test_flattened_side_input (__main__.FlinkRunnerTest) ---------------------------------------------------------------------- Traceback (most recent call last): File "apache_beam/runners/portability/fn_api_runner_test.py", line 191, in test_flattened_side_input equal_to([(None, {'a': 1, 'b': 2})])) File "apache_beam/pipeline.py", line 414, in __exit__ self.run().wait_until_finish() File "apache_beam/runners/portability/portable_runner.py", line 209, in wait_until_finish 'Pipeline %s failed in state %s.' % (self._job_id, self._state)) RuntimeError: Pipeline test_flattened_side_input_1537475904.95_4283b37f-ed6f-4f49-a75d-4fe37e84c971 failed in state FAILED. ====================================================================== ERROR: test_gbk_side_input (__main__.FlinkRunnerTest) ---------------------------------------------------------------------- Traceback (most recent call last): File "apache_beam/runners/portability/fn_api_runner_test.py", line 199, in test_gbk_side_input equal_to([(None, {'a': [1]})])) File "apache_beam/pipeline.py", line 414, in __exit__ self.run().wait_until_finish() File "apache_beam/runners/portability/portable_runner.py", line 209, in wait_until_finish 'Pipeline %s failed in state %s.' % (self._job_id, self._state)) RuntimeError: Pipeline test_gbk_side_input_1537475905.51_a9ddba6d-5ef8-45e0-a78b-c4d77828bb43 failed in state FAILED. ====================================================================== ERROR: test_group_by_key (__main__.FlinkRunnerTest) ---------------------------------------------------------------------- Traceback (most recent call last): File "apache_beam/runners/portability/fn_api_runner_test.py", line 261, in test_group_by_key assert_that(res, equal_to([('a', [1, 2]), ('b', [3])])) File "apache_beam/pipeline.py", line 414, in __exit__ self.run().wait_until_finish() File "apache_beam/runners/portability/portable_runner.py", line 209, in wait_until_finish 'Pipeline %s failed in state %s.' % (self._job_id, self._state)) RuntimeError: Pipeline test_group_by_key_1537475906.15_89777f9f-735b-45a1-a355-e23f07a86c6c failed in state FAILED. ====================================================================== ERROR: test_large_elements (__main__.FlinkRunnerTest) ---------------------------------------------------------------------- Traceback (most recent call last): File "apache_beam/runners/portability/fn_api_runner_test.py", line 317, in test_large_elements assert_that(gbk_res, equal_to(['a', 'b']), label='gbk') File "apache_beam/pipeline.py", line 414, in __exit__ self.run().wait_until_finish() File "apache_beam/runners/portability/portable_runner.py", line 209, in wait_until_finish 'Pipeline %s failed in state %s.' % (self._job_id, self._state)) RuntimeError: Pipeline test_large_elements_1537475906.7_ddfe77b6-3dd6-4478-907d-f12776f0b9b7 failed in state FAILED. ====================================================================== ERROR: test_multimap_side_input (__main__.FlinkRunnerTest) ---------------------------------------------------------------------- Traceback (most recent call last): File "apache_beam/runners/portability/fn_api_runner_test.py", line 210, in test_multimap_side_input equal_to([('a', [1, 3]), ('b', [2])])) File "apache_beam/pipeline.py", line 414, in __exit__ self.run().wait_until_finish() File "apache_beam/runners/portability/portable_runner.py", line 209, in wait_until_finish 'Pipeline %s failed in state %s.' % (self._job_id, self._state)) RuntimeError: Pipeline test_multimap_side_input_1537475907.35_116866c4-22c5-4166-a4fb-8eea0ca77434 failed in state FAILED. ====================================================================== ERROR: test_pardo (__main__.FlinkRunnerTest) ---------------------------------------------------------------------- Traceback (most recent call last): File "apache_beam/runners/portability/fn_api_runner_test.py", line 71, in test_pardo assert_that(res, equal_to(['aax', 'bcbcx'])) File "apache_beam/pipeline.py", line 414, in __exit__ self.run().wait_until_finish() File "apache_beam/runners/portability/portable_runner.py", line 209, in wait_until_finish 'Pipeline %s failed in state %s.' % (self._job_id, self._state)) RuntimeError: Pipeline test_pardo_1537475907.82_aec5dd0f-38b8-4e7f-84f6-9b7677c850bd failed in state FAILED. ====================================================================== ERROR: test_pardo_side_and_main_outputs (__main__.FlinkRunnerTest) ---------------------------------------------------------------------- Traceback (most recent call last): File "apache_beam/runners/portability/fn_api_runner_test.py", line 143, in test_pardo_side_and_main_outputs assert_that(unnamed.odd, equal_to([1, 3]), label='unnamed.odd') File "apache_beam/pipeline.py", line 414, in __exit__ self.run().wait_until_finish() File "apache_beam/runners/portability/portable_runner.py", line 209, in wait_until_finish 'Pipeline %s failed in state %s.' % (self._job_id, self._state)) RuntimeError: Pipeline test_pardo_side_and_main_outputs_1537475908.44_de9b5b30-d28e-4d90-b813-845e4c579868 failed in state FAILED. ====================================================================== ERROR: test_pardo_side_inputs (__main__.FlinkRunnerTest) ---------------------------------------------------------------------- Traceback (most recent call last): File "apache_beam/runners/portability/fn_api_runner_test.py", line 154, in test_pardo_side_inputs ('a', 'y'), ('b', 'y'), ('c', 'y')])) File "apache_beam/pipeline.py", line 414, in __exit__ self.run().wait_until_finish() File "apache_beam/runners/portability/portable_runner.py", line 209, in wait_until_finish 'Pipeline %s failed in state %s.' % (self._job_id, self._state)) RuntimeError: Pipeline test_pardo_side_inputs_1537475909.93_6aea2cf1-d1eb-40ec-93a9-cb8d87905974 failed in state FAILED. ====================================================================== ERROR: test_pardo_side_outputs (__main__.FlinkRunnerTest) ---------------------------------------------------------------------- Traceback (most recent call last): File "apache_beam/runners/portability/fn_api_runner_test.py", line 125, in test_pardo_side_outputs assert_that(xy.y, equal_to(['y', 'xy']), label='y') File "apache_beam/pipeline.py", line 414, in __exit__ self.run().wait_until_finish() File "apache_beam/runners/portability/portable_runner.py", line 209, in wait_until_finish 'Pipeline %s failed in state %s.' % (self._job_id, self._state)) RuntimeError: Pipeline test_pardo_side_outputs_1537475910.43_ddbdd221-657c-41af-8ab2-ba873de64b91 failed in state FAILED. ====================================================================== ERROR: test_pardo_state_only (__main__.FlinkRunnerTest) ---------------------------------------------------------------------- Traceback (most recent call last): File "apache_beam/runners/portability/fn_api_runner_test.py", line 253, in test_pardo_state_only equal_to(expected)) File "apache_beam/pipeline.py", line 414, in __exit__ self.run().wait_until_finish() File "apache_beam/runners/portability/portable_runner.py", line 209, in wait_until_finish 'Pipeline %s failed in state %s.' % (self._job_id, self._state)) RuntimeError: Pipeline test_pardo_state_only_1537475911.05_304c9497-93bd-4e02-92ac-a38379b21f3d failed in state FAILED. ====================================================================== ERROR: test_pardo_unfusable_side_inputs (__main__.FlinkRunnerTest) ---------------------------------------------------------------------- Traceback (most recent call last): File "apache_beam/runners/portability/fn_api_runner_test.py", line 220, in test_pardo_unfusable_side_inputs equal_to([('a', 'a'), ('a', 'b'), ('b', 'a'), ('b', 'b')])) File "apache_beam/pipeline.py", line 414, in __exit__ self.run().wait_until_finish() File "apache_beam/runners/portability/portable_runner.py", line 209, in wait_until_finish 'Pipeline %s failed in state %s.' % (self._job_id, self._state)) RuntimeError: Pipeline test_pardo_unfusable_side_inputs_1537475911.5_8b0c52d0-5ccd-4c8b-bf4a-f4c7fe5e409d failed in state FAILED. ====================================================================== ERROR: test_pardo_windowed_side_inputs (__main__.FlinkRunnerTest) ---------------------------------------------------------------------- Traceback (most recent call last): File "apache_beam/runners/portability/fn_api_runner_test.py", line 181, in test_pardo_windowed_side_inputs label='windowed') File "apache_beam/pipeline.py", line 414, in __exit__ self.run().wait_until_finish() File "apache_beam/runners/portability/portable_runner.py", line 209, in wait_until_finish 'Pipeline %s failed in state %s.' % (self._job_id, self._state)) RuntimeError: Pipeline test_pardo_windowed_side_inputs_1537475911.83_e26d16c7-65d6-43bf-a8f5-f417109ea0f1 failed in state FAILED. ====================================================================== ERROR: test_read (__main__.FlinkRunnerTest) ---------------------------------------------------------------------- Traceback (most recent call last): File "<https://builds.apache.org/job/beam_PostCommit_Python_PVR_Flink_Gradle/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 78, in test_read assert_that(lines, lambda lines: len(lines) > 0) File "apache_beam/pipeline.py", line 414, in __exit__ self.run().wait_until_finish() File "apache_beam/runners/portability/portable_runner.py", line 209, in wait_until_finish 'Pipeline %s failed in state %s.' % (self._job_id, self._state)) RuntimeError: Pipeline test_read_1537475912.18_b87437c4-56c8-4df0-b42b-5230afedb5cc failed in state FAILED. ====================================================================== ERROR: test_windowing (__main__.FlinkRunnerTest) ---------------------------------------------------------------------- Traceback (most recent call last): File "apache_beam/runners/portability/fn_api_runner_test.py", line 298, in test_windowing assert_that(res, equal_to([('k', [1, 2]), ('k', [100, 101, 102])])) File "apache_beam/pipeline.py", line 414, in __exit__ self.run().wait_until_finish() File "apache_beam/runners/portability/portable_runner.py", line 209, in wait_until_finish 'Pipeline %s failed in state %s.' % (self._job_id, self._state)) RuntimeError: Pipeline test_windowing_1537475912.49_10062e27-789c-4ee4-bb51-49bcd2f86e57 failed in state FAILED. ---------------------------------------------------------------------- Ran 24 tests in 13.870s FAILED (errors=17, skipped=5) > Task :beam-sdks-python:flinkCompatibilityMatrixStreaming FAILED :beam-sdks-python:flinkCompatibilityMatrixStreaming (Thread[Task worker for ':' Thread 8,5,main]) completed. Took 15.715 secs. FAILURE: Build completed with 2 failures. 1: Task failed with an exception. ----------- * Where: Build file '<https://builds.apache.org/job/beam_PostCommit_Python_PVR_Flink_Gradle/ws/src/sdks/python/build.gradle'> line: 340 * What went wrong: Execution failed for task ':beam-sdks-python:flinkCompatibilityMatrixBatch'. > Process 'command 'sh'' finished with non-zero exit value 1 * Try: Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights. ============================================================================== 2: Task failed with an exception. ----------- * Where: Build file '<https://builds.apache.org/job/beam_PostCommit_Python_PVR_Flink_Gradle/ws/src/sdks/python/build.gradle'> line: 340 * What went wrong: Execution failed for task ':beam-sdks-python:flinkCompatibilityMatrixStreaming'. > Process 'command 'sh'' finished with non-zero exit value 1 * Try: Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights. ============================================================================== * Get more help at https://help.gradle.org Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0. See https://docs.gradle.org/4.8/userguide/command_line_interface.html#sec:command_line_warnings BUILD FAILED in 6m 12s 59 actionable tasks: 54 executed, 4 from cache, 1 up-to-date Publishing build scan... https://gradle.com/s/vuacyrxhzuipm Build step 'Invoke Gradle script' changed build result to FAILURE Build step 'Invoke Gradle script' marked build as failure