@kapa.ai help, 2026-03-31 231535 destination ERROR DefaultDispatcher-worker-9 i.a.c.l.t.DestinationTaskLauncher$WrappedTask(execute):129 Caught exception in task io.airbyte.cdk.load.task.implementor.SetupTask@52bff280 com.google.cloud.bigquery.BigQueryException: java.lang.InterruptedException at com.google.cloud.bigquery.BigQueryException.translateAndThrow(BigQueryException.java:130) ~[google-cloud-bigquery-2.53.0.jar:2.53.0] at com.google.cloud.bigquery.BigQueryImpl.getTable(BigQueryImpl.java:1141) ~[google-cloud-bigquery-2.53.0.jar:2.53.0] at io.airbyte.integrations.destination.bigquery.write.typing_deduping.direct_load_tables.BigqueryDirectLoadDatabaseInitialStatusGatherer.getTableStatus(BigqueryDirectLoadDatabaseInitialStatusGatherer.kt:47) ~[io.airbyte.airbyte-integrations.connectors-destination-bigquery.jar:?] at io.airbyte.integrations.destination.bigquery.write.typing_deduping.direct_load_tables.BigqueryDirectLoadDatabaseInitialStatusGatherer.access$getTableStatus(BigqueryDirectLoadDatabaseInitialStatusGatherer.kt:22) ~[io.airbyte.airbyte-integrations.connectors-destination-bigquery.jar:?] at io.airbyte.integrations.destination.bigquery.write.typing_deduping.direct_load_tables.BigqueryDirectLoadDatabaseInitialStatusGatherer$gatherInitialStatus$2$1$1.invokeSuspend(BigqueryDirectLoadDatabaseInitialStatusGatherer.kt:38) ~[io.airbyte.airbyte-integrations.connectors-destination-bigquery.jar:?] at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33) [kotlin-stdlib-2.1.10.jar:2.1.10-release-473] at kotlinx.coroutines.DispatchedTask.run(DispatchedTask.kt:100) [kotlinx-coroutines-core-jvm-1.10.2.jar:?] at kotlinx.coroutines.internal.LimitedDispatcher$Worker.run(LimitedDispatcher.kt:124) [kotlinx-coroutines-core-jvm-1.10.2.jar:?] at kotlinx.coroutines.scheduling.TaskImpl.run(Tasks.kt:89) [kotlinx-coroutines-core-jvm-1.10.2.jar:?] at kotlinx.coroutines.scheduling.CoroutineScheduler.runSafely(CoroutineScheduler.kt:586) [kotlinx-coroutines-core-jvm-1.10.2.jar:?] at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.executeTask(CoroutineScheduler.kt:820) [kotlinx-coroutines-core-jvm-1.10.2.jar:?] at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.runWorker(CoroutineScheduler.kt:717) [kotlinx-coroutines-core-jvm-1.10.2.jar:?] at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.run(CoroutineScheduler.kt:704) [kotlinx-coroutines-core-jvm-1.10.2.jar:?] Caused by: java.lang.InterruptedException at com.google.common.util.concurrent.AbstractFuture.get(AbstractFuture.java:555) ~[guava-33.4.0-jre.jar:?] at com.google.common.util.concurrent.AbstractFuture$TrustedFuture.get(AbstractFuture.java:114) ~[guava-33.4.0-jre.jar:?] at com.google.common.util.concurrent.ForwardingFuture.get(ForwardingFuture.java:67) ~[guava-33.4.0-jre.jar:?] at com.google.api.gax.retrying.BasicRetryingFuture.setAttemptFuture(BasicRetryingFuture.java:98) ~[gax-2.68.1.jar:2.68.1] at com.google.api.gax.retrying.DirectRetryingExecutor.submit(DirectRetryingExecutor.java:106) ~[gax-2.68.1.jar:2.68.1] at com.google.cloud.bigquery.BigQueryRetryHelper.run(BigQueryRetryHelper.java:108) ~[google-cloud-bigquery-2.53.0.jar:2.53.0] at com.google.cloud.bigquery.BigQueryRetryHelper.runWithRetries(BigQueryRetryHelper.java:62) ~[google-cloud-bigquery-2.53.0.jar:2.53.0] at com.google.cloud.bigquery.BigQueryImpl.getTable(BigQueryImpl.java:1116) ~[google-cloud-bigquery-2.53.0.jar:2.53.0] ... 11 more Stack Trace: com.google.cloud.bigquery.BigQueryException: java.lang.InterruptedException at com.google.cloud.bigquery.BigQueryException.translateAndThrow(BigQueryException.java:130) at com.google.cloud.bigquery.BigQueryImpl.getTable(BigQueryImpl.java:1141) at io.airbyte.integrations.destination.bigquery.write.typing_deduping.direct_load_tables.BigqueryDirectLoadDatabaseInitialStatusGatherer.getTableStatus(BigqueryDirectLoadDatabaseInitialStatusGatherer.kt:47) at io.airbyte.integrations.destination.bigquery.write.typing_deduping.direct_load_tables.BigqueryDirectLoadDatabaseInitialStatusGatherer.access$getTableStatus(BigqueryDirectLoadDatabaseInitialStatusGatherer.kt:22) at io.airbyte.integrations.destination.bigquery.write.typing_deduping.direct_load_tables.BigqueryDirectLoadDatabaseInitialStatusGatherer$gatherInitialStatus$2$1$1.invokeSuspend(BigqueryDirectLoadDatabaseInitialStatusGatherer.kt:38) at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33) at kotlinx.coroutines.DispatchedTask.run(DispatchedTask.kt:100) at kotlinx.coroutines.internal.LimitedDispatcher$Worker.run(LimitedDispatcher.kt:124) at kotlinx.coroutines.scheduling.TaskImpl.run(Tasks.kt:89) at kotlinx.coroutines.scheduling.CoroutineScheduler.runSafely(CoroutineScheduler.kt:586) at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.executeTask(CoroutineScheduler.kt:820) at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.runWorker(CoroutineScheduler.kt:717) at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.run(CoroutineScheduler.kt:704) Caused by: java.lang.InterruptedException at com.google.common.util.concurrent.AbstractFuture.get(AbstractFuture.java:555) at com.google.common.util.concurrent.AbstractFuture$TrustedFuture.get(AbstractFuture.java:114) at com.google.common.util.concurrent.ForwardingFuture.get(ForwardingFuture.java:67) at com.google.api.gax.retrying.BasicRetryingFuture.setAttemptFuture(BasicRetryingFuture.java:98) at com.google.api.gax.retrying.DirectRetryingExecutor.submit(DirectRetryingExecutor.java:106) at com.google.cloud.bigquery.BigQueryRetryHelper.run(BigQueryRetryHelper.java:108) at com.google.cloud.bigquery.BigQueryRetryHelper.runWithRetries(BigQueryRetryHelper.java:62) at com.google.cloud.bigquery.BigQueryImpl.getTable(BigQueryImpl.java:1116) ... 11 more

This error is a known issue with the destination-bigquery connector. The

BigQueryException: java.lang.InterruptedException

occurs during the setup phase when the connector calls

bigquery.getTable()

inside a Kotlin coroutine. When the coroutine is cancelled (e.g., due to a timeout or upstream failure), the BigQuery SDK wraps the

InterruptedException

in a

BigQueryException

, which gets treated as a hard failure instead of a graceful cancellation. [BigQuery InterruptedException fix] This has been reported approximately 15 times in the last 30 days and a fix has been developed. [BigQuery InterruptedException fix] What the fix does: A

bigQueryCall()

suspend helper is introduced that: 1. Runs blocking BigQuery SDK calls on

Dispatchers.IO

2. Catches

BigQueryException

whose cause is

InterruptedException

→ converts to

CancellationException

3. Catches direct

InterruptedException

→ converts to

CancellationException

4. Restores the thread interrupt flag via

Thread.currentThread().interrupt()

before rethrowing The

BigqueryDirectLoadDatabaseInitialStatusGatherer

class (which is exactly where your stack trace originates) is updated to use this helper. [BigQuery InterruptedException fix] What you can do now: • Retry the sync — this is a transient error. The error message in the fix describes it as "a transient error caused by the sync being cancelled due to a timeout or upstream failure", meaning it typically resolves on retry. [BigQuery InterruptedException fix] • Upgrade the destination-bigquery connector once the fix (PR #75912) is released, as it will handle this gracefully instead of treating it as a hard failure. 👍 0 button 👎 0 button ℹ️ Tip: Mention @kapa.ai in the thread for follow-ups or DM the app for 1-to-1 help.