pubsublite.spark-connector.spark_streaming_test: test_spark_streaming_to_pubsublite failed

[flaky-bot[bot]]

Note: #10500 was also for this test, but it was closed more than 10 days ago. So, I didn't mark it flaky.

---

commit: b4bd938d759bd4aa2b46fc838e14eaa19d90dbf7 buildURL: Build Status, Sponge status: failed

Test output

Traceback (most recent call last):
  File "/workspace/pubsublite/spark-connector/.nox/py-3-8/lib/python3.8/site-packages/google/api_core/grpc_helpers.py", line 72, in error_remapped_callable
    return callable_(*args, **kwargs)
  File "/workspace/pubsublite/spark-connector/.nox/py-3-8/lib/python3.8/site-packages/grpc/_channel.py", line 1161, in __call__
    return _end_unary_response_blocking(state, call, False, None)
  File "/workspace/pubsublite/spark-connector/.nox/py-3-8/lib/python3.8/site-packages/grpc/_channel.py", line 1004, in _end_unary_response_blocking
    raise _InactiveRpcError(state)  # pytype: disable=not-instantiable
grpc._channel._InactiveRpcError: <_inactiverpcerror of rpc that terminated with: status="StatusCode.ALREADY_EXISTS" details="Already exists: Failed to submit job: Job projects/python-docs-samples-tests/regions/us-west1/jobs/spark-streaming-topic-4715" debug_error_string="UNKNOWN:Error received from peer ipv4:142.250.148.95:443 {created_time:" grpc_status:6 grpc_message: exists: failed to submit job: job projects>
The above exception was the direct cause of the following exception:
Traceback (most recent call last):
File "/workspace/pubsublite/spark-connector/spark_streaming_test.py", line 208, in test_spark_streaming_to_pubsublite
operation = job_client.submit_job_as_operation(
File "/workspace/pubsublite/spark-connector/.nox/py-3-8/lib/python3.8/site-packages/google/cloud/dataproc_v1/services/job_controller/client.py", line 683, in submit_job_as_operation
response = rpc(
File "/workspace/pubsublite/spark-connector/.nox/py-3-8/lib/python3.8/site-packages/google/api_core/gapic_v1/method.py", line 113, in call
return wrapped_func(*args, **kwargs)
File "/workspace/pubsublite/spark-connector/.nox/py-3-8/lib/python3.8/site-packages/google/api_core/retry.py", line 349, in retry_wrapped_func
return retry_target(
File "/workspace/pubsublite/spark-connector/.nox/py-3-8/lib/python3.8/site-packages/google/api_core/retry.py", line 191, in retry_target
return target()
File "/workspace/pubsublite/spark-connector/.nox/py-3-8/lib/python3.8/site-packages/google/api_core/timeout.py", line 120, in func_with_timeout
return func(*args, **kwargs)
File "/workspace/pubsublite/spark-connector/.nox/py-3-8/lib/python3.8/site-packages/google/api_core/grpc_helpers.py", line 74, in error_remapped_callable
raise exceptions.from_grpc_error(exc) from exc
google.api_core.exceptions.AlreadyExists: 409 Already exists: Failed to submit job: Job projects/python-docs-samples-tests/regions/us-west1/jobs/spark-streaming-topic-4715

[flaky-bot[bot]]

Looks like this issue is flaky. :worried:

I'm going to leave this open and stop commenting.

A human should fix and close this.

---

When run at the same commit (b4bd938d759bd4aa2b46fc838e14eaa19d90dbf7), this test passed in one build (Build Status, Sponge) and failed in another build (Build Status, Sponge).

[flaky-bot[bot]]

Oops! Looks like this issue is still flaky. It failed again. :grimacing:

I reopened the issue, but a human will need to close it again.

---

commit: e6517d868ee4a33c58629fa413a7706beb46c72b buildURL: Build Status, Sponge status: failed

[glasnt]

closing unaddressed flaky-bot:flaky issues, see go/flakybot-bankruptcy