[ 
https://issues.apache.org/jira/browse/BEAM-5722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Valentyn Tymofieiev closed BEAM-5722.
-------------------------------------
    Fix Version/s: Not applicable
       Resolution: Incomplete

> Flake in Python integration test - Operation cancel not allowed for job. Job 
> is not yet ready for canceling.
> ------------------------------------------------------------------------------------------------------------
>
>                 Key: BEAM-5722
>                 URL: https://issues.apache.org/jira/browse/BEAM-5722
>             Project: Beam
>          Issue Type: Bug
>          Components: test-failures
>            Reporter: Valentyn Tymofieiev
>            Assignee: Yifan Zou
>            Priority: P2
>              Labels: stale-assigned
>             Fix For: Not applicable
>
>
> 12:42:33 
> ======================================================================
> 12:42:33 ERROR: test_big_query_new_types 
> (apache_beam.io.gcp.big_query_query_to_table_it_test.BigQueryQueryToTableIT)
> 12:42:33 
> ----------------------------------------------------------------------
> 12:42:33 Traceback (most recent call last):
> 12:42:33   File 
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python_Verify/src/sdks/python/apache_beam/io/gcp/big_query_query_to_table_it_test.py",
>  line 167, in test_big_query_new_types
> 12:42:33     big_query_query_to_table_pipeline.run_bq_pipeline(options)
> 12:42:33   File 
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python_Verify/src/sdks/python/apache_beam/io/gcp/big_query_query_to_table_pipeline.py",
>  line 67, in run_bq_pipeline
> 12:42:33     result = p.run()
> 12:42:33   File 
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python_Verify/src/sdks/python/apache_beam/testing/test_pipeline.py",
>  line 104, in run
> 12:42:33     result = super(TestPipeline, self).run(test_runner_api)
> 12:42:33   File 
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python_Verify/src/sdks/python/apache_beam/pipeline.py",
>  line 416, in run
> 12:42:33     return self.runner.run_pipeline(self)
> 12:42:33   File 
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python_Verify/src/sdks/python/apache_beam/runners/dataflow/test_dataflow_runner.py",
>  line 68, in run_pipeline
> 12:42:33     self.result.cancel()
> 12:42:33   File 
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python_Verify/src/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py",
>  line 1181, in cancel
> 12:42:33     self.job_id(), 'JOB_STATE_CANCELLED'):
> 12:42:33   File 
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python_Verify/src/sdks/python/apache_beam/utils/retry.py",
>  line 184, in wrapper
> 12:42:33     return fun(*args, **kwargs)
> 12:42:33   File 
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python_Verify/src/sdks/python/apache_beam/runners/dataflow/internal/apiclient.py",
>  line 600, in modify_job_state
> 12:42:33     self._client.projects_locations_jobs.Update(request)
> 12:42:33   File 
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python_Verify/src/sdks/python/apache_beam/runners/dataflow/internal/clients/dataflow/dataflow_v1b3_client.py",
>  line 682, in Update
> 12:42:33     config, request, global_params=global_params)
> 12:42:33   File 
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python_Verify/src/sdks/python/build/gradleenv/local/lib/python2.7/site-packages/apitools/base/py/base_api.py",
>  line 722, in _RunMethod
> 12:42:33     return self.ProcessHttpResponse(method_config, http_response, 
> request)
> 12:42:33   File 
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python_Verify/src/sdks/python/build/gradleenv/local/lib/python2.7/site-packages/apitools/base/py/base_api.py",
>  line 728, in ProcessHttpResponse
> 12:42:33     self.__ProcessHttpResponse(method_config, http_response, 
> request))
> 12:42:33   File 
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python_Verify/src/sdks/python/build/gradleenv/local/lib/python2.7/site-packages/apitools/base/py/base_api.py",
>  line 599, in __ProcessHttpResponse
> 12:42:33     http_response, method_config=method_config, request=request)
> 12:42:33 HttpBadRequestError: HttpError accessing 
> <https://dataflow.googleapis.com/v1b3/projects/apache-beam-testing/locations/us-central1/jobs/2018-10-11_12_34_08-11945601871177836156?alt=json>:
>  response: <{'status': '400', 'content-length': '316', 'x-xss-protection': 
> '1; mode=block', 'x-content-type-options': 'nosniff', 'transfer-encoding': 
> 'chunked', 'vary': 'Origin, X-Origin, Referer', 'server': 'ESF', 
> '-content-encoding': 'gzip', 'cache-control': 'private', 'date': 'Thu, 11 Oct 
> 2018 19:36:17 GMT', 'x-frame-options': 'SAMEORIGIN', 'content-type': 
> 'application/json; charset=UTF-8'}>, content <{
> 12:42:33   "error": {
> 12:42:33     "code": 400,
> 12:42:33     "message": "(f4d3cf3db38ed95d): Workflow modification failed. 
> Causes: (5bf98356c427cb5d): Operation cancel not allowed for job 
> 2018-10-11_12_34_08-11945601871177836156. Job is not yet ready for canceling. 
> Please retry in a few minutes.",
> 12:42:33     "status": "FAILED_PRECONDITION"
> 12:42:33   }
> 12:42:33 }
> 12:42:33 >



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to