2022-06-15 12:47:27 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/7/0/logs.log
2022-06-15 12:47:27 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.18-alpha
2022-06-15 12:47:27 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-mssql:0.4.2 exists...
2022-06-15 12:47:27 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mssql:0.4.2 was found locally.
2022-06-15 12:47:27 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 7
2022-06-15 12:47:27 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/7/0 --log-driver none --name source-mssql-check-7-0-ilskn --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_CONNECTOR_IMAGE=airbyte/source-mssql:0.4.2 -e WORKER_JOB_ATTEMPT=0 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.39.18-alpha -e WORKER_JOB_ID=7 airbyte/source-mssql:0.4.2 check --config source_config.json
2022-06-15 12:47:27 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings.
2022-06-15 12:47:27 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-06-15 12:47:27 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.30.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-06-15 12:47:27 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-06-15 12:47:27 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-06-15 12:47:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-15 12:47:28 INFO i.a.i.s.m.MssqlSource(main):449 - starting source: class io.airbyte.integrations.source.mssql.MssqlSource
2022-06-15 12:47:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-15 12:47:28 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json}
2022-06-15 12:47:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-15 12:47:28 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-06-15 12:47:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-15 12:47:28 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: CHECK
2022-06-15 12:47:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-15 12:47:28 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'}
2022-06-15 12:47:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-15 12:47:28 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-06-15 12:47:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-15 12:47:28 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-06-15 12:47:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-15 12:47:28 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-06-15 12:47:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-15 12:47:28 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-06-15 12:47:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-15 12:47:28 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL
2022-06-15 12:47:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-15 12:47:28 INFO c.z.h.HikariDataSource(<init>):80 - HikariPool-1 - Starting...
2022-06-15 12:47:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-15 12:47:28 INFO c.z.h.HikariDataSource(<init>):82 - HikariPool-1 - Start completed.
2022-06-15 12:47:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-15 12:47:28 INFO i.a.i.s.j.AbstractJdbcSource(lambda$getCheckOperations$1):93 - Attempting to get metadata from the database to see if we can connect.
2022-06-15 12:47:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-15 12:47:28 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated...
2022-06-15 12:47:28 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-15 12:47:28 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed.
2022-06-15 12:47:29 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-06-15 12:47:29 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/7/0/logs.log
2022-06-15 12:47:29 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.18-alpha
2022-06-15 12:47:29 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-postgres:0.3.20 exists...
2022-06-15 12:47:29 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-postgres:0.3.20 was found locally.
2022-06-15 12:47:29 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 7
2022-06-15 12:47:29 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/7/0 --log-driver none --name destination-postgres-check-7-0-mifks --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_CONNECTOR_IMAGE=airbyte/destination-postgres:0.3.20 -e WORKER_JOB_ATTEMPT=0 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.39.18-alpha -e WORKER_JOB_ID=7 airbyte/destination-postgres:0.3.20 check --config source_config.json
2022-06-15 12:47:29 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings.
2022-06-15 12:47:29 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-06-15 12:47:29 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-06-15 12:47:29 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-06-15 12:47:29 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-06-15 12:47:29 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-06-15 12:47:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-15 12:47:30 INFO i.a.i.d.p.PostgresDestination(main):90 - starting destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2022-06-15 12:47:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-15 12:47:30 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json}
2022-06-15 12:47:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-15 12:47:30 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2022-06-15 12:47:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-15 12:47:30 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: CHECK
2022-06-15 12:47:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-15 12:47:30 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'}
2022-06-15 12:47:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-15 12:47:30 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-06-15 12:47:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-15 12:47:30 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-06-15 12:47:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-15 12:47:30 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-06-15 12:47:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-15 12:47:30 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-06-15 12:47:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-15 12:47:30 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL
2022-06-15 12:47:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-15 12:47:30 INFO c.z.h.HikariDataSource(<init>):80 - HikariPool-1 - Starting...
2022-06-15 12:47:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-15 12:47:30 INFO c.z.h.HikariDataSource(<init>):82 - HikariPool-1 - Start completed.
2022-06-15 12:47:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-15 12:47:30 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated...
2022-06-15 12:47:30 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-15 12:47:30 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed.
2022-06-15 12:47:30 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-06-15 12:47:30 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/7/0/logs.log
2022-06-15 12:47:30 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.18-alpha
2022-06-15 12:47:31 INFO i.a.w.g.DefaultReplicationWorker(run):115 - start sync worker. job id: 7 attempt id: 0
2022-06-15 12:47:31 INFO i.a.w.g.DefaultReplicationWorker(run):127 - configured sync modes: {dbo.test_binary_data=incremental - append, dbo.test_byte_data=incremental - append}
2022-06-15 12:47:31 INFO i.a.w.i.DefaultAirbyteDestination(start):69 - Running destination...
2022-06-15 12:47:31 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-postgres:0.3.20 exists...
2022-06-15 12:47:31 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-postgres:0.3.20 was found locally.
2022-06-15 12:47:31 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 7
2022-06-15 12:47:31 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/7/0 --log-driver none --name destination-postgres-write-7-0-ttwqm --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_CONNECTOR_IMAGE=airbyte/destination-postgres:0.3.20 -e WORKER_JOB_ATTEMPT=0 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.39.18-alpha -e WORKER_JOB_ID=7 airbyte/destination-postgres:0.3.20 write --config destination_config.json --catalog destination_catalog.json
2022-06-15 12:47:31 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-mssql:0.4.2 exists...
2022-06-15 12:47:31 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mssql:0.4.2 was found locally.
2022-06-15 12:47:31 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 7
2022-06-15 12:47:31 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/7/0 --log-driver none --name source-mssql-read-7-0-snnma --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_CONNECTOR_IMAGE=airbyte/source-mssql:0.4.2 -e WORKER_JOB_ATTEMPT=0 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.39.18-alpha -e WORKER_JOB_ID=7 airbyte/source-mssql:0.4.2 read --config source_config.json --catalog source_catalog.json --state input_state.json
2022-06-15 12:47:31 INFO i.a.w.g.DefaultReplicationWorker(run):169 - Waiting for source and destination threads to complete.
2022-06-15 12:47:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):395 - Destination output thread started.
2022-06-15 12:47:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):298 - Replication thread started.
2022-06-15 12:47:31 source > SLF4J: Class path contains multiple SLF4J bindings.
2022-06-15 12:47:31 source > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-06-15 12:47:31 source > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.30.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-06-15 12:47:31 source > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-06-15 12:47:31 source > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-06-15 12:47:31 destination > SLF4J: Class path contains multiple SLF4J bindings.
2022-06-15 12:47:31 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-06-15 12:47:31 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-06-15 12:47:31 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-06-15 12:47:31 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-06-15 12:47:31 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-06-15 12:47:32 destination > 2022-06-15 12:47:32 INFO i.a.i.d.p.PostgresDestination(main):90 - starting destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2022-06-15 12:47:32 source > 2022-06-15 12:47:32 INFO i.a.i.s.m.MssqlSource(main):449 - starting source: class io.airbyte.integrations.source.mssql.MssqlSource
2022-06-15 12:47:32 source > 2022-06-15 12:47:32 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-06-15 12:47:32 destination > 2022-06-15 12:47:32 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-06-15 12:47:32 source > 2022-06-15 12:47:32 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-06-15 12:47:32 source > 2022-06-15 12:47:32 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: READ
2022-06-15 12:47:32 destination > 2022-06-15 12:47:32 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2022-06-15 12:47:32 destination > 2022-06-15 12:47:32 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: WRITE
2022-06-15 12:47:32 source > 2022-06-15 12:47:32 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=READ, configPath='source_config.json', catalogPath='source_catalog.json', statePath='input_state.json'}
2022-06-15 12:47:32 destination > 2022-06-15 12:47:32 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2022-06-15 12:47:32 destination > 2022-06-15 12:47:32 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-06-15 12:47:32 destination > 2022-06-15 12:47:32 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-06-15 12:47:32 destination > 2022-06-15 12:47:32 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-06-15 12:47:32 destination > 2022-06-15 12:47:32 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-06-15 12:47:32 source > 2022-06-15 12:47:32 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-06-15 12:47:32 source > 2022-06-15 12:47:32 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-06-15 12:47:32 source > 2022-06-15 12:47:32 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-06-15 12:47:32 source > 2022-06-15 12:47:32 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-06-15 12:47:32 destination > 2022-06-15 12:47:32 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL
2022-06-15 12:47:32 source > 2022-06-15 12:47:32 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL
2022-06-15 12:47:32 source > 2022-06-15 12:47:32 INFO i.a.i.s.r.CdcStateManager(<init>):26 - Initialized CDC state with: null
2022-06-15 12:47:32 source > 2022-06-15 12:47:32 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='test_binary_data', namespace='dbo'}, New Cursor Field: column_binar. Resetting cursor value
2022-06-15 12:47:32 source > 2022-06-15 12:47:32 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='test_byte_data', namespace='dbo'}, New Cursor Field: column_byte. Resetting cursor value
2022-06-15 12:47:32 destination > 2022-06-15 12:47:32 INFO c.z.h.HikariDataSource(<init>):80 - HikariPool-1 - Starting...
2022-06-15 12:47:32 destination > 2022-06-15 12:47:32 INFO c.z.h.HikariDataSource(<init>):82 - HikariPool-1 - Start completed.
2022-06-15 12:47:32 source > 2022-06-15 12:47:32 INFO c.z.h.HikariDataSource(<init>):80 - HikariPool-1 - Starting...
2022-06-15 12:47:32 source > 2022-06-15 12:47:32 INFO c.z.h.HikariDataSource(<init>):82 - HikariPool-1 - Start completed.
2022-06-15 12:47:32 destination > 2022-06-15 12:47:32 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):98 - Write config: WriteConfig{streamName=test_binary_data, namespace=dbo, outputSchemaName=dbo, tmpTableName=_airbyte_tmp_zhg_test_binary_data, outputTableName=_airbyte_raw_test_binary_data, syncMode=append}
2022-06-15 12:47:32 destination > 2022-06-15 12:47:32 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):98 - Write config: WriteConfig{streamName=test_byte_data, namespace=dbo, outputSchemaName=dbo, tmpTableName=_airbyte_tmp_vzh_test_byte_data, outputTableName=_airbyte_raw_test_byte_data, syncMode=append}
2022-06-15 12:47:32 destination > 2022-06-15 12:47:32 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-06-15 12:47:32 destination > 2022-06-15 12:47:32 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):123 - Preparing tmp tables in destination started for 2 streams
2022-06-15 12:47:32 destination > 2022-06-15 12:47:32 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):127 - Preparing tmp table in destination started for stream test_binary_data. schema: dbo, tmp table name: _airbyte_tmp_zhg_test_binary_data
2022-06-15 12:47:32 destination > 2022-06-15 12:47:32 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):127 - Preparing tmp table in destination started for stream test_byte_data. schema: dbo, tmp table name: _airbyte_tmp_vzh_test_byte_data
2022-06-15 12:47:32 destination > 2022-06-15 12:47:32 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):133 - Preparing tables in destination completed.
2022-06-15 12:47:32 source > 2022-06-15 12:47:32 INFO i.a.i.s.j.AbstractJdbcSource(discoverInternal):121 - Internal schemas to exclude: [spt_fallback_db, spt_monitor, cdc, spt_values, INFORMATION_SCHEMA, spt_fallback_usg, MSreplication_options, sys, spt_fallback_dev]
2022-06-15 12:47:35 source > 2022-06-15 12:47:35 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table test_byte_data column column_int (type int[10]) -> JsonSchemaType({type=number})
2022-06-15 12:47:35 source > 2022-06-15 12:47:35 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table test_byte_data column column_byte (type varbinary[500]) -> JsonSchemaType({type=string, contentEncoding=base64})
2022-06-15 12:47:35 source > 2022-06-15 12:47:35 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table test_binary_data column column_int (type int[10]) -> JsonSchemaType({type=number})
2022-06-15 12:47:35 source > 2022-06-15 12:47:35 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table test_binary_data column column_binar (type binary[500]) -> JsonSchemaType({type=string, contentEncoding=base64})
2022-06-15 12:47:35 source > 2022-06-15 12:47:35 INFO i.a.i.s.m.MssqlSource(getIncrementalIterators):368 - using CDC: false
2022-06-15 12:47:35 source > 2022-06-15 12:47:35 INFO i.a.i.s.m.MssqlSource(queryTableFullRefresh):78 - Queueing query for table: test_binary_data
2022-06-15 12:47:35 source > 2022-06-15 12:47:35 INFO i.a.d.j.s.AdaptiveStreamingQueryConfig(initialize):38 - Set initial fetch size: 10 rows
2022-06-15 12:47:35 source > 2022-06-15 12:47:35 INFO i.a.i.s.m.MssqlSource(queryTableFullRefresh):87 - Prepared SQL query for TableFullRefresh is: SELECT "column_int","column_binar" FROM "dbo"."test_binary_data"
2022-06-15 12:47:35 source > 2022-06-15 12:47:35 INFO i.a.i.s.m.MssqlSource(queryTableFullRefresh):78 - Queueing query for table: test_byte_data
2022-06-15 12:47:35 source > 2022-06-15 12:47:35 INFO i.a.d.j.s.AdaptiveStreamingQueryConfig(initialize):38 - Set initial fetch size: 10 rows
2022-06-15 12:47:35 source > 2022-06-15 12:47:35 INFO i.a.i.s.m.MssqlSource(queryTableFullRefresh):87 - Prepared SQL query for TableFullRefresh is: SELECT "column_int","column_byte" FROM "dbo"."test_byte_data"
2022-06-15 12:47:35 source > 2022-06-15 12:47:35 INFO i.a.d.j.s.AdaptiveStreamingQueryConfig(initialize):38 - Set initial fetch size: 10 rows
2022-06-15 12:47:35 source > 2022-06-15 12:47:35 INFO i.a.i.s.r.StateDecoratingIterator(computeNext):60 - State Report: stream name: AirbyteStreamNameNamespacePair{name='test_binary_data', namespace='dbo'}, original cursor field: null, original cursor null, cursor field: column_binar, new cursor: ttt\u0000ttt
2022-06-15 12:47:35 source > 2022-06-15 12:47:35 INFO i.a.d.j.s.AdaptiveStreamingQueryConfig(initialize):38 - Set initial fetch size: 10 rows
2022-06-15 12:47:35 source > 2022-06-15 12:47:35 INFO i.a.i.s.r.StateDecoratingIterator(computeNext):60 - State Report: stream name: AirbyteStreamNameNamespacePair{name='test_byte_data', namespace='dbo'}, original cursor field: null, original cursor null, cursor field: column_byte, new cursor: ttt\u0000ttt
2022-06-15 12:47:35 source > 2022-06-15 12:47:35 INFO i.a.i.s.r.AbstractDbSource(lambda$read$2):130 - Closing database connection pool.
2022-06-15 12:47:35 source > 2022-06-15 12:47:35 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated...
2022-06-15 12:47:35 source > 2022-06-15 12:47:35 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed.
2022-06-15 12:47:35 source > 2022-06-15 12:47:35 INFO i.a.i.s.r.AbstractDbSource(lambda$read$2):132 - Closed database connection pool.
2022-06-15 12:47:35 source > 2022-06-15 12:47:35 INFO i.a.i.b.IntegrationRunner(runInternal):171 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-06-15 12:47:35 source > 2022-06-15 12:47:35 INFO i.a.i.s.m.MssqlSource(main):451 - completed source: class io.airbyte.integrations.source.mssql.MssqlSource
2022-06-15 12:47:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):347 - Source has no more messages, closing connection.
2022-06-15 12:47:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):355 - Total records read: 12 (9 KB)
2022-06-15 12:47:35 INFO i.a.w.g.DefaultReplicationWorker(run):174 - One of source or destination thread complete. Waiting on the other.
2022-06-15 12:47:35 destination > 2022-06-15 12:47:35 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded.
2022-06-15 12:47:35 destination > 2022-06-15 12:47:35 INFO i.a.i.d.b.BufferedStreamConsumer(close):170 - executing on success close procedure.
2022-06-15 12:47:35 destination > 2022-06-15 12:47:35 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing test_binary_data: 3 records (35 KB)
2022-06-15 12:47:35 destination > 2022-06-15 12:47:35 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing test_byte_data: 7 records (35 KB)
2022-06-15 12:47:35 destination > 2022-06-15 12:47:35 INFO i.a.i.d.j.SqlOperations(onDestinationCloseOperations):138 - No onDestinationCloseOperations required for this destination.
2022-06-15 12:47:35 destination > 2022-06-15 12:47:35 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):163 - Finalizing tables in destination started for 2 streams
2022-06-15 12:47:35 destination > 2022-06-15 12:47:35 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):168 - Finalizing stream test_binary_data. schema dbo, tmp table _airbyte_tmp_zhg_test_binary_data, final table _airbyte_raw_test_binary_data
2022-06-15 12:47:35 destination > 2022-06-15 12:47:35 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):168 - Finalizing stream test_byte_data. schema dbo, tmp table _airbyte_tmp_vzh_test_byte_data, final table _airbyte_raw_test_byte_data
2022-06-15 12:47:35 destination > 2022-06-15 12:47:35 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):181 - Executing finalization of tables.
2022-06-15 12:47:35 destination > 2022-06-15 12:47:35 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):183 - Finalizing tables in destination completed.
2022-06-15 12:47:35 destination > 2022-06-15 12:47:35 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):186 - Cleaning tmp tables in destination started for 2 streams
2022-06-15 12:47:35 destination > 2022-06-15 12:47:35 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):190 - Cleaning tmp table in destination started for stream test_binary_data. schema dbo, tmp table name: _airbyte_tmp_zhg_test_binary_data
2022-06-15 12:47:35 destination > 2022-06-15 12:47:35 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):190 - Cleaning tmp table in destination started for stream test_byte_data. schema dbo, tmp table name: _airbyte_tmp_vzh_test_byte_data
2022-06-15 12:47:35 destination > 2022-06-15 12:47:35 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):195 - Cleaning tmp tables in destination completed.
2022-06-15 12:47:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):405 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@326889c[type=STATE,log=<null>,spec=<null>,connectionStatus=<null>,catalog=<null>,record=<null>,state=io.airbyte.protocol.models.AirbyteStateMessage@de16688[stateType=<null>,stream=<null>,global=<null>,data={"cdc":false,"streams":[{"stream_name":"test_binary_data","stream_namespace":"dbo","cursor_field":["column_binar"],"cursor":"ttt\\u0000ttt\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000"},{"stream_name":"test_byte_data","stream_namespace":"dbo","cursor_field":["column_byte"],"cursor":"ttt\\u0000ttt"}]},additionalProperties={streams=[]}],trace=<null>,additionalProperties={}]
2022-06-15 12:47:36 destination > 2022-06-15 12:47:36 INFO i.a.i.b.IntegrationRunner(runInternal):171 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2022-06-15 12:47:36 destination > 2022-06-15 12:47:36 INFO i.a.i.d.p.PostgresDestination(main):92 - completed destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2022-06-15 12:47:36 INFO i.a.w.g.DefaultReplicationWorker(run):176 - Source and destination threads complete.
2022-06-15 12:47:36 INFO i.a.w.g.DefaultReplicationWorker(run):239 - sync summary: io.airbyte.config.ReplicationAttemptSummary@2f89d870[status=completed,recordsSynced=10,bytesSynced=9226,startTime=1655297251001,endTime=1655297256141,totalStats=io.airbyte.config.SyncStats@1eb043b[recordsEmitted=10,bytesEmitted=9226,stateMessagesEmitted=2,recordsCommitted=10],streamStats=[io.airbyte.config.StreamSyncStats@35c902b4[streamName=test_byte_data,stats=io.airbyte.config.SyncStats@f43414f[recordsEmitted=7,bytesEmitted=281,stateMessagesEmitted=<null>,recordsCommitted=7]], io.airbyte.config.StreamSyncStats@6ee8428f[streamName=test_binary_data,stats=io.airbyte.config.SyncStats@37fb59b5[recordsEmitted=3,bytesEmitted=8945,stateMessagesEmitted=<null>,recordsCommitted=3]]]]
2022-06-15 12:47:36 INFO i.a.w.g.DefaultReplicationWorker(run):266 - Source output at least one state message
2022-06-15 12:47:36 INFO i.a.w.g.DefaultReplicationWorker(run):272 - State capture: Updated state to: Optional[io.airbyte.config.State@4a5a315c[state={"cdc":false,"streams":[{"stream_name":"test_binary_data","stream_namespace":"dbo","cursor_field":["column_binar"],"cursor":"ttt\\u0000ttt\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000"},{"stream_name":"test_byte_data","stream_namespace":"dbo","cursor_field":["column_byte"],"cursor":"ttt\\u0000ttt"}]}]]
2022-06-15 12:47:36 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-06-15 12:47:36 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):157 - sync summary: io.airbyte.config.StandardSyncOutput@6fe2f9ab[standardSyncSummary=io.airbyte.config.StandardSyncSummary@20de1f10[status=completed,recordsSynced=10,bytesSynced=9226,startTime=1655297251001,endTime=1655297256141,totalStats=io.airbyte.config.SyncStats@1eb043b[recordsEmitted=10,bytesEmitted=9226,stateMessagesEmitted=2,recordsCommitted=10],streamStats=[io.airbyte.config.StreamSyncStats@35c902b4[streamName=test_byte_data,stats=io.airbyte.config.SyncStats@f43414f[recordsEmitted=7,bytesEmitted=281,stateMessagesEmitted=<null>,recordsCommitted=7]], io.airbyte.config.StreamSyncStats@6ee8428f[streamName=test_binary_data,stats=io.airbyte.config.SyncStats@37fb59b5[recordsEmitted=3,bytesEmitted=8945,stateMessagesEmitted=<null>,recordsCommitted=3]]]],normalizationSummary=<null>,state=io.airbyte.config.State@4a5a315c[state={"cdc":false,"streams":[{"stream_name":"test_binary_data","stream_namespace":"dbo","cursor_field":["column_binar"],"cursor":"ttt\\u0000ttt\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000"},{"stream_name":"test_byte_data","stream_namespace":"dbo","cursor_field":["column_byte"],"cursor":"ttt\\u0000ttt"}]}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@2450a8bb[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@cb1fbf8[stream=io.airbyte.protocol.models.AirbyteStream@74e67464[name=test_binary_data,jsonSchema={"type":"object","properties":{"column_int":{"type":"number"},"column_binar":{"type":"string","contentEncoding":"base64"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=dbo,additionalProperties={}],syncMode=incremental,cursorField=[column_binar],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@2490c377[stream=io.airbyte.protocol.models.AirbyteStream@524a22e[name=test_byte_data,jsonSchema={"type":"object","properties":{"column_int":{"type":"number"},"column_byte":{"type":"string","contentEncoding":"base64"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=dbo,additionalProperties={}],syncMode=incremental,cursorField=[column_byte],destinationSyncMode=append,primaryKey=[],additionalProperties={}]],additionalProperties={}],failures=[]]
2022-06-15 12:47:36 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):236 - Stopping temporal heartbeating...
2022-06-15 12:47:36 INFO i.a.c.p.ConfigRepository(updateConnectionState):775 - Updating connection 8cec6f02-03a8-41be-8005-92f38d57bf04 state: io.airbyte.config.State@63e20e95[state={"cdc":false,"streams":[{"stream_name":"test_binary_data","stream_namespace":"dbo","cursor_field":["column_binar"],"cursor":"ttt\\u0000ttt\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000"},{"stream_name":"test_byte_data","stream_namespace":"dbo","cursor_field":["column_byte"],"cursor":"ttt\\u0000ttt"}]}]
2022-06-15 12:47:36 WARN i.t.i.a.POJOActivityTaskHandler(activityFailureToResult):307 - Activity failure. ActivityId=b5adebe1-4c04-3819-b60e-83ebfd4c9b61, activityType=Persist, attempt=1
org.jooq.exception.DataAccessException: SQL [update "public"."state" set "connection_id" = cast(? as uuid), "state" = cast(? as jsonb), "updated_at" = cast(? as timestamp with time zone) where "public"."state"."connection_id" = cast(? as uuid)]; ERROR: unsupported Unicode escape sequence
  Detail: \u0000 cannot be converted to text.
  Where: JSON data, line 1: ...":"dbo","cursor_field":["column_binar"],"cursor":...
	at org.jooq_3.13.4.POSTGRES.debug(Unknown Source) ~[?:?]
	at org.jooq.impl.Tools.translate(Tools.java:2753) ~[jooq-3.13.4.jar:?]
	at org.jooq.impl.DefaultExecuteContext.sqlException(DefaultExecuteContext.java:755) ~[jooq-3.13.4.jar:?]
	at org.jooq.impl.AbstractQuery.execute(AbstractQuery.java:385) ~[jooq-3.13.4.jar:?]
	at org.jooq.impl.AbstractDelegatingQuery.execute(AbstractDelegatingQuery.java:119) ~[jooq-3.13.4.jar:?]
	at io.airbyte.config.persistence.DatabaseConfigPersistence.lambda$writeStandardSyncState$47(DatabaseConfigPersistence.java:1170) ~[io.airbyte.airbyte-config-config-persistence-0.39.18-alpha.jar:?]
	at java.util.ArrayList.forEach(ArrayList.java:1511) ~[?:?]
	at io.airbyte.config.persistence.DatabaseConfigPersistence.writeStandardSyncState(DatabaseConfigPersistence.java:1159) ~[io.airbyte.airbyte-config-config-persistence-0.39.18-alpha.jar:?]
	at io.airbyte.config.persistence.DatabaseConfigPersistence.lambda$writeStandardSyncState$46(DatabaseConfigPersistence.java:1152) ~[io.airbyte.airbyte-config-config-persistence-0.39.18-alpha.jar:?]
	at io.airbyte.db.Database.lambda$transaction$0(Database.java:27) ~[io.airbyte.airbyte-db-db-lib-0.39.18-alpha.jar:?]
	at org.jooq.impl.DefaultDSLContext.lambda$transactionResult0$0(DefaultDSLContext.java:564) ~[jooq-3.13.4.jar:?]
	at org.jooq.impl.Tools$12$1.block(Tools.java:4926) ~[jooq-3.13.4.jar:?]
	at java.util.concurrent.ForkJoinPool.unmanagedBlock(ForkJoinPool.java:3463) ~[?:?]
	at java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3434) ~[?:?]
	at org.jooq.impl.Tools$12.get(Tools.java:4923) ~[jooq-3.13.4.jar:?]
	at org.jooq.impl.DefaultDSLContext.transactionResult0(DefaultDSLContext.java:616) ~[jooq-3.13.4.jar:?]
	at org.jooq.impl.DefaultDSLContext.transactionResult(DefaultDSLContext.java:533) ~[jooq-3.13.4.jar:?]
	at io.airbyte.db.Database.transaction(Database.java:27) ~[io.airbyte.airbyte-db-db-lib-0.39.18-alpha.jar:?]
	at io.airbyte.db.ExceptionWrappingDatabase.transaction(ExceptionWrappingDatabase.java:31) ~[io.airbyte.airbyte-db-db-lib-0.39.18-alpha.jar:?]
	at io.airbyte.config.persistence.DatabaseConfigPersistence.writeStandardSyncState(DatabaseConfigPersistence.java:1151) ~[io.airbyte.airbyte-config-config-persistence-0.39.18-alpha.jar:?]
	at io.airbyte.config.persistence.DatabaseConfigPersistence.writeConfigs(DatabaseConfigPersistence.java:1274) ~[io.airbyte.airbyte-config-config-persistence-0.39.18-alpha.jar:?]
	at io.airbyte.config.persistence.ValidatingConfigPersistence.writeConfigs(ValidatingConfigPersistence.java:89) ~[io.airbyte.airbyte-config-config-persistence-0.39.18-alpha.jar:?]
	at io.airbyte.config.persistence.ValidatingConfigPersistence.writeConfig(ValidatingConfigPersistence.java:80) ~[io.airbyte.airbyte-config-config-persistence-0.39.18-alpha.jar:?]
	at io.airbyte.config.persistence.ConfigRepository.updateConnectionState(ConfigRepository.java:778) ~[io.airbyte.airbyte-config-config-persistence-0.39.18-alpha.jar:?]
	at io.airbyte.workers.temporal.sync.PersistStateActivityImpl.persist(PersistStateActivityImpl.java:32) ~[io.airbyte-airbyte-workers-0.39.18-alpha.jar:?]
	at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:?]
	at jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77) ~[?:?]
	at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?]
	at java.lang.reflect.Method.invoke(Method.java:568) ~[?:?]
	at io.temporal.internal.activity.POJOActivityTaskHandler$POJOActivityInboundCallsInterceptor.execute(POJOActivityTaskHandler.java:214) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.activity.POJOActivityTaskHandler$POJOActivityImplementation.execute(POJOActivityTaskHandler.java:180) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.activity.POJOActivityTaskHandler.handle(POJOActivityTaskHandler.java:120) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:204) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:164) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:93) ~[temporal-sdk-1.8.1.jar:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) [?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) [?:?]
	at java.lang.Thread.run(Thread.java:833) [?:?]
Caused by: org.postgresql.util.PSQLException: ERROR: unsupported Unicode escape sequence
  Detail: \u0000 cannot be converted to text.
  Where: JSON data, line 1: ...":"dbo","cursor_field":["column_binar"],"cursor":...
	at org.postgresql.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:2675) ~[postgresql-42.3.4.jar:42.3.4]
	at org.postgresql.core.v3.QueryExecutorImpl.processResults(QueryExecutorImpl.java:2365) ~[postgresql-42.3.4.jar:42.3.4]
	at org.postgresql.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:355) ~[postgresql-42.3.4.jar:42.3.4]
	at org.postgresql.jdbc.PgStatement.executeInternal(PgStatement.java:490) ~[postgresql-42.3.4.jar:42.3.4]
	at org.postgresql.jdbc.PgStatement.execute(PgStatement.java:408) ~[postgresql-42.3.4.jar:42.3.4]
	at org.postgresql.jdbc.PgPreparedStatement.executeWithFlags(PgPreparedStatement.java:167) ~[postgresql-42.3.4.jar:42.3.4]
	at org.postgresql.jdbc.PgPreparedStatement.execute(PgPreparedStatement.java:156) ~[postgresql-42.3.4.jar:42.3.4]
	at com.zaxxer.hikari.pool.ProxyPreparedStatement.execute(ProxyPreparedStatement.java:44) ~[HikariCP-5.0.1.jar:?]
	at com.zaxxer.hikari.pool.HikariProxyPreparedStatement.execute(HikariProxyPreparedStatement.java) ~[HikariCP-5.0.1.jar:?]
	at org.jooq.tools.jdbc.DefaultPreparedStatement.execute(DefaultPreparedStatement.java:209) ~[jooq-3.13.4.jar:?]
	at org.jooq.impl.AbstractQuery.execute(AbstractQuery.java:453) ~[jooq-3.13.4.jar:?]
	at org.jooq.impl.AbstractDMLQuery.execute(AbstractDMLQuery.java:904) ~[jooq-3.13.4.jar:?]
	at org.jooq.impl.AbstractQuery.execute(AbstractQuery.java:371) ~[jooq-3.13.4.jar:?]
	... 34 more