Connection finished with error io.grpc.StatusRuntimeException: CANCELLED: Stream is closed by user.

Google Cloud Data Analytics
1

we are using the code provided here to write to BQ storage. It works but we see following message in the logs which looks like an error:

Jul 06, 2022 7:04:40 PM com.google.cloud.bigquery.storage.v1.StreamWriter close
INFO: User closing stream: projects/…
Jul 06, 2022 7:04:40 PM com.google.cloud.bigquery.storage.v1.StreamWriter doneCallback
INFO: Connection finished with error io.grpc.StatusRuntimeException: CANCELLED: Stream is closed by user. for stream projects/…
Jul 06, 2022 7:04:40 PM com.google.cloud.bigquery.storage.v1.StreamWriter close
INFO: User close complete. Stream: projects/…

Can someone explain what is this and how to fix it? thanks.

2

Is the error affecting your work? Is the connection stable every time you run the code? Did you change something on the code that is posted? If you did some changes on it, the error might be occurring since you may have put an wrong value and the problem would be on the code.

3

i am also seeing this issue. Instead of creating BigQueryQriteClient every time, I created it only once and reusing it. Could it be the cause of this issue? Can we safely ignore this issue if bq write is successful?