See <https://builds.apache.org/job/beam_PostCommit_Python_PVR_Flink_Gradle/65/display/redirect?page=changes>
Changes: [vin1990] Endpoint host port configuration reset issue [vin1990] Endpoint host port configuration reset issue [vin1990] Fixes https://issues.apache.org/jira/browse/BEAM-3446. BaseReadFn to [vin1990] package private and typo fix [vin1990] Using mget with configurable batch size to increase efficiency of read [vin1990] fixing equality of batch size [vin1990] fixing order of test arguments, to fix [vin1990] Aggregating on per window, applyiong redis get on per window batch and ------------------------------------------ [...truncated 554.12 KB...] raise self _Rendezvous: <_Rendezvous of RPC that terminated with: status = StatusCode.UNAVAILABLE details = "Socket closed" debug_error_string = "{"created":"@1537370417.520571380","description":"Error received from peer","file":"src/core/lib/surface/call.cc","file_line":1099,"grpc_message":"Socket closed","grpc_status":14}" > ====================================================================== ERROR: test_combine_per_key (__main__.FlinkRunnerTest) ---------------------------------------------------------------------- Traceback (most recent call last): File "apache_beam/runners/portability/fn_api_runner_test.py", line 251, 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_1537370409.95_ec03f2e6-b8ac-4a83-8fe2-893f776f6a91 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 62, 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_1537370410.39_d60b4bc5-d144-45fb-a764-00b3a669faa9 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 244, 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_1537370411.0_ed08efb8-128d-43a7-a968-e0551a718c54 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 190, 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_1537370411.46_5478fe71-7fc5-4cc3-8770-271b95ca3c01 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 198, 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_1537370411.94_f7b80bf9-cbfa-4c78-8893-165747e22740 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 237, 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_1537370412.41_581533b5-6f74-4bf6-81de-f88116d368a1 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 293, 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_1537370412.76_4c582781-30ed-44ee-98db-98e0f74189ce 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 209, 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_1537370413.27_005173ec-5abf-4148-b934-dd4951b69571 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 70, 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_1537370413.66_5f22b76f-49ec-4b2e-b4fa-0d108508dac8 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 142, 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_1537370414.21_eb855582-3198-4edd-9c59-f5c6febbd7ff 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 153, 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_1537370415.41_c7334214-660e-43da-8f95-4ae4d16a3fa2 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 124, 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_1537370415.78_0115bede-fe56-482e-8aa6-fc1ae9cef092 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 219, 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_1537370416.24_9f6273d9-38fc-4528-b929-ed0463b03fea 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 180, 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_1537370416.54_2584f352-cca0-454a-ad96-583788aa9f16 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_1537370416.86_2a1fae24-31c2-4827-b74f-69fa5e1b0724 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 274, 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_1537370417.15_a0c6ac97-3fd9-483d-a1d5-f6d5077f8fe9 failed in state FAILED. ---------------------------------------------------------------------- Ran 23 tests in 11.324s FAILED (errors=16, skipped=5) > Task :beam-sdks-python:flinkCompatibilityMatrixStreaming FAILED :beam-sdks-python:flinkCompatibilityMatrixStreaming (Thread[Task worker for ':' Thread 3,5,main]) completed. Took 13.165 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 5m 59s 59 actionable tasks: 54 executed, 4 from cache, 1 up-to-date Publishing build scan... https://gradle.com/s/rmp2q3ihdt5vi Build step 'Invoke Gradle script' changed build result to FAILURE Build step 'Invoke Gradle script' marked build as failure
