prodriguezdefino opened a new pull request, #25073: URL: https://github.com/apache/beam/pull/25073
In case the error returned is a StatusRuntimeException it includes the inner description, this description usually include valuable information like quota related messages. Example: ``` Append to stream projects/xxx/datasets/yyy/tables/zzz/streams/_default by client #17 failed with error, operations will be retried. Description: Exceeds 'AppendRows throughput' quota, user_id: projecttttttt0_us (status: INSUFFICIENT_TOKENS), you can issue a raise quota request through Google Cloud Console. Be sure to include this full error message in the request description. Entity: projects/pabs-pso-lab/datasets/pinstall/tables/streaming_pinstall_sub/streams/_default Details: com.google.cloud.bigquery.storage.v1.ConnectionWorker.requestCallback(ConnectionWorker.java:676) com.google.cloud.bigquery.storage.v1.ConnectionWorker.access$100(ConnectionWorker.java:62) com.google.cloud.bigquery.storage.v1.ConnectionWorker$2.run(ConnectionWorker.java:251) com.google.cloud.bigquery.storage.v1.StreamConnection$1.onResponse(StreamConnection.java:63) com.google.cloud.bigquery.storage.v1.StreamConnection$1.onResponse(StreamConnection.java:54) com.google.api.gax.tracing.TracedResponseObserver.onResponse(TracedResponseObserver.java:91) com.google.api.gax.grpc.ExceptionResponseObserver.onResponseImpl(ExceptionResponseObserver.java:74) com.google.api.gax.rpc.StateCheckingResponseObserver.onResponse(StateCheckingResponseObserver.java:60) com.google.api.gax.grpc.GrpcDirectStreamController$ResponseObserverAdapter.onMessage(GrpcDirectStreamController.java:134) io.grpc.ForwardingClientCallListener.onMessage(ForwardingClientCallListener.java:33) io.grpc.ForwardingClientCallListener.onMessage(ForwardingClientCallListener.java:33) io.grpc.ForwardingClientCallListener.onMessage(ForwardingClientCallListener.java:33) io.grpc.internal.DelayedClientCall$DelayedListener.onMessage(DelayedClientCall.java:455) io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1MessagesAvailable.runInternal(ClientCallImpl.java:662) io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1MessagesAvailable.runInContext(ClientCallImpl.java:647) io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37) io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:133) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) java.base/java.lang.Thread.run(Thread.java:834) ``` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
