See <https://builds.apache.org/job/beam_PostCommit_Py_VR_Dataflow/3954/display/redirect>
------------------------------------------ [...truncated 681.56 KB...] root: INFO: 2019-07-05T18:38:30.535Z: JOB_MESSAGE_DETAILED: Checking permissions granted to controller Service Account. root: INFO: 2019-07-05T18:38:31.029Z: JOB_MESSAGE_BASIC: Worker configuration: n1-standard-4 in us-central1-a. root: INFO: 2019-07-05T18:38:31.574Z: JOB_MESSAGE_DETAILED: Expanding SplittableParDo operations into optimizable parts. root: INFO: 2019-07-05T18:38:31.577Z: JOB_MESSAGE_DETAILED: Expanding CollectionToSingleton operations into optimizable parts. root: INFO: 2019-07-05T18:38:31.584Z: JOB_MESSAGE_DETAILED: Expanding CoGroupByKey operations into optimizable parts. root: INFO: 2019-07-05T18:38:31.590Z: JOB_MESSAGE_DEBUG: Combiner lifting skipped for step Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey1.out.0)/GroupByKey: GroupByKey not followed by a combiner. root: INFO: 2019-07-05T18:38:31.592Z: JOB_MESSAGE_DEBUG: Combiner lifting skipped for step Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey0.out.0)/GroupByKey: GroupByKey not followed by a combiner. root: INFO: 2019-07-05T18:38:31.594Z: JOB_MESSAGE_DETAILED: Expanding SplittableProcessKeyed operations into optimizable parts. root: INFO: 2019-07-05T18:38:31.596Z: JOB_MESSAGE_DETAILED: Expanding GroupByKey operations into streaming Read/Write steps root: INFO: 2019-07-05T18:38:31.606Z: JOB_MESSAGE_DEBUG: Annotating graph with Autotuner information. root: INFO: 2019-07-05T18:38:31.623Z: JOB_MESSAGE_DETAILED: Fusing adjacent ParDo, Read, Write, and Flatten operations root: INFO: 2019-07-05T18:38:31.626Z: JOB_MESSAGE_DETAILED: Fusing consumer Map(<lambda at sideinputs_test.py:262>)/MapToVoidKey0 into side list/Decode Values root: INFO: 2019-07-05T18:38:31.629Z: JOB_MESSAGE_DETAILED: Fusing consumer Map(<lambda at sideinputs_test.py:262>)/MapToVoidKey1 into side list/Decode Values root: INFO: 2019-07-05T18:38:31.631Z: JOB_MESSAGE_DETAILED: Fusing consumer Map(<lambda at sideinputs_test.py:262>)/MapToVoidKey0 into side list/Decode Values root: INFO: 2019-07-05T18:38:31.633Z: JOB_MESSAGE_DETAILED: Fusing consumer Map(<lambda at sideinputs_test.py:262>)/MapToVoidKey1 into side list/Decode Values root: INFO: 2019-07-05T18:38:31.635Z: JOB_MESSAGE_DETAILED: Unzipping flatten s16 for input s14.out root: INFO: 2019-07-05T18:38:31.637Z: JOB_MESSAGE_DETAILED: Fusing unzipped copy of assert_that/Group/GroupByKey/WriteStream, through flatten assert_that/Group/Flatten, into producer assert_that/Group/pair_with_0 root: INFO: 2019-07-05T18:38:31.639Z: JOB_MESSAGE_DETAILED: Fusing consumer assert_that/Group/GroupByKey/WriteStream into assert_that/Group/pair_with_1 root: INFO: 2019-07-05T18:38:31.641Z: JOB_MESSAGE_DETAILED: Fusing consumer Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey0.out.0)/StreamingPCollectionViewWriter into Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey0.out.0)/Values root: INFO: 2019-07-05T18:38:31.643Z: JOB_MESSAGE_DETAILED: Fusing consumer main input/Decode Values into main input/Impulse root: INFO: 2019-07-05T18:38:31.645Z: JOB_MESSAGE_DETAILED: Fusing consumer assert_that/Match into assert_that/Unkey root: INFO: 2019-07-05T18:38:31.647Z: JOB_MESSAGE_DETAILED: Fusing consumer Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey0.out.0)/PairWithVoidKey into Map(<lambda at sideinputs_test.py:262>)/MapToVoidKey0 root: INFO: 2019-07-05T18:38:31.649Z: JOB_MESSAGE_DETAILED: Fusing consumer Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey1.out.0)/StreamingPCollectionViewWriter into Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey1.out.0)/Values root: INFO: 2019-07-05T18:38:31.651Z: JOB_MESSAGE_DETAILED: Fusing consumer assert_that/Group/Map(_merge_tagged_vals_under_key) into assert_that/Group/GroupByKey/MergeBuckets root: INFO: 2019-07-05T18:38:31.652Z: JOB_MESSAGE_DETAILED: Fusing consumer assert_that/Unkey into assert_that/Group/Map(_merge_tagged_vals_under_key) root: INFO: 2019-07-05T18:38:31.654Z: JOB_MESSAGE_DETAILED: Fusing consumer assert_that/Group/GroupByKey/MergeBuckets into assert_that/Group/GroupByKey/ReadStream root: INFO: 2019-07-05T18:38:31.656Z: JOB_MESSAGE_DETAILED: Fusing consumer Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey1.out.0)/Values into Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey1.out.0)/GroupByKey/MergeBuckets root: INFO: 2019-07-05T18:38:31.658Z: JOB_MESSAGE_DETAILED: Fusing consumer assert_that/Group/pair_with_1 into assert_that/ToVoidKey root: INFO: 2019-07-05T18:38:31.660Z: JOB_MESSAGE_DETAILED: Fusing consumer assert_that/ToVoidKey into assert_that/WindowInto(WindowIntoFn) root: INFO: 2019-07-05T18:38:31.662Z: JOB_MESSAGE_DETAILED: Fusing consumer assert_that/WindowInto(WindowIntoFn) into Map(<lambda at sideinputs_test.py:262>)/Map(<lambda at sideinputs_test.py:262>) root: INFO: 2019-07-05T18:38:31.664Z: JOB_MESSAGE_DETAILED: Fusing consumer Map(<lambda at sideinputs_test.py:262>)/Map(<lambda at sideinputs_test.py:262>) into main input/Decode Values root: INFO: 2019-07-05T18:38:31.666Z: JOB_MESSAGE_DETAILED: Fusing consumer assert_that/Group/pair_with_0 into assert_that/Create/Decode Values root: INFO: 2019-07-05T18:38:31.668Z: JOB_MESSAGE_DETAILED: Fusing consumer assert_that/Create/Decode Values into assert_that/Create/Impulse root: INFO: 2019-07-05T18:38:31.669Z: JOB_MESSAGE_DETAILED: Fusing consumer Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey0.out.0)/Values into Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey0.out.0)/GroupByKey/MergeBuckets root: INFO: 2019-07-05T18:38:31.671Z: JOB_MESSAGE_DETAILED: Fusing consumer side list/Decode Values into side list/Impulse root: INFO: 2019-07-05T18:38:31.673Z: JOB_MESSAGE_DETAILED: Fusing consumer Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey0.out.0)/GroupByKey/MergeBuckets into Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey0.out.0)/GroupByKey/ReadStream root: INFO: 2019-07-05T18:38:31.675Z: JOB_MESSAGE_DETAILED: Fusing consumer Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey1.out.0)/GroupByKey/WriteStream into Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey1.out.0)/PairWithVoidKey root: INFO: 2019-07-05T18:38:31.677Z: JOB_MESSAGE_DETAILED: Fusing consumer Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey1.out.0)/GroupByKey/MergeBuckets into Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey1.out.0)/GroupByKey/ReadStream root: INFO: 2019-07-05T18:38:31.679Z: JOB_MESSAGE_DETAILED: Fusing consumer Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey1.out.0)/PairWithVoidKey into Map(<lambda at sideinputs_test.py:262>)/MapToVoidKey1 root: INFO: 2019-07-05T18:38:31.681Z: JOB_MESSAGE_DETAILED: Fusing consumer Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey0.out.0)/GroupByKey/WriteStream into Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey0.out.0)/PairWithVoidKey root: INFO: 2019-07-05T18:38:31.692Z: JOB_MESSAGE_DEBUG: Adding StepResource setup and teardown to workflow graph. root: INFO: 2019-07-05T18:38:31.755Z: JOB_MESSAGE_DEBUG: Adding workflow start and stop steps. root: INFO: 2019-07-05T18:38:31.765Z: JOB_MESSAGE_DEBUG: Assigning stage ids. root: INFO: 2019-07-05T18:38:31.931Z: JOB_MESSAGE_DEBUG: Executing wait step start2 root: INFO: 2019-07-05T18:38:31.963Z: JOB_MESSAGE_DEBUG: Starting worker pool setup. root: INFO: 2019-07-05T18:38:31.968Z: JOB_MESSAGE_BASIC: Starting 1 workers... root: INFO: 2019-07-05T18:38:35.205Z: JOB_MESSAGE_BASIC: Executing operation Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey0.out.0)/GroupByKey/ReadStream+Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey0.out.0)/GroupByKey/MergeBuckets+Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey0.out.0)/Values+Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey0.out.0)/StreamingPCollectionViewWriter root: INFO: 2019-07-05T18:38:35.209Z: JOB_MESSAGE_BASIC: Executing operation side list/Impulse+side list/Decode Values+Map(<lambda at sideinputs_test.py:262>)/MapToVoidKey0+Map(<lambda at sideinputs_test.py:262>)/MapToVoidKey1+Map(<lambda at sideinputs_test.py:262>)/MapToVoidKey0+Map(<lambda at sideinputs_test.py:262>)/MapToVoidKey1+Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey0.out.0)/PairWithVoidKey+Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey1.out.0)/PairWithVoidKey+Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey1.out.0)/GroupByKey/WriteStream+Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey0.out.0)/GroupByKey/WriteStream root: INFO: 2019-07-05T18:38:35.209Z: JOB_MESSAGE_BASIC: Executing operation main input/Impulse+main input/Decode Values+Map(<lambda at sideinputs_test.py:262>)/Map(<lambda at sideinputs_test.py:262>)+assert_that/WindowInto(WindowIntoFn)+assert_that/ToVoidKey+assert_that/Group/pair_with_1+assert_that/Group/GroupByKey/WriteStream root: INFO: 2019-07-05T18:38:35.209Z: JOB_MESSAGE_BASIC: Executing operation assert_that/Create/Impulse+assert_that/Create/Decode Values+assert_that/Group/pair_with_0+assert_that/Group/GroupByKey/WriteStream root: INFO: 2019-07-05T18:38:35.225Z: JOB_MESSAGE_BASIC: Executing operation Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey1.out.0)/GroupByKey/ReadStream+Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey1.out.0)/GroupByKey/MergeBuckets+Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey1.out.0)/Values+Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey1.out.0)/StreamingPCollectionViewWriter root: INFO: 2019-07-05T18:38:35.226Z: JOB_MESSAGE_BASIC: Executing operation assert_that/Group/GroupByKey/ReadStream+assert_that/Group/GroupByKey/MergeBuckets+assert_that/Group/Map(_merge_tagged_vals_under_key)+assert_that/Unkey+assert_that/Match root: INFO: 2019-07-05T18:39:25.240Z: JOB_MESSAGE_DETAILED: Workers have started successfully. root: INFO: 2019-07-05T18:39:32.314Z: JOB_MESSAGE_DEBUG: Executing input step topology_init_attach_disk_input_step root: INFO: 2019-07-05T18:39:32.531Z: JOB_MESSAGE_DETAILED: Checking permissions granted to controller Service Account. root: INFO: 2019-07-05T18:39:33.118Z: JOB_MESSAGE_BASIC: Worker configuration: n1-standard-4 in us-central1-a. root: INFO: 2019-07-05T18:42:33.120Z: JOB_MESSAGE_BASIC: Worker configuration: n1-standard-4 in us-central1-a. root: INFO: 2019-07-05T18:44:12.629Z: JOB_MESSAGE_BASIC: Finished operation assert_that/Group/GroupByKey/ReadStream+assert_that/Group/GroupByKey/MergeBuckets+assert_that/Group/Map(_merge_tagged_vals_under_key)+assert_that/Unkey+assert_that/Match root: INFO: 2019-07-05T18:44:12.629Z: JOB_MESSAGE_BASIC: Finished operation Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey0.out.0)/GroupByKey/ReadStream+Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey0.out.0)/GroupByKey/MergeBuckets+Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey0.out.0)/Values+Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey0.out.0)/StreamingPCollectionViewWriter root: INFO: 2019-07-05T18:44:12.630Z: JOB_MESSAGE_BASIC: Finished operation side list/Impulse+side list/Decode Values+Map(<lambda at sideinputs_test.py:262>)/MapToVoidKey0+Map(<lambda at sideinputs_test.py:262>)/MapToVoidKey1+Map(<lambda at sideinputs_test.py:262>)/MapToVoidKey0+Map(<lambda at sideinputs_test.py:262>)/MapToVoidKey1+Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey0.out.0)/PairWithVoidKey+Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey1.out.0)/PairWithVoidKey+Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey1.out.0)/GroupByKey/WriteStream+Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey0.out.0)/GroupByKey/WriteStream root: INFO: 2019-07-05T18:44:12.630Z: JOB_MESSAGE_BASIC: Finished operation assert_that/Create/Impulse+assert_that/Create/Decode Values+assert_that/Group/pair_with_0+assert_that/Group/GroupByKey/WriteStream root: INFO: 2019-07-05T18:44:12.630Z: JOB_MESSAGE_BASIC: Finished operation Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey1.out.0)/GroupByKey/ReadStream+Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey1.out.0)/GroupByKey/MergeBuckets+Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey1.out.0)/Values+Map(<lambda at sideinputs_test.py:262>)/_UnpickledSideInput(MapToVoidKey1.out.0)/StreamingPCollectionViewWriter root: INFO: 2019-07-05T18:44:12.630Z: JOB_MESSAGE_BASIC: Finished operation main input/Impulse+main input/Decode Values+Map(<lambda at sideinputs_test.py:262>)/Map(<lambda at sideinputs_test.py:262>)+assert_that/WindowInto(WindowIntoFn)+assert_that/ToVoidKey+assert_that/Group/pair_with_1+assert_that/Group/GroupByKey/WriteStream root: INFO: 2019-07-05T18:44:12.797Z: JOB_MESSAGE_DETAILED: Cleaning up. root: INFO: 2019-07-05T18:44:12.824Z: JOB_MESSAGE_BASIC: Worker pool stopped. root: INFO: 2019-07-05T18:44:12.827Z: JOB_MESSAGE_DEBUG: Tearing down pending resources... root: INFO: 2019-07-05T18:44:12.829Z: JOB_MESSAGE_DEBUG: Starting worker pool teardown. root: INFO: 2019-07-05T18:44:12.834Z: JOB_MESSAGE_BASIC: Stopping worker pool... --------------------- >> end captured logging << --------------------- Found: https://console.cloud.google.com/dataflow/jobsDetail/locations/us-central1/jobs/2019-07-05_11_30_13-5946336304508913946?project=apache-beam-testing. Found: https://console.cloud.google.com/dataflow/jobsDetail/locations/us-central1/jobs/2019-07-05_11_38_58-7375303083329185502?project=apache-beam-testing. Found: https://console.cloud.google.com/dataflow/jobsDetail/locations/us-central1/jobs/2019-07-05_11_30_14-2987933378084723178?project=apache-beam-testing. Found: https://console.cloud.google.com/dataflow/jobsDetail/locations/us-central1/jobs/2019-07-05_11_39_04-9225798393143649461?project=apache-beam-testing. Found: https://console.cloud.google.com/dataflow/jobsDetail/locations/us-central1/jobs/2019-07-05_11_30_13-2785182920966826660?project=apache-beam-testing. Found: https://console.cloud.google.com/dataflow/jobsDetail/locations/us-central1/jobs/2019-07-05_11_30_14-13867732540170949108?project=apache-beam-testing. Found: https://console.cloud.google.com/dataflow/jobsDetail/locations/us-central1/jobs/2019-07-05_11_38_59-14107655015568261090?project=apache-beam-testing. Found: https://console.cloud.google.com/dataflow/jobsDetail/locations/us-central1/jobs/2019-07-05_11_30_14-7457832992840691139?project=apache-beam-testing. Found: https://console.cloud.google.com/dataflow/jobsDetail/locations/us-central1/jobs/2019-07-05_11_38_54-11076598471520280039?project=apache-beam-testing. Exception in thread Thread-2: Traceback (most recent call last): File "/usr/lib/python3.5/threading.py", line 914, in _bootstrap_inner self.run() File "/usr/lib/python3.5/threading.py", line 862, in run self._target(*self._args, **self._kwargs) File "<https://builds.apache.org/job/beam_PostCommit_Py_VR_Dataflow/ws/src/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py";,> line 190, in poll_for_job_completion job_id, page_token=page_token, start_time=last_message_time) File "<https://builds.apache.org/job/beam_PostCommit_Py_VR_Dataflow/ws/src/sdks/python/apache_beam/utils/retry.py";,> line 197, in wrapper return fun(*args, **kwargs) File "<https://builds.apache.org/job/beam_PostCommit_Py_VR_Dataflow/ws/src/sdks/python/apache_beam/runners/dataflow/internal/apiclient.py";,> line 748, in list_messages response = self._client.projects_locations_jobs_messages.List(request) File "<https://builds.apache.org/job/beam_PostCommit_Py_VR_Dataflow/ws/src/sdks/python/apache_beam/runners/dataflow/internal/clients/dataflow/dataflow_v1b3_client.py";,> line 553, in List config, request, global_params=global_params) File "<https://builds.apache.org/job/beam_PostCommit_Py_VR_Dataflow/ws/src/build/gradleenv/-1734967054/lib/python3.5/site-packages/apitools/base/py/base_api.py";,> line 731, in _RunMethod return self.ProcessHttpResponse(method_config, http_response, request) File "<https://builds.apache.org/job/beam_PostCommit_Py_VR_Dataflow/ws/src/build/gradleenv/-1734967054/lib/python3.5/site-packages/apitools/base/py/base_api.py";,> line 737, in ProcessHttpResponse self.__ProcessHttpResponse(method_config, http_response, request)) File "<https://builds.apache.org/job/beam_PostCommit_Py_VR_Dataflow/ws/src/build/gradleenv/-1734967054/lib/python3.5/site-packages/apitools/base/py/base_api.py";,> line 604, in __ProcessHttpResponse http_response, method_config=method_config, request=request) apitools.base.py.exceptions.HttpNotFoundError: HttpError accessing <https://dataflow.googleapis.com/v1b3/projects/apache-beam-testing/locations/us-central1/jobs/2019-07-05_11_38_54-11076598471520280039/messages?alt=json&startTime=2019-07-05T18%3A44%3A23.914Z>: response: <{'server': 'ESF', 'content-length': '280', 'x-content-type-options': 'nosniff', '-content-encoding': 'gzip', 'x-frame-options': 'SAMEORIGIN', 'x-xss-protection': '0', 'status': '404', 'date': 'Fri, 05 Jul 2019 18:45:31 GMT', 'transfer-encoding': 'chunked', 'content-type': 'application/json; charset=UTF-8', 'cache-control': 'private', 'vary': 'Origin, X-Origin, Referer'}>, content <{ "error": { "code": 404, "message": "(33e745a7df05d5c4): Information about job 2019-07-05_11_38_54-11076598471520280039 could not be found in our system. Please double check the id is correct. If it is please contact customer support.", "status": "NOT_FOUND" } } > Found: https://console.cloud.google.com/dataflow/jobsDetail/locations/us-central1/jobs/2019-07-05_11_30_13-558609494829774?project=apache-beam-testing. Found: https://console.cloud.google.com/dataflow/jobsDetail/locations/us-central1/jobs/2019-07-05_11_38_36-9764247965758226891?project=apache-beam-testing. Found: https://console.cloud.google.com/dataflow/jobsDetail/locations/us-central1/jobs/2019-07-05_11_30_14-11540141550238530181?project=apache-beam-testing. Found: https://console.cloud.google.com/dataflow/jobsDetail/locations/us-central1/jobs/2019-07-05_11_38_26-870067968341953096?project=apache-beam-testing. Exception in thread Thread-1: Traceback (most recent call last): File "/usr/lib/python3.5/threading.py", line 914, in _bootstrap_inner self.run() File "/usr/lib/python3.5/threading.py", line 862, in run self._target(*self._args, **self._kwargs) File "<https://builds.apache.org/job/beam_PostCommit_Py_VR_Dataflow/ws/src/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py";,> line 157, in poll_for_job_completion response = runner.dataflow_client.get_job(job_id) File "<https://builds.apache.org/job/beam_PostCommit_Py_VR_Dataflow/ws/src/sdks/python/apache_beam/utils/retry.py";,> line 197, in wrapper return fun(*args, **kwargs) File "<https://builds.apache.org/job/beam_PostCommit_Py_VR_Dataflow/ws/src/sdks/python/apache_beam/runners/dataflow/internal/apiclient.py";,> line 663, in get_job response = self._client.projects_locations_jobs.Get(request) File "<https://builds.apache.org/job/beam_PostCommit_Py_VR_Dataflow/ws/src/sdks/python/apache_beam/runners/dataflow/internal/clients/dataflow/dataflow_v1b3_client.py";,> line 689, in Get config, request, global_params=global_params) File "<https://builds.apache.org/job/beam_PostCommit_Py_VR_Dataflow/ws/src/build/gradleenv/-1734967054/lib/python3.5/site-packages/apitools/base/py/base_api.py";,> line 731, in _RunMethod return self.ProcessHttpResponse(method_config, http_response, request) File "<https://builds.apache.org/job/beam_PostCommit_Py_VR_Dataflow/ws/src/build/gradleenv/-1734967054/lib/python3.5/site-packages/apitools/base/py/base_api.py";,> line 737, in ProcessHttpResponse self.__ProcessHttpResponse(method_config, http_response, request)) File "<https://builds.apache.org/job/beam_PostCommit_Py_VR_Dataflow/ws/src/build/gradleenv/-1734967054/lib/python3.5/site-packages/apitools/base/py/base_api.py";,> line 604, in __ProcessHttpResponse http_response, method_config=method_config, request=request) apitools.base.py.exceptions.HttpNotFoundError: HttpError accessing <https://dataflow.googleapis.com/v1b3/projects/apache-beam-testing/locations/us-central1/jobs/2019-07-05_11_30_14-11540141550238530181?alt=json>: response: <{'server': 'ESF', 'content-length': '280', 'x-content-type-options': 'nosniff', '-content-encoding': 'gzip', 'x-frame-options': 'SAMEORIGIN', 'x-xss-protection': '0', 'status': '404', 'date': 'Fri, 05 Jul 2019 18:36:11 GMT', 'transfer-encoding': 'chunked', 'content-type': 'application/json; charset=UTF-8', 'cache-control': 'private', 'vary': 'Origin, X-Origin, Referer'}>, content <{ "error": { "code": 404, "message": "(41a84a32b8f74991): Information about job 2019-07-05_11_30_14-11540141550238530181 could not be found in our system. Please double check the id is correct. If it is please contact customer support.", "status": "NOT_FOUND" } } > Exception in thread Thread-2: Traceback (most recent call last): File "/usr/lib/python3.5/threading.py", line 914, in _bootstrap_inner self.run() File "/usr/lib/python3.5/threading.py", line 862, in run self._target(*self._args, **self._kwargs) File "<https://builds.apache.org/job/beam_PostCommit_Py_VR_Dataflow/ws/src/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py";,> line 190, in poll_for_job_completion job_id, page_token=page_token, start_time=last_message_time) File "<https://builds.apache.org/job/beam_PostCommit_Py_VR_Dataflow/ws/src/sdks/python/apache_beam/utils/retry.py";,> line 197, in wrapper return fun(*args, **kwargs) File "<https://builds.apache.org/job/beam_PostCommit_Py_VR_Dataflow/ws/src/sdks/python/apache_beam/runners/dataflow/internal/apiclient.py";,> line 748, in list_messages response = self._client.projects_locations_jobs_messages.List(request) File "<https://builds.apache.org/job/beam_PostCommit_Py_VR_Dataflow/ws/src/sdks/python/apache_beam/runners/dataflow/internal/clients/dataflow/dataflow_v1b3_client.py";,> line 553, in List config, request, global_params=global_params) File "<https://builds.apache.org/job/beam_PostCommit_Py_VR_Dataflow/ws/src/build/gradleenv/-1734967054/lib/python3.5/site-packages/apitools/base/py/base_api.py";,> line 731, in _RunMethod return self.ProcessHttpResponse(method_config, http_response, request) File "<https://builds.apache.org/job/beam_PostCommit_Py_VR_Dataflow/ws/src/build/gradleenv/-1734967054/lib/python3.5/site-packages/apitools/base/py/base_api.py";,> line 737, in ProcessHttpResponse self.__ProcessHttpResponse(method_config, http_response, request)) File "<https://builds.apache.org/job/beam_PostCommit_Py_VR_Dataflow/ws/src/build/gradleenv/-1734967054/lib/python3.5/site-packages/apitools/base/py/base_api.py";,> line 604, in __ProcessHttpResponse http_response, method_config=method_config, request=request) apitools.base.py.exceptions.HttpNotFoundError: HttpError accessing <https://dataflow.googleapis.com/v1b3/projects/apache-beam-testing/locations/us-central1/jobs/2019-07-05_11_38_26-870067968341953096/messages?alt=json&startTime=2019-07-05T18%3A44%3A12.834Z>: response: <{'server': 'ESF', 'content-length': '278', 'x-content-type-options': 'nosniff', '-content-encoding': 'gzip', 'x-frame-options': 'SAMEORIGIN', 'x-xss-protection': '0', 'status': '404', 'date': 'Fri, 05 Jul 2019 18:45:44 GMT', 'transfer-encoding': 'chunked', 'content-type': 'application/json; charset=UTF-8', 'cache-control': 'private', 'vary': 'Origin, X-Origin, Referer'}>, content <{ "error": { "code": 404, "message": "(ed9fb7458120059e): Information about job 2019-07-05_11_38_26-870067968341953096 could not be found in our system. Please double check the id is correct. If it is please contact customer support.", "status": "NOT_FOUND" } } > Found: https://console.cloud.google.com/dataflow/jobsDetail/locations/us-central1/jobs/2019-07-05_11_30_13-14668073191202578580?project=apache-beam-testing. Found: https://console.cloud.google.com/dataflow/jobsDetail/locations/us-central1/jobs/2019-07-05_11_39_59-17210182905016095037?project=apache-beam-testing. ---------------------------------------------------------------------- XML: <https://builds.apache.org/job/beam_PostCommit_Py_VR_Dataflow/ws/src/sdks/python/nosetests.xml> ---------------------------------------------------------------------- Ran 15 tests in 1199.441s FAILED (failures=3) > Task :sdks:python:test-suites:dataflow:py35:validatesRunnerStreamingTests > FAILED FAILURE: Build completed with 4 failures. 1: Task failed with an exception. ----------- * Where: Build file '<https://builds.apache.org/job/beam_PostCommit_Py_VR_Dataflow/ws/src/sdks/python/test-suites/dataflow/py36/build.gradle'> line: 67 * What went wrong: Execution failed for task ':sdks:python:test-suites:dataflow:py36:validatesRunnerBatchTests'. > 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: Build file '<https://builds.apache.org/job/beam_PostCommit_Py_VR_Dataflow/ws/src/sdks/python/test-suites/dataflow/py36/build.gradle'> line: 87 * What went wrong: Execution failed for task ':sdks:python:test-suites:dataflow:py36:validatesRunnerStreamingTests'. > 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: Build file '<https://builds.apache.org/job/beam_PostCommit_Py_VR_Dataflow/ws/src/sdks/python/test-suites/dataflow/py37/build.gradle'> line: 117 * What went wrong: Execution failed for task ':sdks:python:test-suites:dataflow:py37:validatesRunnerStreamingTests'. > 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. ============================================================================== 4: Task failed with an exception. ----------- * Where: Build file '<https://builds.apache.org/job/beam_PostCommit_Py_VR_Dataflow/ws/src/sdks/python/test-suites/dataflow/py35/build.gradle'> line: 87 * What went wrong: Execution failed for task ':sdks:python:test-suites:dataflow:py35:validatesRunnerStreamingTests'. > 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 49m 26s 76 actionable tasks: 59 executed, 17 from cache Publishing build scan... https://gradle.com/s/4bmkyoprypffc Build step 'Invoke Gradle script' changed build result to FAILURE Build step 'Invoke Gradle script' marked build as failure --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
