See <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/689/display/redirect?page=changes>
Changes: [huangry] Revert "Revert "[BEAM-5299] Define max timestamp for global window in ------------------------------------------ [...truncated 479.01 KB...] assert_that(res, equal_to([('a', 1.5), ('b', 3.0)])) File "apache_beam/pipeline.py", line 425, in __exit__ self.run().wait_until_finish() File "apache_beam/runners/portability/portable_runner.py", line 226, in wait_until_finish 'Pipeline %s failed in state %s.' % (self._job_id, self._state)) RuntimeError: Pipeline test_combine_per_key_1541763023.16_5dd8f584-fb97-4505-90f0-a4bc3be57e2c 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 65, in test_create assert_that(p | beam.Create(['a', 'b']), equal_to(['a', 'b'])) File "apache_beam/pipeline.py", line 425, in __exit__ self.run().wait_until_finish() File "apache_beam/runners/portability/portable_runner.py", line 226, in wait_until_finish 'Pipeline %s failed in state %s.' % (self._job_id, self._state)) RuntimeError: Pipeline test_create_1541763023.51_d1b2647e-4c08-4434-9355-be0ea6ac903f 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 322, in test_flatten assert_that(res, equal_to(['a', 'b', 'c', 'd'])) File "apache_beam/pipeline.py", line 425, in __exit__ self.run().wait_until_finish() File "apache_beam/runners/portability/portable_runner.py", line 226, in wait_until_finish 'Pipeline %s failed in state %s.' % (self._job_id, self._state)) RuntimeError: Pipeline test_flatten_1541763024.02_fbf21c92-06b6-4ee1-b049-d8275fc75727 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 206, in test_flattened_side_input equal_to([(None, {'a': 1, 'b': 2})])) File "apache_beam/pipeline.py", line 425, in __exit__ self.run().wait_until_finish() File "apache_beam/runners/portability/portable_runner.py", line 226, in wait_until_finish 'Pipeline %s failed in state %s.' % (self._job_id, self._state)) RuntimeError: Pipeline test_flattened_side_input_1541763024.41_a005353e-031a-4d74-a8ec-45ab71c8aacd 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 217, in test_gbk_side_input equal_to([(None, {'a': [1]})])) File "apache_beam/pipeline.py", line 425, in __exit__ self.run().wait_until_finish() File "apache_beam/runners/portability/portable_runner.py", line 226, in wait_until_finish 'Pipeline %s failed in state %s.' % (self._job_id, self._state)) RuntimeError: Pipeline test_gbk_side_input_1541763024.71_a3ff53de-8c2f-4dc1-a84e-b17f7975f7ef 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 315, in test_group_by_key assert_that(res, equal_to([('a', [1, 2]), ('b', [3])])) File "apache_beam/pipeline.py", line 425, in __exit__ self.run().wait_until_finish() File "apache_beam/runners/portability/portable_runner.py", line 226, in wait_until_finish 'Pipeline %s failed in state %s.' % (self._job_id, self._state)) RuntimeError: Pipeline test_group_by_key_1541763025.01_1acff4bb-487c-400d-abe4-00e0ce1f1dc7 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 382, in test_large_elements assert_that(gbk_res, equal_to(['a', 'b']), label='gbk') File "apache_beam/pipeline.py", line 425, in __exit__ self.run().wait_until_finish() File "apache_beam/runners/portability/portable_runner.py", line 226, in wait_until_finish 'Pipeline %s failed in state %s.' % (self._job_id, self._state)) RuntimeError: Pipeline test_large_elements_1541763025.33_58381000-11ba-4252-9b03-c8e1d4adff52 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 231, in test_multimap_side_input equal_to([('a', [1, 3]), ('b', [2])])) File "apache_beam/pipeline.py", line 425, in __exit__ self.run().wait_until_finish() File "apache_beam/runners/portability/portable_runner.py", line 226, in wait_until_finish 'Pipeline %s failed in state %s.' % (self._job_id, self._state)) RuntimeError: Pipeline test_multimap_side_input_1541763025.86_9b237899-9635-4270-bb89-92bb84470132 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 73, in test_pardo assert_that(res, equal_to(['aax', 'bcbcx'])) File "apache_beam/pipeline.py", line 425, in __exit__ self.run().wait_until_finish() File "apache_beam/runners/portability/portable_runner.py", line 226, in wait_until_finish 'Pipeline %s failed in state %s.' % (self._job_id, self._state)) RuntimeError: Pipeline test_pardo_1541763026.35_9a40c7fb-8486-4584-9c5e-717429a8d45e 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 149, in test_pardo_side_and_main_outputs assert_that(unnamed.odd, equal_to([1, 3]), label='unnamed.odd') File "apache_beam/pipeline.py", line 425, in __exit__ self.run().wait_until_finish() File "apache_beam/runners/portability/portable_runner.py", line 226, in wait_until_finish 'Pipeline %s failed in state %s.' % (self._job_id, self._state)) RuntimeError: Pipeline test_pardo_side_and_main_outputs_1541763026.81_72f4414d-64d7-42cd-b829-5f7a64c651c6 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 163, in test_pardo_side_inputs ('a', 'y'), ('b', 'y'), ('c', 'y')])) File "apache_beam/pipeline.py", line 425, in __exit__ self.run().wait_until_finish() File "apache_beam/runners/portability/portable_runner.py", line 226, in wait_until_finish 'Pipeline %s failed in state %s.' % (self._job_id, self._state)) RuntimeError: Pipeline test_pardo_side_inputs_1541763027.76_6d8faaa3-c548-4425-b400-a6dd65f7c04f 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 131, in test_pardo_side_outputs assert_that(xy.y, equal_to(['y', 'xy']), label='y') File "apache_beam/pipeline.py", line 425, in __exit__ self.run().wait_until_finish() File "apache_beam/runners/portability/portable_runner.py", line 226, in wait_until_finish 'Pipeline %s failed in state %s.' % (self._job_id, self._state)) RuntimeError: Pipeline test_pardo_side_outputs_1541763028.16_2b4047b4-8482-4176-8cfc-82842826e48b 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 280, in test_pardo_state_only equal_to(expected)) File "apache_beam/pipeline.py", line 425, in __exit__ self.run().wait_until_finish() File "apache_beam/runners/portability/portable_runner.py", line 226, in wait_until_finish 'Pipeline %s failed in state %s.' % (self._job_id, self._state)) RuntimeError: Pipeline test_pardo_state_only_1541763028.57_b433cd28-d6e0-43da-8b2a-e71402f94048 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 244, in test_pardo_unfusable_side_inputs equal_to([('a', 'a'), ('a', 'b'), ('b', 'a'), ('b', 'b')])) File "apache_beam/pipeline.py", line 425, in __exit__ self.run().wait_until_finish() File "apache_beam/runners/portability/portable_runner.py", line 226, in wait_until_finish 'Pipeline %s failed in state %s.' % (self._job_id, self._state)) RuntimeError: Pipeline test_pardo_unfusable_side_inputs_1541763028.88_87504f68-ddcf-4a77-9b99-27aadab55b2b 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 193, in test_pardo_windowed_side_inputs label='windowed') File "apache_beam/pipeline.py", line 425, in __exit__ self.run().wait_until_finish() File "apache_beam/runners/portability/portable_runner.py", line 226, in wait_until_finish 'Pipeline %s failed in state %s.' % (self._job_id, self._state)) RuntimeError: Pipeline test_pardo_windowed_side_inputs_1541763029.18_1598ce95-c0d1-4cd3-aad2-4d44c6eda52b failed in state FAILED. ====================================================================== ERROR: test_read (__main__.FlinkRunnerTest) ---------------------------------------------------------------------- Traceback (most recent call last): File "<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",> line 104, in test_read assert_that(lines, lambda lines: len(lines) > 0) File "apache_beam/pipeline.py", line 425, in __exit__ self.run().wait_until_finish() File "apache_beam/runners/portability/portable_runner.py", line 226, in wait_until_finish 'Pipeline %s failed in state %s.' % (self._job_id, self._state)) RuntimeError: Pipeline test_read_1541763029.56_535863f5-5b34-4d4e-9f13-e54365d97b9c 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 360, in test_windowing assert_that(res, equal_to([('k', [1, 2]), ('k', [100, 101, 102])])) File "apache_beam/pipeline.py", line 425, in __exit__ self.run().wait_until_finish() File "apache_beam/runners/portability/portable_runner.py", line 226, in wait_until_finish 'Pipeline %s failed in state %s.' % (self._job_id, self._state)) RuntimeError: Pipeline test_windowing_1541763029.86_2c124934-047a-4652-bbd4-a6ede9d5ce19 failed in state FAILED. ---------------------------------------------------------------------- Ran 26 tests in 11.455s FAILED (errors=17, skipped=7) > Task :beam-sdks-python:flinkCompatibilityMatrixStreamingDOCKER FAILED :beam-sdks-python:flinkCompatibilityMatrixStreamingDOCKER (Thread[Task worker for ':' Thread 2,5,main]) completed. Took 13.305 secs. FAILURE: Build completed with 2 failures. 1: Task failed with an exception. ----------- * Where: Build file '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build.gradle'> line: 426 * What went wrong: Execution failed for task ':beam-sdks-python:flinkCompatibilityMatrixBatchDOCKER'. > 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_VR_Flink/ws/src/sdks/python/build.gradle'> line: 426 * What went wrong: Execution failed for task ':beam-sdks-python:flinkCompatibilityMatrixStreamingDOCKER'. > 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. Use '--warning-mode all' to show the individual deprecation warnings. See https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings BUILD FAILED in 6m 17s 60 actionable tasks: 58 executed, 1 from cache, 1 up-to-date Publishing build scan... https://gradle.com/s/5phxn2tasgwai Build step 'Invoke Gradle script' changed build result to FAILURE Build step 'Invoke Gradle script' marked build as failure --------------------------------------------------------------------- To unsubscribe, e-mail: builds-unsubscr...@beam.apache.org For additional commands, e-mail: builds-h...@beam.apache.org