@kapa.ai help 2026-03-31 231535 destination ERROR main i.a.c.AirbyteConnectorRunnable(run):38 Failed class io.airbyte.cdk.load.write.WriteOperation operation execution. 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 —

com.google.cloud.bigquery.BigQueryException: java.lang.InterruptedException

occurring in

BigqueryDirectLoadDatabaseInitialStatusGatherer.getTableStatus()

— is a known issue with the BigQuery destination connector. Root Cause The BigQuery Java SDK internally calls

AbstractFuture.get()

, which throws

InterruptedException

when the thread is interrupted. When this blocking call runs inside a Kotlin coroutine that gets cancelled (e.g., due to a timeout or parent scope cancellation), the SDK wraps the

InterruptedException

in a

BigQueryException

. This is then treated as a hard failure instead of a graceful cancellation. [fix PR] This specific error originates during the setup/initialization phase of the sync, when the connector gathers initial table status via

bigquery.getTable()

. [fix PR] Status This is a known bug that has been reported approximately 15 times in the last 30 days. A fix has been proposed (PR #75912) that: 1. Introduces a

bigQueryCall()

suspend helper that runs blocking BigQuery SDK calls on

Dispatchers.IO

2. Catches

BigQueryException

whose cause is

InterruptedException

and converts it to a

CancellationException

(graceful cancellation) 3. Restores the thread interrupt flag via

Thread.currentThread().interrupt()

before rethrowing [fix PR] What You Can Do Now • Retry the sync — this is typically a transient error caused by the sync being cancelled due to a timeout or upstream failure. It usually resolves on retry. [fix PR] • Upgrade the connector once the fix in PR #75912 is merged and released, as it will handle this exception 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.