2021-07-29 05:25:43 INFO () WorkerRun(call):62 - Executing worker wrapper. Airbyte version: 0.27.2-alpha
2021-07-29 05:25:43 INFO () TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.27.2-alpha
2021-07-29 05:25:43 INFO () DefaultReplicationWorker(run):102 - start sync worker. job id: 2974 attempt id: 0
2021-07-29 05:25:43 INFO () DefaultReplicationWorker(run):111 - configured sync modes: {admin_devclubniagadb.client_order=full_refresh - append}
2021-07-29 05:25:43 INFO () DefaultAirbyteDestination(start):78 - Running destination...
2021-07-29 05:25:43 INFO () LineGobbler(voidCall):85 - Checking if airbyte/destination-bigquery:0.3.7 exists...
2021-07-29 05:25:43 INFO () LineGobbler(voidCall):85 - airbyte/destination-bigquery:0.3.7 was found locally.
2021-07-29 05:25:43 INFO () DockerProcessFactory(create):146 - Preparing command: docker run --rm --init -i -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -w /data/2974/0 --network host --log-driver none airbyte/destination-bigquery:0.3.7 write --config destination_config.json --catalog destination_catalog.json
2021-07-29 05:25:43 INFO () LineGobbler(voidCall):85 - Checking if airbyte/source-mysql:0.4.0 exists...
2021-07-29 05:25:43 INFO () LineGobbler(voidCall):85 - airbyte/source-mysql:0.4.0 was found locally.
2021-07-29 05:25:43 INFO () DockerProcessFactory(create):146 - Preparing command: docker run --rm --init -i -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -w /data/2974/0 --network host --log-driver none airbyte/source-mysql:0.4.0 read --config source_config.json --catalog source_catalog.json
2021-07-29 05:25:44 INFO () DefaultReplicationWorker(run):139 - Waiting for source thread to join.
2021-07-29 05:25:44 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):210 - Replication thread started.
2021-07-29 05:25:44 INFO () DefaultReplicationWorker(lambda$getDestinationOutputRunnable$3):246 - Destination output thread started.
2021-07-29 05:25:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 05:25:45 INFO i.a.i.d.b.BigQueryDestination(main):278 - {} - starting destination: class io.airbyte.integrations.destination.bigquery.BigQueryDestination
2021-07-29 05:25:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 05:25:45 INFO i.a.i.b.IntegrationRunner(run):78 - {} - Running integration: io.airbyte.integrations.destination.bigquery.BigQueryDestination
2021-07-29 05:25:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 05:25:45 INFO i.a.i.b.IntegrationCliParser(parseOptions):135 - {} - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2021-07-29 05:25:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 05:25:45 INFO i.a.i.b.IntegrationRunner(run):82 - {} - Command: WRITE
2021-07-29 05:25:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 05:25:45 INFO i.a.i.b.IntegrationRunner(run):83 - {} - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2021-07-29 05:25:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 05:25:45 INFO i.a.i.s.m.MySqlSource(main):249 - {} - starting source: class io.airbyte.integrations.source.mysql.MySqlSource
2021-07-29 05:25:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 05:25:45 INFO i.a.i.b.IntegrationRunner(run):81 - {} - Running integration: io.airbyte.integrations.source.mysql.MySqlSource
2021-07-29 05:25:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 05:25:45 INFO i.a.i.b.IntegrationCliParser(parseOptions):135 - {} - integration args: {read=null, catalog=source_catalog.json, config=source_config.json}
2021-07-29 05:25:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 05:25:45 INFO i.a.i.b.IntegrationRunner(run):85 - {} - Command: READ
2021-07-29 05:25:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 05:25:45 INFO i.a.i.b.IntegrationRunner(run):86 - {} - Integration config: IntegrationConfig{command=READ, configPath='source_config.json', catalogPath='source_catalog.json', statePath='null'}
2021-07-29 05:25:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 05:25:46 INFO i.a.i.s.r.CdcStateManager(<init>):46 - {} - Initialized CDC state with: null
2021-07-29 05:25:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 05:25:46 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):137 - {} - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='client_order', namespace='admin_devclubniagadb'}, New Cursor Field: null. Resetting cursor value
2021-07-29 05:25:47 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 05:25:47 INFO i.a.i.s.m.MySqlSource(getIncrementalIterators):232 - {} - using CDC: false
2021-07-29 05:25:47 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 05:25:47 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):460 - {} - Queueing query for table: client_order
2021-07-29 05:25:47 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 05:25:47 INFO i.a.i.s.r.AbstractRelationalDbSource(lambda$read$2):200 - {} - Closing database connection pool.
2021-07-29 05:25:47 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 05:25:47 INFO i.a.i.s.r.AbstractRelationalDbSource(lambda$read$2):202 - {} - Closed database connection pool.
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - Exception in thread "main" java.lang.RuntimeException: java.sql.SQLException: YEAR
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at io.airbyte.db.jdbc.JdbcUtils$1.tryAdvance(JdbcUtils.java:76)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at java.base/java.util.Spliterators$1Adapter.hasNext(Spliterators.java:681)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:58)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:141)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:136)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at io.airbyte.commons.util.LazyAutoCloseableIterator.computeNext(LazyAutoCloseableIterator.java:62)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:141)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:136)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at com.google.common.collect.TransformedIterator.hasNext(TransformedIterator.java:42)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:58)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:141)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:136)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at com.google.common.collect.TransformedIterator.hasNext(TransformedIterator.java:42)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:58)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:141)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:136)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at io.airbyte.commons.util.CompositeIterator.computeNext(CompositeIterator.java:83)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:141)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:136)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:58)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:141)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:136)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at java.base/java.util.Iterator.forEachRemaining(Iterator.java:132)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:109)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at io.airbyte.integrations.source.mysql.MySqlSource.main(MySqlSource.java:250)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - Caused by: java.sql.SQLException: YEAR
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:129)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:97)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:89)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:63)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:73)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:85)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at com.mysql.cj.jdbc.result.ResultSetImpl.getTimestamp(ResultSetImpl.java:914)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at com.mysql.cj.jdbc.result.ResultSetImpl.getObject(ResultSetImpl.java:1254)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at org.apache.commons.dbcp2.DelegatingResultSet.getObject(DelegatingResultSet.java:733)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at org.apache.commons.dbcp2.DelegatingResultSet.getObject(DelegatingResultSet.java:733)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at io.airbyte.db.jdbc.JdbcUtils.rowToJson(JdbcUtils.java:103)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at io.airbyte.db.jdbc.JdbcUtils$1.tryAdvance(JdbcUtils.java:73)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	... 24 more
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - Caused by: com.mysql.cj.exceptions.WrongArgumentException: YEAR
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at java.base/jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at java.base/jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at java.base/jdk.internal.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at java.base/java.lang.reflect.Constructor.newInstanceWithCaller(Constructor.java:500)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at java.base/java.lang.reflect.Constructor.newInstance(Constructor.java:481)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at com.mysql.cj.exceptions.ExceptionFactory.createException(ExceptionFactory.java:61)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at com.mysql.cj.exceptions.ExceptionFactory.createException(ExceptionFactory.java:105)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at com.mysql.cj.result.SqlTimestampValueFactory.localCreateFromTimestamp(SqlTimestampValueFactory.java:112)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at com.mysql.cj.result.SqlTimestampValueFactory.localCreateFromTimestamp(SqlTimestampValueFactory.java:50)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at com.mysql.cj.result.AbstractDateTimeValueFactory.createFromTimestamp(AbstractDateTimeValueFactory.java:87)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at com.mysql.cj.protocol.a.MysqlBinaryValueDecoder.decodeTimestamp(MysqlBinaryValueDecoder.java:84)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at com.mysql.cj.protocol.result.AbstractResultsetRow.decodeAndCreateReturnValue(AbstractResultsetRow.java:87)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at com.mysql.cj.protocol.result.AbstractResultsetRow.getValueFromBytes(AbstractResultsetRow.java:241)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at com.mysql.cj.protocol.a.result.BinaryBufferRow.getValue(BinaryBufferRow.java:244)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	... 30 more
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - Caused by: java.lang.IllegalArgumentException: YEAR
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at java.base/java.util.GregorianCalendar.computeTime(GregorianCalendar.java:2646)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at java.base/java.util.Calendar.updateTime(Calendar.java:3429)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at java.base/java.util.Calendar.getTimeInMillis(Calendar.java:1813)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	at com.mysql.cj.result.SqlTimestampValueFactory.localCreateFromTimestamp(SqlTimestampValueFactory.java:108)
2021-07-29 05:25:47 ERROR () LineGobbler(voidCall):85 - 	... 36 more
2021-07-29 05:25:48 INFO () DefaultReplicationWorker(run):141 - Source thread complete.
2021-07-29 05:25:48 INFO () DefaultReplicationWorker(run):142 - Waiting for destination thread to join.
2021-07-29 05:25:48 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 05:25:48 INFO i.a.i.d.b.BigQueryUtils(createTable):83 - {} - Table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=niaga, tableId=_airbyte_tmp_sig_client_order}} created successfully
2021-07-29 05:25:50 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 05:25:50 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):80 - {} - Airbyte message consumer: succeeded.
2021-07-29 05:25:53 INFO () TemporalAttemptExecution(lambda$getCancellationChecker$3):180 - Running sync worker cancellation...
2021-07-29 05:25:53 INFO () DefaultReplicationWorker(cancel):270 - Cancelling replication worker...
2021-07-29 05:25:54 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 05:25:54 INFO i.a.i.d.b.BigQueryRecordConsumer(close):132 - {} - executing on success close procedure.
2021-07-29 05:25:58 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 05:25:58 INFO i.a.i.d.b.BigQueryRecordConsumer(copyTable):163 - {} - successfully copied tmp table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=niaga, tableId=_airbyte_tmp_sig_client_order}} to final table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=niaga, tableId=_airbyte_raw_client_order}}
2021-07-29 05:25:58 INFO () JsonSchemaValidator(test):76 - JSON schema validation failed. 
errors: $: null found, object expected
2021-07-29 05:25:58 ERROR () DefaultAirbyteStreamFactory(lambda$create$1):83 - Validation failed: null
2021-07-29 05:25:58 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 05:25:58 INFO i.a.i.b.IntegrationRunner(run):118 - {} - Completed integration: io.airbyte.integrations.destination.bigquery.BigQueryDestination
2021-07-29 05:25:58 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 05:25:58 INFO i.a.i.d.b.BigQueryDestination(main):280 - {} - completed destination: class io.airbyte.integrations.destination.bigquery.BigQueryDestination
2021-07-29 05:25:59 INFO () DefaultReplicationWorker(run):144 - Destination thread complete.
2021-07-29 05:25:59 ERROR () DefaultReplicationWorker(run):148 - Sync worker failed.
io.airbyte.workers.WorkerException: Source process exit with code 1. This warning is normal if the job was cancelled.
	at io.airbyte.workers.protocols.airbyte.DefaultAirbyteSource.close(DefaultAirbyteSource.java:134) ~[io.airbyte-airbyte-workers-0.27.2-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:146) ~[io.airbyte-airbyte-workers-0.27.2-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:52) ~[io.airbyte-airbyte-workers-0.27.2-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:146) ~[io.airbyte-airbyte-workers-0.27.2-alpha.jar:?]
	at java.lang.Thread.run(Thread.java:832) [?:?]
2021-07-29 05:25:59 INFO () DefaultReplicationWorker(run):172 - sync summary: io.airbyte.config.ReplicationAttemptSummary@1f82fb97[status=failed,recordsSynced=97,bytesSynced=56333,startTime=1627536343808,endTime=1627536359065]
2021-07-29 05:25:59 INFO () DefaultReplicationWorker(run):181 - Source did not output any state messages
2021-07-29 05:25:59 INFO () DefaultReplicationWorker(cancel):278 - Cancelling destination...
2021-07-29 05:25:59 INFO () DefaultAirbyteDestination(cancel):133 - Attempting to cancel destination process...
2021-07-29 05:25:59 INFO () DefaultAirbyteDestination(cancel):138 - Destination process exists, cancelling...
2021-07-29 05:25:59 INFO () DefaultAirbyteDestination(cancel):140 - Cancelled destination process!
2021-07-29 05:25:59 INFO () DefaultReplicationWorker(cancel):285 - Cancelling source...
2021-07-29 05:25:59 INFO () DefaultAirbyteSource(cancel):140 - Attempting to cancel source process...
2021-07-29 05:25:59 INFO () DefaultAirbyteSource(cancel):145 - Source process exists, cancelling...
2021-07-29 05:25:59 WARN () DefaultReplicationWorker(run):192 - State capture: No state retained.
2021-07-29 05:25:59 INFO () TemporalAttemptExecution(get):133 - Stopping cancellation check scheduling...
2021-07-29 05:25:59 INFO () RetryingTemporalAttemptExecution(get):118 - Last output present: true. Should attempt again: true
2021-07-29 05:25:59 INFO () RetryingTemporalAttemptExecution(get):123 - Starting attempt: 1 of 3
2021-07-29 05:25:59 INFO () TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.27.2-alpha
2021-07-29 05:25:59 INFO () DefaultAirbyteSource(cancel):147 - Cancelled source process!
2021-07-29 05:25:59 INFO () TemporalAttemptExecution(lambda$getCancellationChecker$3):184 - Interrupting worker thread...
2021-07-29 05:25:59 INFO () TemporalAttemptExecution(lambda$getCancellationChecker$3):187 - Cancelling completable future...
2021-07-29 05:25:59 WARN () CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):71 - Job either timeout-ed or was cancelled.
2021-07-29 05:25:59 INFO () TemporalAttemptExecution(lambda$getCancellationChecker$3):180 - Running sync worker cancellation...
2021-07-29 05:25:59 INFO () DefaultReplicationWorker(cancel):270 - Cancelling replication worker...
2021-07-29 05:26:09 INFO () DefaultReplicationWorker(cancel):278 - Cancelling destination...
2021-07-29 05:26:09 INFO () DefaultAirbyteDestination(cancel):133 - Attempting to cancel destination process...
2021-07-29 05:26:09 INFO () DefaultAirbyteDestination(cancel):136 - Destination process no longer exists, cancellation is a no-op.
2021-07-29 05:26:09 INFO () DefaultReplicationWorker(cancel):285 - Cancelling source...
2021-07-29 05:26:09 INFO () DefaultAirbyteSource(cancel):140 - Attempting to cancel source process...
2021-07-29 05:26:09 INFO () DefaultAirbyteSource(cancel):143 - Source process no longer exists, cancellation is a no-op.
2021-07-29 05:26:09 INFO () TemporalAttemptExecution(lambda$getCancellationChecker$3):184 - Interrupting worker thread...
2021-07-29 05:26:09 INFO () TemporalAttemptExecution(lambda$getCancellationChecker$3):187 - Cancelling completable future...
2021-07-29 05:26:09 WARN () CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):71 - Job either timeout-ed or was cancelled.
2021-07-29 05:26:09 INFO () TemporalAttemptExecution(get):133 - Stopping cancellation check scheduling...
2021-07-29 05:26:09 INFO () DefaultReplicationWorker(run):102 - start sync worker. job id: 2974 attempt id: 0
2021-07-29 05:26:09 INFO () DefaultReplicationWorker(run):111 - configured sync modes: {admin_devclubniagadb.client_order=full_refresh - append}
2021-07-29 05:26:09 INFO () DefaultAirbyteDestination(start):78 - Running destination...
2021-07-29 05:26:09 WARN () POJOActivityTaskHandler$POJOActivityImplementation(execute):243 - Activity failure. ActivityId=bfeea24f-4006-39b5-8d54-92ae52e4aa44, activityType=Replicate, attempt=1
java.util.concurrent.CancellationException: null
	at java.util.concurrent.CompletableFuture.cancel(CompletableFuture.java:2468) ~[?:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$3(TemporalAttemptExecution.java:190) ~[io.airbyte-airbyte-workers-0.27.2-alpha.jar:?]
	at io.airbyte.workers.temporal.CancellationHandler$TemporalCancellationHandler.checkAndHandleCancellation(CancellationHandler.java:70) ~[io.airbyte-airbyte-workers-0.27.2-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$4(TemporalAttemptExecution.java:193) ~[io.airbyte-airbyte-workers-0.27.2-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.get(TemporalAttemptExecution.java:124) ~[io.airbyte-airbyte-workers-0.27.2-alpha.jar:?]
	at io.airbyte.workers.temporal.RetryingTemporalAttemptExecution.get(RetryingTemporalAttemptExecution.java:133) ~[io.airbyte-airbyte-workers-0.27.2-alpha.jar:?]
	at io.airbyte.workers.temporal.SyncWorkflow$ReplicationActivityImpl.replicate(SyncWorkflow.java:199) ~[io.airbyte-airbyte-workers-0.27.2-alpha.jar:?]
	at jdk.internal.reflect.GeneratedMethodAccessor307.invoke(Unknown Source) ~[?:?]
	at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?]
	at java.lang.reflect.Method.invoke(Method.java:564) ~[?:?]
	at io.temporal.internal.sync.POJOActivityTaskHandler$POJOActivityInboundCallsInterceptor.execute(POJOActivityTaskHandler.java:277) ~[temporal-sdk-1.0.4.jar:?]
	at io.temporal.internal.sync.POJOActivityTaskHandler$POJOActivityImplementation.execute(POJOActivityTaskHandler.java:216) ~[temporal-sdk-1.0.4.jar:?]
	at io.temporal.internal.sync.POJOActivityTaskHandler.handle(POJOActivityTaskHandler.java:181) ~[temporal-sdk-1.0.4.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:192) ~[temporal-sdk-1.0.4.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:154) ~[temporal-sdk-1.0.4.jar:?]
	at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:73) ~[temporal-sdk-1.0.4.jar:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130) [?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:630) [?:?]
	at java.lang.Thread.run(Thread.java:832) [?:?]
2021-07-29 05:26:09 WARN () CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):71 - Job either timeout-ed or was cancelled.
2021-07-29 05:26:09 ERROR () WorkerUtils(gentleClose):58 - Exception while while waiting for process to finish
java.lang.InterruptedException: null
	at java.lang.Object.wait(Native Method) ~[?:?]
	at java.lang.Object.wait(Object.java:455) ~[?:?]
	at java.util.concurrent.TimeUnit.timedWait(TimeUnit.java:408) ~[?:?]
	at java.lang.ProcessImpl.waitFor(ProcessImpl.java:489) ~[?:?]
	at io.airbyte.workers.WorkerUtils.gentleClose(WorkerUtils.java:56) ~[io.airbyte-airbyte-workers-0.27.2-alpha.jar:?]
	at io.airbyte.workers.process.DockerProcessFactory.checkImageExists(DockerProcessFactory.java:166) ~[io.airbyte-airbyte-workers-0.27.2-alpha.jar:?]
	at io.airbyte.workers.process.DockerProcessFactory.create(DockerProcessFactory.java:95) ~[io.airbyte-airbyte-workers-0.27.2-alpha.jar:?]
	at io.airbyte.workers.process.AirbyteIntegrationLauncher.write(AirbyteIntegrationLauncher.java:163) ~[io.airbyte-airbyte-workers-0.27.2-alpha.jar:?]
	at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.start(DefaultAirbyteDestination.java:79) ~[io.airbyte-airbyte-workers-0.27.2-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:122) ~[io.airbyte-airbyte-workers-0.27.2-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:52) ~[io.airbyte-airbyte-workers-0.27.2-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:146) ~[io.airbyte-airbyte-workers-0.27.2-alpha.jar:?]
	at java.lang.Thread.run(Thread.java:832) [?:?]
2021-07-29 05:26:09 WARN () WorkerUtils(forceShutdown):128 - Process is taking too long to finish. Killing it
2021-07-29 05:26:09 ERROR () DefaultReplicationWorker(run):148 - Sync worker failed.
io.airbyte.workers.WorkerException: Could not find image: airbyte/destination-bigquery:0.3.7
	at io.airbyte.workers.process.DockerProcessFactory.create(DockerProcessFactory.java:96) ~[io.airbyte-airbyte-workers-0.27.2-alpha.jar:?]
	at io.airbyte.workers.process.AirbyteIntegrationLauncher.write(AirbyteIntegrationLauncher.java:163) ~[io.airbyte-airbyte-workers-0.27.2-alpha.jar:?]
	at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.start(DefaultAirbyteDestination.java:79) ~[io.airbyte-airbyte-workers-0.27.2-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:122) ~[io.airbyte-airbyte-workers-0.27.2-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:52) ~[io.airbyte-airbyte-workers-0.27.2-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:146) ~[io.airbyte-airbyte-workers-0.27.2-alpha.jar:?]
	at java.lang.Thread.run(Thread.java:832) [?:?]
2021-07-29 05:26:09 INFO () DefaultReplicationWorker(run):172 - sync summary: io.airbyte.config.ReplicationAttemptSummary@3162538a[status=cancelled,recordsSynced=0,bytesSynced=0,startTime=1627536369086,endTime=1627536369102]
2021-07-29 05:26:09 INFO () DefaultReplicationWorker(run):181 - Source did not output any state messages
2021-07-29 05:26:09 WARN () DefaultReplicationWorker(run):192 - State capture: No state retained.