2022-04-13 08:28:38 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.35.65-alpha
2022-04-13 08:28:38 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/30/0/logs.log
2022-04-13 08:28:38 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.65-alpha
2022-04-13 08:28:38 INFO i.a.w.DefaultReplicationWorker(run):104 - start sync worker. job id: 30 attempt id: 0
2022-04-13 08:28:38 INFO i.a.w.DefaultReplicationWorker(run):116 - configured sync modes: {dbo.Transactions=full_refresh - append}
2022-04-13 08:28:38 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination...
2022-04-13 08:28:38 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-mysql:0.1.18 exists...
2022-04-13 08:28:38 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-mysql:0.1.18 was found locally.
2022-04-13 08:28:38 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 30
2022-04-13 08:28:38 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/30/0 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-mysql:0.1.18 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.35.65-alpha -e WORKER_JOB_ID=30 airbyte/destination-mysql:0.1.18 write --config destination_config.json --catalog destination_catalog.json
2022-04-13 08:28:38 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-mssql:0.3.19 exists...
2022-04-13 08:28:38 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mssql:0.3.19 was found locally.
2022-04-13 08:28:38 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 30
2022-04-13 08:28:38 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/30/0 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/source-mssql:0.3.19 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.35.65-alpha -e WORKER_JOB_ID=30 airbyte/source-mssql:0.3.19 read --config source_config.json --catalog source_catalog.json --state input_state.json
2022-04-13 08:28:38 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):339 - Destination output thread started.
2022-04-13 08:28:38 INFO i.a.w.DefaultReplicationWorker(run):158 - Waiting for source and destination threads to complete.
2022-04-13 08:28:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):279 - Replication thread started.
2022-04-13 08:28:41 destination > SLF4J: Class path contains multiple SLF4J bindings.
2022-04-13 08:28:41 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-04-13 08:28:41 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-04-13 08:28:41 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-04-13 08:28:41 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-04-13 08:28:41 destination > 2022-04-13 08:28:41 INFO i.a.i.d.m.MySQLDestination(main):125 - starting destination: class io.airbyte.integrations.destination.mysql.MySQLDestination
2022-04-13 08:28:42 source > SLF4J: Class path contains multiple SLF4J bindings.
2022-04-13 08:28:42 source > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-04-13 08:28:42 source > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.30.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-04-13 08:28:42 source > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-04-13 08:28:42 source > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-04-13 08:28:43 source > 2022-04-13 08:28:43 INFO i.a.i.s.m.MssqlSource(main):448 - starting source: class io.airbyte.integrations.source.mssql.MssqlSource
2022-04-13 08:28:43 source > 2022-04-13 08:28:43 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {read=null, catalog=source_catalog.json, state=input_state.json, config=source_config.json}
2022-04-13 08:28:43 source > 2022-04-13 08:28:43 INFO i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-04-13 08:28:43 source > 2022-04-13 08:28:43 INFO i.a.i.b.IntegrationRunner(runInternal):122 - Command: READ
2022-04-13 08:28:43 source > 2022-04-13 08:28:43 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Integration config: IntegrationConfig{command=READ, configPath='source_config.json', catalogPath='source_catalog.json', statePath='input_state.json'}
2022-04-13 08:28:43 source > 2022-04-13 08:28:43 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-13 08:28:43 source > 2022-04-13 08:28:43 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-13 08:28:43 source > 2022-04-13 08:28:43 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-13 08:28:43 source > 2022-04-13 08:28:43 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword multiline - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-13 08:28:43 source > 2022-04-13 08:28:43 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL
2022-04-13 08:28:43 source > 2022-04-13 08:28:43 INFO i.a.i.s.r.CdcStateManager(<init>):26 - Initialized CDC state with: null
2022-04-13 08:28:43 source > 2022-04-13 08:28:43 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='Transactions', namespace='dbo'}, New Cursor Field: null. Resetting cursor value
2022-04-13 08:28:44 destination > 2022-04-13 08:28:44 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-04-13 08:28:44 destination > 2022-04-13 08:28:44 INFO i.a.i.b.IntegrationRunner(run):88 - Sentry transaction event: 0a545907c9f949ee82a91b0114a612df
2022-04-13 08:28:44 destination > 2022-04-13 08:28:44 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2022-04-13 08:28:44 destination > 2022-04-13 08:28:44 INFO i.a.i.b.IntegrationRunner(runInternal):107 - Command: WRITE
2022-04-13 08:28:44 destination > 2022-04-13 08:28:44 INFO i.a.i.b.IntegrationRunner(runInternal):108 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2022-04-13 08:28:44 destination > 2022-04-13 08:28:44 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-13 08:28:44 destination > 2022-04-13 08:28:44 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-13 08:28:44 destination > 2022-04-13 08:28:44 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-13 08:28:44 destination > 2022-04-13 08:28:44 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword multiline - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-13 08:28:44 destination > 2022-04-13 08:28:44 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL
2022-04-13 08:28:44 destination > 2022-04-13 08:28:44 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=Transactions, namespace=null, outputSchemaName=test_airbyte_2, tmpTableName=_airbyte_tmp_eob_transactions, outputTableName=_airbyte_raw_transactions, syncMode=append}
2022-04-13 08:28:44 destination > 2022-04-13 08:28:44 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):141 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-04-13 08:28:44 destination > 2022-04-13 08:28:44 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):121 - Preparing tmp tables in destination started for 1 streams
2022-04-13 08:28:44 destination > 2022-04-13 08:28:44 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream Transactions. schema: test_airbyte_2, tmp table name: _airbyte_tmp_eob_transactions
2022-04-13 08:28:45 destination > 2022-04-13 08:28:45 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):131 - Preparing tables in destination completed.
2022-04-13 08:29:20 source > 2022-04-13 08:29:20 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table Transactions column id (type int[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@45792847
2022-04-13 08:29:20 source > 2022-04-13 08:29:20 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table Transactions column name (type varchar[25]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4e25147a
2022-04-13 08:29:20 source > 2022-04-13 08:29:20 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table Transactions column state (type varchar[25]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4e25147a
2022-04-13 08:29:20 source > 2022-04-13 08:29:20 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table Transactions column date (type datetime[23]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4e25147a
2022-04-13 08:29:20 source > 2022-04-13 08:29:20 INFO i.a.i.s.m.MssqlSource(getIncrementalIterators):361 - using CDC: false
2022-04-13 08:29:20 source > 2022-04-13 08:29:20 INFO i.a.i.s.m.MssqlSource(queryTableFullRefresh):74 - Queueing query for table: Transactions
2022-04-13 08:29:20 source > 2022-04-13 08:29:20 INFO i.a.i.s.m.MssqlSource(queryTableFullRefresh):83 - Prepared SQL query for TableFullRefresh is: SELECT "id","name","state","date" FROM "dbo"."Transactions"
2022-04-13 08:29:20 source > 2022-04-13 08:29:20 INFO i.a.i.s.r.AbstractDbSource(lambda$read$2):124 - Closing database connection pool.
2022-04-13 08:29:20 source > 2022-04-13 08:29:20 INFO i.a.i.s.r.AbstractDbSource(lambda$read$2):126 - Closed database connection pool.
2022-04-13 08:29:20 source > 2022-04-13 08:29:20 INFO i.a.i.b.IntegrationRunner(runInternal):169 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-04-13 08:29:20 source > 2022-04-13 08:29:20 INFO i.a.i.s.m.MssqlSource(main):450 - completed source: class io.airbyte.integrations.source.mssql.MssqlSource
2022-04-13 08:29:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):305 - Total records read: 1 (76 bytes)
2022-04-13 08:29:20 INFO i.a.w.DefaultReplicationWorker(run):163 - One of source or destination thread complete. Waiting on the other.
2022-04-13 08:29:20 destination > 2022-04-13 08:29:20 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded.
2022-04-13 08:29:20 destination > 2022-04-13 08:29:20 INFO i.a.i.d.b.BufferedStreamConsumer(close):217 - executing on success close procedure.
2022-04-13 08:29:20 destination > 2022-04-13 08:29:20 INFO i.a.i.d.b.BufferedStreamConsumer(flushQueueToDestination):181 - Flushing buffer: 304 bytes
2022-04-13 08:29:20 destination > 2022-04-13 08:29:20 INFO i.a.i.d.b.BufferedStreamConsumer(lambda$flushQueueToDestination$1):185 - Flushing Transactions: 1 records
2022-04-13 08:29:20 destination > 2022-04-13 08:29:20 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):160 - Finalizing tables in destination started for 1 streams
2022-04-13 08:29:20 destination > 2022-04-13 08:29:20 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream Transactions. schema test_airbyte_2, tmp table _airbyte_tmp_eob_transactions, final table _airbyte_raw_transactions
2022-04-13 08:29:20 destination > 2022-04-13 08:29:20 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):178 - Executing finalization of tables.
2022-04-13 08:29:20 destination > 2022-04-13 08:29:20 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):180 - Finalizing tables in destination completed.
2022-04-13 08:29:20 destination > 2022-04-13 08:29:20 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):183 - Cleaning tmp tables in destination started for 1 streams
2022-04-13 08:29:20 destination > 2022-04-13 08:29:20 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream Transactions. schema test_airbyte_2, tmp table name: _airbyte_tmp_eob_transactions
2022-04-13 08:29:20 destination > 2022-04-13 08:29:20 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):192 - Cleaning tmp tables in destination completed.
2022-04-13 08:29:20 destination > 2022-04-13 08:29:20 INFO i.a.i.b.IntegrationRunner(runInternal):154 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2022-04-13 08:29:20 destination > 2022-04-13 08:29:20 INFO i.a.i.d.m.MySQLDestination(main):127 - completed destination: class io.airbyte.integrations.destination.mysql.MySQLDestination
2022-04-13 08:29:20 INFO i.a.w.DefaultReplicationWorker(run):165 - Source and destination threads complete.
2022-04-13 08:29:20 INFO i.a.w.DefaultReplicationWorker(run):228 - sync summary: io.airbyte.config.ReplicationAttemptSummary@4fbccb97[status=completed,recordsSynced=1,bytesSynced=76,startTime=1649838518792,endTime=1649838560514,totalStats=io.airbyte.config.SyncStats@24b9d2b1[recordsEmitted=1,bytesEmitted=76,stateMessagesEmitted=0,recordsCommitted=1],streamStats=[io.airbyte.config.StreamSyncStats@7d10e974[streamName=Transactions,stats=io.airbyte.config.SyncStats@5cb7550c[recordsEmitted=1,bytesEmitted=76,stateMessagesEmitted=<null>,recordsCommitted=1]]]]
2022-04-13 08:29:20 INFO i.a.w.DefaultReplicationWorker(run):250 - Source did not output any state messages
2022-04-13 08:29:20 WARN i.a.w.DefaultReplicationWorker(run):258 - State capture: No new state, falling back on input state: io.airbyte.config.State@757edd7e[state={}]
2022-04-13 08:29:20 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-04-13 08:29:20 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$1):147 - sync summary: io.airbyte.config.StandardSyncOutput@265fc950[standardSyncSummary=io.airbyte.config.StandardSyncSummary@535faf64[status=completed,recordsSynced=1,bytesSynced=76,startTime=1649838518792,endTime=1649838560514,totalStats=io.airbyte.config.SyncStats@24b9d2b1[recordsEmitted=1,bytesEmitted=76,stateMessagesEmitted=0,recordsCommitted=1],streamStats=[io.airbyte.config.StreamSyncStats@7d10e974[streamName=Transactions,stats=io.airbyte.config.SyncStats@5cb7550c[recordsEmitted=1,bytesEmitted=76,stateMessagesEmitted=<null>,recordsCommitted=1]]]],state=io.airbyte.config.State@757edd7e[state={}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@5e9df549[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@258328c[stream=io.airbyte.protocol.models.AirbyteStream@5a157ede[name=Transactions,jsonSchema={"type":"object","properties":{"id":{"type":"number"},"date":{"type":"string"},"name":{"type":"string"},"state":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=<null>,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}]],additionalProperties={}],failures=[]]
2022-04-13 08:29:20 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating...
2022-04-13 08:29:20 INFO i.a.c.p.ConfigRepository(updateConnectionState):731 - Updating connection 96bc49ca-26df-4898-8d86-7339b55a0883 state: io.airbyte.config.State@616cc6d[state={}]