com.example.bigquerystorage.WriteToDefaultStreamIT: testWriteToDefaultStream failed

[flaky-bot]

This test failed!

To configure my behavior, see the Flaky Bot documentation.

If I'm commenting on this issue too often, add the flakybot: quiet label and
I will stop commenting.

---

commit: 2332dc1
buildURL: Build Status, Sponge
status: failed

Test output

java.lang.RuntimeException: com.google.cloud.bigquery.storage.v1.Exceptions$StreamWriterClosedException: FAILED_PRECONDITION: Connection is already closed
	at com.example.bigquerystorage.WriteToDefaultStream$DataWriter$AppendCompleteCallback.onFailure(WriteToDefaultStream.java:271)
	at com.google.api.core.ApiFutures$1.onFailure(ApiFutures.java:67)
	at com.google.common.util.concurrent.Futures$CallbackListener.run(Futures.java:1132)
	at com.google.common.util.concurrent.DirectExecutor.execute(DirectExecutor.java:31)
	at com.google.common.util.concurrent.AbstractFuture.executeListener(AbstractFuture.java:1270)
	at com.google.common.util.concurrent.AbstractFuture.addListener(AbstractFuture.java:761)
	at com.google.common.util.concurrent.Futures.addCallback(Futures.java:1105)
	at com.google.api.core.ApiFutures.addCallback(ApiFutures.java:62)
	at com.example.bigquerystorage.WriteToDefaultStream$DataWriter.append(WriteToDefaultStream.java:170)
	at com.example.bigquerystorage.WriteToDefaultStream$DataWriter$AppendCompleteCallback.lambda$onFailure$0(WriteToDefaultStream.java:222)
	at java.lang.Thread.run(Thread.java:750)
Caused by: com.google.cloud.bigquery.storage.v1.Exceptions$StreamWriterClosedException: FAILED_PRECONDITION: Connection is already closed
	at com.google.cloud.bigquery.storage.v1.ConnectionWorker.appendInternal(ConnectionWorker.java:290)
	at com.google.cloud.bigquery.storage.v1.ConnectionWorker.append(ConnectionWorker.java:268)
	at com.google.cloud.bigquery.storage.v1.StreamWriter$SingleConnectionOrConnectionPool.append(StreamWriter.java:134)
	at com.google.cloud.bigquery.storage.v1.StreamWriter.append(StreamWriter.java:354)
	at com.google.cloud.bigquery.storage.v1.JsonStreamWriter.append(JsonStreamWriter.java:234)
	at com.google.cloud.bigquery.storage.v1.JsonStreamWriter.append(JsonStreamWriter.java:116)
	at com.example.bigquerystorage.WriteToDefaultStream$DataWriter.append(WriteToDefaultStream.java:169)
	... 2 more

[flaky-bot]

Looks like this issue is flaky. 😟

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

A human should fix and close this.

---

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

[Neenu1995]

Flaky test.

[flaky-bot]

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

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

---

commit: 1608f65
buildURL: Build Status, Sponge
status: failed

Test output

java.lang.RuntimeException: com.google.cloud.bigquery.storage.v1.Exceptions$StreamWriterClosedException: FAILED_PRECONDITION: Connection is already closed
	at com.example.bigquerystorage.WriteToDefaultStream$DataWriter$AppendCompleteCallback.onFailure(WriteToDefaultStream.java:271)
	at com.google.api.core.ApiFutures$1.onFailure(ApiFutures.java:67)
	at com.google.common.util.concurrent.Futures$CallbackListener.run(Futures.java:1132)
	at com.google.common.util.concurrent.DirectExecutor.execute(DirectExecutor.java:31)
	at com.google.common.util.concurrent.AbstractFuture.executeListener(AbstractFuture.java:1270)
	at com.google.common.util.concurrent.AbstractFuture.addListener(AbstractFuture.java:761)
	at com.google.common.util.concurrent.Futures.addCallback(Futures.java:1105)
	at com.google.api.core.ApiFutures.addCallback(ApiFutures.java:62)
	at com.example.bigquerystorage.WriteToDefaultStream$DataWriter.append(WriteToDefaultStream.java:170)
	at com.example.bigquerystorage.WriteToDefaultStream$DataWriter$AppendCompleteCallback.lambda$onFailure$0(WriteToDefaultStream.java:222)
	at java.lang.Thread.run(Thread.java:750)
Caused by: com.google.cloud.bigquery.storage.v1.Exceptions$StreamWriterClosedException: FAILED_PRECONDITION: Connection is already closed
	at com.google.cloud.bigquery.storage.v1.ConnectionWorker.appendInternal(ConnectionWorker.java:289)
	at com.google.cloud.bigquery.storage.v1.ConnectionWorker.append(ConnectionWorker.java:267)
	at com.google.cloud.bigquery.storage.v1.StreamWriter$SingleConnectionOrConnectionPool.append(StreamWriter.java:133)
	at com.google.cloud.bigquery.storage.v1.StreamWriter.append(StreamWriter.java:353)
	at com.google.cloud.bigquery.storage.v1.JsonStreamWriter.append(JsonStreamWriter.java:234)
	at com.google.cloud.bigquery.storage.v1.JsonStreamWriter.append(JsonStreamWriter.java:116)
	at com.example.bigquerystorage.WriteToDefaultStream$DataWriter.append(WriteToDefaultStream.java:169)
	... 2 more

[Neenu1995]

No failure in the past week.

[flaky-bot]

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

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

---

commit: 065cc4f
buildURL: Build Status, Sponge
status: failed

Test output

java.lang.RuntimeException: com.google.cloud.bigquery.storage.v1.Exceptions$StreamWriterClosedException: FAILED_PRECONDITION: Connection is already closed
	at com.example.bigquerystorage.WriteToDefaultStream$DataWriter$AppendCompleteCallback.onFailure(WriteToDefaultStream.java:273)
	at com.google.api.core.ApiFutures$1.onFailure(ApiFutures.java:67)
	at com.google.common.util.concurrent.Futures$CallbackListener.run(Futures.java:1132)
	at com.google.common.util.concurrent.DirectExecutor.execute(DirectExecutor.java:31)
	at com.google.common.util.concurrent.AbstractFuture.executeListener(AbstractFuture.java:1270)
	at com.google.common.util.concurrent.AbstractFuture.addListener(AbstractFuture.java:761)
	at com.google.common.util.concurrent.Futures.addCallback(Futures.java:1105)
	at com.google.api.core.ApiFutures.addCallback(ApiFutures.java:62)
	at com.example.bigquerystorage.WriteToDefaultStream$DataWriter.append(WriteToDefaultStream.java:172)
	at com.example.bigquerystorage.WriteToDefaultStream$DataWriter$AppendCompleteCallback.lambda$onFailure$0(WriteToDefaultStream.java:226)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at java.lang.Thread.run(Thread.java:750)
Caused by: com.google.cloud.bigquery.storage.v1.Exceptions$StreamWriterClosedException: FAILED_PRECONDITION: Connection is already closed
	at com.google.cloud.bigquery.storage.v1.ConnectionWorker.appendInternal(ConnectionWorker.java:289)
	at com.google.cloud.bigquery.storage.v1.ConnectionWorker.append(ConnectionWorker.java:267)
	at com.google.cloud.bigquery.storage.v1.StreamWriter$SingleConnectionOrConnectionPool.append(StreamWriter.java:129)
	at com.google.cloud.bigquery.storage.v1.StreamWriter.append(StreamWriter.java:348)
	at com.google.cloud.bigquery.storage.v1.JsonStreamWriter.append(JsonStreamWriter.java:236)
	at com.google.cloud.bigquery.storage.v1.JsonStreamWriter.append(JsonStreamWriter.java:117)
	at com.example.bigquerystorage.WriteToDefaultStream$DataWriter.append(WriteToDefaultStream.java:171)
	... 6 more

[flaky-bot]

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

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

---

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

Test output

java.lang.RuntimeException: com.google.cloud.bigquery.storage.v1.Exceptions$StreamWriterClosedException: FAILED_PRECONDITION: Connection is already closed
	at com.example.bigquerystorage.WriteToDefaultStream$DataWriter$AppendCompleteCallback.onFailure(WriteToDefaultStream.java:266)
	at com.google.api.core.ApiFutures$1.onFailure(ApiFutures.java:67)
	at com.google.common.util.concurrent.Futures$CallbackListener.run(Futures.java:1132)
	at com.google.common.util.concurrent.DirectExecutor.execute(DirectExecutor.java:31)
	at com.google.common.util.concurrent.AbstractFuture.executeListener(AbstractFuture.java:1270)
	at com.google.common.util.concurrent.AbstractFuture.addListener(AbstractFuture.java:761)
	at com.google.common.util.concurrent.Futures.addCallback(Futures.java:1105)
	at com.google.api.core.ApiFutures.addCallback(ApiFutures.java:62)
	at com.example.bigquerystorage.WriteToDefaultStream$DataWriter.append(WriteToDefaultStream.java:165)
	at com.example.bigquerystorage.WriteToDefaultStream$DataWriter$AppendCompleteCallback.lambda$onFailure$0(WriteToDefaultStream.java:219)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at java.lang.Thread.run(Thread.java:750)
Caused by: com.google.cloud.bigquery.storage.v1.Exceptions$StreamWriterClosedException: FAILED_PRECONDITION: Connection is already closed
	at com.google.cloud.bigquery.storage.v1.ConnectionWorker.appendInternal(ConnectionWorker.java:289)
	at com.google.cloud.bigquery.storage.v1.ConnectionWorker.append(ConnectionWorker.java:267)
	at com.google.cloud.bigquery.storage.v1.StreamWriter$SingleConnectionOrConnectionPool.append(StreamWriter.java:136)
	at com.google.cloud.bigquery.storage.v1.StreamWriter.append(StreamWriter.java:371)
	at com.google.cloud.bigquery.storage.v1.JsonStreamWriter.append(JsonStreamWriter.java:234)
	at com.google.cloud.bigquery.storage.v1.JsonStreamWriter.append(JsonStreamWriter.java:116)
	at com.example.bigquerystorage.WriteToDefaultStream$DataWriter.append(WriteToDefaultStream.java:164)
	... 6 more