2022-08-11 15:13:14 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/24/0/logs.log
2022-08-11 15:13:14 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.39.41-alpha
2022-08-11 15:13:14 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-postgres:0.4.38 exists...
2022-08-11 15:13:14 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-postgres:0.4.38 was found locally.
2022-08-11 15:13:14 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 24
2022-08-11 15:13:14 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/24/0 --log-driver none --name source-postgres-check-24-0-lwqom --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_CONNECTOR_IMAGE=airbyte/source-postgres:0.4.38 -e WORKER_JOB_ATTEMPT=0 -e AIRBYTE_VERSION=0.39.41-alpha -e WORKER_JOB_ID=24 --cpus=0.7 --memory=8g airbyte/source-postgres:0.4.38 check --config source_config.json
2022-08-11 15:13:14 ERROR i.a.c.i.LineGobbler(voidCall):82 - WARNING: Your kernel does not support swap limit capabilities or the cgroup is not mounted. Memory limited without swap.
2022-08-11 15:13:16 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:13:16 INFO i.a.i.b.a.AdaptiveSourceRunner$Runner(getSource):73 - Running source under deployment mode: OSS
2022-08-11 15:13:16 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:13:16 INFO i.a.i.b.a.AdaptiveSourceRunner$Runner(run):85 - Starting source: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-08-11 15:13:16 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:13:16 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json}
2022-08-11 15:13:16 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:13:16 INFO i.a.i.b.IntegrationRunner(runInternal):104 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-08-11 15:13:16 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:13:16 INFO i.a.i.b.IntegrationRunner(runInternal):105 - Command: CHECK
2022-08-11 15:13:16 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:13:16 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'}
2022-08-11 15:13:16 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:13:16 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-08-11 15:13:16 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:13:16 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-08-11 15:13:16 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:13:16 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-08-11 15:13:16 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:13:16 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-08-11 15:13:16 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:13:16 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword min - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-08-11 15:13:16 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:13:16 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword max - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-08-11 15:13:17 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:13:17 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL
2022-08-11 15:13:17 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:13:17 INFO c.z.h.HikariDataSource(<init>):80 - HikariPool-1 - Starting...
2022-08-11 15:13:17 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:13:17 INFO c.z.h.HikariDataSource(<init>):82 - HikariPool-1 - Start completed.
2022-08-11 15:13:18 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:13:18 INFO i.a.i.s.p.PostgresUtils(isCdc):29 - using CDC: false
2022-08-11 15:13:18 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:13:18 INFO i.a.i.s.j.AbstractJdbcSource(lambda$getCheckOperations$1):95 - Attempting to get metadata from the database to see if we can connect.
2022-08-11 15:13:18 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:13:18 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated...
2022-08-11 15:13:18 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:13:18 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed.
2022-08-11 15:13:18 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:13:18 INFO i.a.i.b.IntegrationRunner(runInternal):152 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-08-11 15:13:18 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:13:18 INFO i.a.i.b.a.AdaptiveSourceRunner$Runner(run):87 - Completed source: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-08-11 15:13:18 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-08-11 15:13:18 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/24/0/logs.log
2022-08-11 15:13:18 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.39.41-alpha
2022-08-11 15:13:18 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-postgres:0.3.21 exists...
2022-08-11 15:13:18 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-postgres:0.3.21 was found locally.
2022-08-11 15:13:18 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 24
2022-08-11 15:13:18 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/24/0 --log-driver none --name destination-postgres-check-24-0-xlqmu --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_CONNECTOR_IMAGE=airbyte/destination-postgres:0.3.21 -e WORKER_JOB_ATTEMPT=0 -e AIRBYTE_VERSION=0.39.41-alpha -e WORKER_JOB_ID=24 --cpus=0.7 --memory=8g airbyte/destination-postgres:0.3.21 check --config source_config.json
2022-08-11 15:13:18 ERROR i.a.c.i.LineGobbler(voidCall):82 - WARNING: Your kernel does not support swap limit capabilities or the cgroup is not mounted. Memory limited without swap.
2022-08-11 15:13:19 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings.
2022-08-11 15:13:19 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-08-11 15:13:19 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-reload4j-1.7.36.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-08-11 15:13:19 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-08-11 15:13:19 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-08-11 15:13:19 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-08-11 15:13:19 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-08-11 15:13:20 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:13:20 INFO i.a.i.d.p.PostgresDestination(main):90 - starting destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2022-08-11 15:13:20 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:13:20 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json}
2022-08-11 15:13:20 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:13:20 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2022-08-11 15:13:20 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:13:20 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: CHECK
2022-08-11 15:13:20 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:13:20 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'}
2022-08-11 15:13:21 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:13:21 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-08-11 15:13:21 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:13:21 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-08-11 15:13:21 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:13:21 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-08-11 15:13:21 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:13:21 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-08-11 15:13:21 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:13:21 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL
2022-08-11 15:13:21 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:13:21 INFO c.z.h.HikariDataSource(<init>):80 - HikariPool-1 - Starting...
2022-08-11 15:13:21 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:13:21 INFO c.z.h.HikariDataSource(<init>):82 - HikariPool-1 - Start completed.
2022-08-11 15:13:22 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:13:22 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated...
2022-08-11 15:13:22 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:13:22 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed.
2022-08-11 15:13:22 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:13:22 INFO i.a.i.b.IntegrationRunner(runInternal):171 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2022-08-11 15:13:22 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:13:22 INFO i.a.i.d.p.PostgresDestination(main):92 - completed destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2022-08-11 15:13:23 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-08-11 15:13:23 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/24/0/logs.log
2022-08-11 15:13:23 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.39.41-alpha
2022-08-11 15:13:23 INFO i.a.w.g.DefaultReplicationWorker(run):116 - start sync worker. job id: 24 attempt id: 0
2022-08-11 15:13:23 INFO i.a.w.g.DefaultReplicationWorker(run):128 - configured sync modes: {c3idb.c3_log_dtl=full_refresh - append}
2022-08-11 15:13:23 INFO i.a.w.i.DefaultAirbyteDestination(start):69 - Running destination...
2022-08-11 15:13:23 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-postgres:0.3.21 exists...
2022-08-11 15:13:23 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-postgres:0.3.21 was found locally.
2022-08-11 15:13:23 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 24
2022-08-11 15:13:23 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/24/0 --log-driver none --name destination-postgres-write-24-0-pqenb --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_CONNECTOR_IMAGE=airbyte/destination-postgres:0.3.21 -e WORKER_JOB_ATTEMPT=0 -e AIRBYTE_VERSION=0.39.41-alpha -e WORKER_JOB_ID=24 --cpus=0.7 --memory=8g airbyte/destination-postgres:0.3.21 write --config destination_config.json --catalog destination_catalog.json
2022-08-11 15:13:23 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-postgres:0.4.38 exists...
2022-08-11 15:13:23 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-postgres:0.4.38 was found locally.
2022-08-11 15:13:23 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 24
2022-08-11 15:13:23 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/24/0 --log-driver none --name source-postgres-read-24-0-unkxn --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_CONNECTOR_IMAGE=airbyte/source-postgres:0.4.38 -e WORKER_JOB_ATTEMPT=0 -e AIRBYTE_VERSION=0.39.41-alpha -e WORKER_JOB_ID=24 --cpus=0.7 --memory=8g airbyte/source-postgres:0.4.38 read --config source_config.json --catalog source_catalog.json --state input_state.json
2022-08-11 15:13:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):406 - Destination output thread started.
2022-08-11 15:13:23 INFO i.a.w.g.DefaultReplicationWorker(run):170 - Waiting for source and destination threads to complete.
2022-08-11 15:13:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):299 - Replication thread started.
2022-08-11 15:13:23 destination > WARNING: Your kernel does not support swap limit capabilities or the cgroup is not mounted. Memory limited without swap.
2022-08-11 15:13:23 source > WARNING: Your kernel does not support swap limit capabilities or the cgroup is not mounted. Memory limited without swap.
2022-08-11 15:13:23 destination > SLF4J: Class path contains multiple SLF4J bindings.
2022-08-11 15:13:23 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-08-11 15:13:23 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-reload4j-1.7.36.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-08-11 15:13:23 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-08-11 15:13:23 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-08-11 15:13:23 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-08-11 15:13:23 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-08-11 15:13:25 destination > 2022-08-11 15:13:25 INFO i.a.i.d.p.PostgresDestination(main):90 - starting destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2022-08-11 15:13:25 source > 2022-08-11 15:13:25 INFO i.a.i.b.a.AdaptiveSourceRunner$Runner(getSource):73 - Running source under deployment mode: OSS
2022-08-11 15:13:25 source > 2022-08-11 15:13:25 INFO i.a.i.b.a.AdaptiveSourceRunner$Runner(run):85 - Starting source: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-08-11 15:13:25 destination > 2022-08-11 15:13:25 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-08-11 15:13:25 destination > 2022-08-11 15:13:25 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2022-08-11 15:13:25 destination > 2022-08-11 15:13:25 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: WRITE
2022-08-11 15:13:25 destination > 2022-08-11 15:13:25 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2022-08-11 15:13:25 source > 2022-08-11 15:13:25 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-08-11 15:13:25 source > 2022-08-11 15:13:25 INFO i.a.i.b.IntegrationRunner(runInternal):104 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-08-11 15:13:25 source > 2022-08-11 15:13:25 INFO i.a.i.b.IntegrationRunner(runInternal):105 - Command: READ
2022-08-11 15:13:25 source > 2022-08-11 15:13:25 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Integration config: IntegrationConfig{command=READ, configPath='source_config.json', catalogPath='source_catalog.json', statePath='input_state.json'}
2022-08-11 15:13:25 destination > 2022-08-11 15:13:25 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-08-11 15:13:25 destination > 2022-08-11 15:13:25 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-08-11 15:13:25 destination > 2022-08-11 15:13:25 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-08-11 15:13:25 destination > 2022-08-11 15:13:25 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-08-11 15:13:25 source > 2022-08-11 15:13:25 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-08-11 15:13:25 source > 2022-08-11 15:13:25 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-08-11 15:13:25 source > 2022-08-11 15:13:25 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-08-11 15:13:25 source > 2022-08-11 15:13:25 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-08-11 15:13:25 source > 2022-08-11 15:13:25 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword min - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-08-11 15:13:25 source > 2022-08-11 15:13:25 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword max - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-08-11 15:13:26 destination > 2022-08-11 15:13:26 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL
2022-08-11 15:13:26 source > 2022-08-11 15:13:26 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL
2022-08-11 15:13:26 destination > 2022-08-11 15:13:26 INFO c.z.h.HikariDataSource(<init>):80 - HikariPool-1 - Starting...
2022-08-11 15:13:26 source > 2022-08-11 15:13:26 INFO c.z.h.HikariDataSource(<init>):80 - HikariPool-1 - Starting...
2022-08-11 15:13:26 destination > 2022-08-11 15:13:26 INFO c.z.h.HikariDataSource(<init>):82 - HikariPool-1 - Start completed.
2022-08-11 15:13:26 source > 2022-08-11 15:13:26 INFO c.z.h.HikariDataSource(<init>):82 - HikariPool-1 - Start completed.
2022-08-11 15:13:26 destination > 2022-08-11 15:13:26 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):97 - Write config: WriteConfig{streamName=nocdclast_c3_log_dtl, namespace=null, outputSchemaName=c3stat, tmpTableName=_airbyte_tmp_mdu_nocdclast_c3_log_dtl, outputTableName=_airbyte_raw_nocdclast_c3_log_dtl, syncMode=append}
2022-08-11 15:13:26 destination > 2022-08-11 15:13:26 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-08-11 15:13:26 destination > 2022-08-11 15:13:26 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):122 - Preparing tmp tables in destination started for 1 streams
2022-08-11 15:13:26 destination > 2022-08-11 15:13:26 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):126 - Preparing tmp table in destination started for stream nocdclast_c3_log_dtl. schema: c3stat, tmp table name: _airbyte_tmp_mdu_nocdclast_c3_log_dtl
2022-08-11 15:13:27 source > 2022-08-11 15:13:27 INFO i.a.i.s.p.PostgresUtils(isCdc):29 - using CDC: false
2022-08-11 15:13:27 source > 2022-08-11 15:13:27 INFO i.a.i.s.j.AbstractJdbcSource(lambda$getCheckOperations$1):95 - Attempting to get metadata from the database to see if we can connect.
2022-08-11 15:13:27 source > 2022-08-11 15:13:27 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated...
2022-08-11 15:13:27 source > 2022-08-11 15:13:27 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed.
2022-08-11 15:13:27 source > 2022-08-11 15:13:27 INFO i.a.i.s.r.s.StateManagerFactory(createStateManager):48 - Legacy state manager selected to manage state object with type LEGACY.
2022-08-11 15:13:27 source > 2022-08-11 15:13:27 INFO i.a.i.s.r.s.CursorManager(createCursorInfoForStream):161 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='c3_log_dtl', namespace='c3idb'}, New Cursor Field: null. Resetting cursor value
2022-08-11 15:13:27 source > 2022-08-11 15:13:27 INFO i.a.i.s.r.CdcStateManager(<init>):29 - Initialized CDC state with: null
2022-08-11 15:13:27 source > 2022-08-11 15:13:27 INFO c.z.h.HikariDataSource(<init>):80 - HikariPool-2 - Starting...
2022-08-11 15:13:27 source > 2022-08-11 15:13:27 INFO c.z.h.HikariDataSource(<init>):82 - HikariPool-2 - Start completed.
2022-08-11 15:13:27 source > 2022-08-11 15:13:27 INFO i.a.i.s.p.PostgresSource(discoverRawTables):207 - Checking schema: c3idb
2022-08-11 15:13:27 source > 2022-08-11 15:13:27 INFO i.a.i.s.j.AbstractJdbcSource(discoverInternal):123 - Internal schemas to exclude: [catalog_history, information_schema, pg_catalog, pg_internal]
2022-08-11 15:13:27 destination > 2022-08-11 15:13:27 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):132 - Preparing tables in destination completed.
2022-08-11 15:13:28 source > 2022-08-11 15:13:28 INFO i.a.d.j.s.AdaptiveStreamingQueryConfig(initialize):38 - Set initial fetch size: 10 rows
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_task_properties column task_seq (type varchar[32]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_task_properties column task_name (type varchar[100]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_task_properties column task_stage (type varchar[100]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_task_properties column task_package_name (type varchar[100]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_task_properties column task_procedure_name (type varchar[100]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_task_properties column task_run_order (type numeric[15]) -> JsonSchemaType({type=number})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_task_properties column artefact_type_seq (type varchar[32]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_task_properties column task_parallel_factor (type varchar[50]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_task_properties column parent_task_seq (type varchar[32]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_task_properties column is_period_required (type bool[1]) -> JsonSchemaType({type=boolean})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_task_properties column is_processing_interval_required (type bool[1]) -> JsonSchemaType({type=boolean})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_file_ctrl column file_seq (type varchar[32]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_file_ctrl column req_seq (type varchar[32]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_file_ctrl column upload_date (type timestamp[22]) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_file_ctrl column orig_filename (type varchar[2000]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_file_ctrl column filename (type varchar[2000]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_file_ctrl column period_seq (type varchar[32]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_file_ctrl column period_key (type varchar[100]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_file_ctrl column artefact_ctx_seq (type varchar[32]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_file_ctrl column artefact_ctx_id (type varchar[100]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_file_ctrl column remove_date (type timestamp[22]) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_file_ctrl column approved_by (type varchar[256]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_file_ctrl column approved_status (type varchar[256]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_file_ctrl column approved_datetime (type timestamp[22]) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_file_ctrl column upload_user (type varchar[255]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_file_ctrl column numberofrows (type numeric[0]) -> JsonSchemaType({type=number})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_file_ctrl column interface_seq (type varchar[32]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_file_ctrl column interface_id (type varchar[100]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_file_ctrl column interface_artefact_type_seq (type varchar[32]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_file_ctrl column interface_type (type varchar[100]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3_log_dtl column log_dtl_seq (type int8[19]) -> JsonSchemaType({type=number, airbyte_type=integer})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3_log_dtl column run_seq (type varchar[32]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3_log_dtl column log_type (type varchar[32]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3_log_dtl column description (type varchar[500]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3_log_dtl column mapping_seq (type varchar[32]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3_log_dtl column mapping_order (type varchar[32]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3_log_dtl column source_artefact_type_seq (type varchar[32]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3_log_dtl column source_artefact_seq (type varchar[32]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3_log_dtl column target_artefact_type_seq (type varchar[32]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3_log_dtl column target_artefact_seq (type varchar[32]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3_log_dtl column row_cnt (type varchar[32]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3_log_dtl column start_time (type timestamp[29]) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3_log_dtl column end_time (type timestamp[29]) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3_log_dtl column sql_query (type text[2147483647]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3_log_dtl column severity (type varchar[32]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3_log_dtl column error_code (type varchar[100]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3_log_dtl column error_detail (type varchar[10485760]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3_log_dtl column stage (type varchar[32]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3_log_dtl column mapping_id (type varchar[100]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_request_run_detail column req_seq (type varchar[32]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_request_run_detail column run_seq (type varchar[32]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_request_run_detail column task_seq (type varchar[32]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_request_run_detail column task_name (type varchar[100]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_request_run_detail column start_time (type timestamp[22]) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_request_run_detail column stop_time (type timestamp[22]) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_request_run_detail column status (type varchar[30]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_request_run_detail column processing_start_dt (type timestamp[22]) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_request_run_detail column processing_end_dt (type timestamp[22]) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_request_run_detail column period_seq (type varchar[32]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_request_run_detail column period_key (type varchar[100]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_request_run_detail column artefact_ctx_seq (type varchar[32]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_request_run_detail column artefact_ctx_id (type varchar[100]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_request_run_detail column artefact_seq (type varchar[32]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_request_run_detail column artefact_id (type varchar[100]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_request_run_detail column artefact_group_seq (type varchar[32]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_request_run_detail column artefact_group_id (type varchar[100]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_request_run_detail column execution_group_seq (type varchar[32]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_request_run_detail column execution_group_id (type varchar[100]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_request_run_detail column filename (type varchar[2000]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_request_run_detail column user_filename (type varchar[2000]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_request_run_detail column task_options (type text[2147483647]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_request_run_detail column source_period_seq (type varchar[32]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_request_run_detail column source_period_key (type varchar[100]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_request_run_detail column export_type (type varchar[32]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_request_run_detail column ext_artefact_id (type varchar[100]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_request_run_detail column ext_artefact_seq (type varchar[32]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_request column req_seq (type varchar[32]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_request column request_time (type timestamp[22]) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_request column request_tasks (type varchar[256]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_request column start_time (type timestamp[22]) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_request column stop_time (type timestamp[22]) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_request column status (type varchar[30]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_request column userid (type varchar[100]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_request column command (type text[2147483647]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_request column debug_level (type varchar[25]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_request column ctx_seq (type varchar[100]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_request column request_type (type varchar[30]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_request column job_id (type varchar[36]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):145 - Table c3i_request column job_run_id (type varchar[36]) -> JsonSchemaType({type=string})
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.p.PostgresSource(discoverRawTables):211 - Found table: c3idb.c3i_task_properties
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.p.PostgresSource(discoverRawTables):211 - Found table: c3idb.c3i_file_ctrl
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.p.PostgresSource(discoverRawTables):211 - Found table: c3idb.c3_log_dtl
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.p.PostgresSource(discoverRawTables):211 - Found table: c3idb.c3i_request_run_detail
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.p.PostgresSource(discoverRawTables):211 - Found table: c3idb.c3i_request
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.p.PostgresUtils(isCdc):29 - using CDC: false
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.p.PostgresUtils(isCdc):29 - using CDC: false
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: c3_log_dtl
2022-08-11 15:15:04 source > 2022-08-11 15:15:04 INFO i.a.d.j.s.AdaptiveStreamingQueryConfig(initialize):38 - Set initial fetch size: 10 rows
2022-08-11 15:15:04 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_type - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-08-11 15:15:05 source > 2022-08-11 15:15:05 INFO i.a.d.j.s.TwoStageSizeEstimator(getTargetBufferByteSize):72 - Max memory limit: 6227755008, JDBC buffer size: 1073741824
2022-08-11 15:15:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 1000 (1 MB)
2022-08-11 15:15:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 2000 (1 MB)
2022-08-11 15:15:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 3000 (2 MB)
2022-08-11 15:15:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 4000 (3 MB)
2022-08-11 15:15:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 5000 (4 MB)
2022-08-11 15:15:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 6000 (5 MB)
2022-08-11 15:15:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 7000 (6 MB)
2022-08-11 15:15:07 destination > 2022-08-11 15:15:07 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 7168 records (24 MB)
2022-08-11 15:15:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 8000 (7 MB)
2022-08-11 15:15:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 9000 (8 MB)
2022-08-11 15:15:08 source > 2022-08-11 15:15:08 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 10000
2022-08-11 15:15:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 10000 (9 MB)
2022-08-11 15:15:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 11000 (10 MB)
2022-08-11 15:15:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 12000 (11 MB)
2022-08-11 15:15:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 13000 (12 MB)
2022-08-11 15:15:09 destination > 2022-08-11 15:15:09 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 6294 records (24 MB)
2022-08-11 15:15:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 14000 (13 MB)
2022-08-11 15:15:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 15000 (14 MB)
2022-08-11 15:15:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 16000 (15 MB)
2022-08-11 15:15:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 17000 (16 MB)
2022-08-11 15:15:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 18000 (17 MB)
2022-08-11 15:15:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 19000 (18 MB)
2022-08-11 15:15:10 destination > 2022-08-11 15:15:10 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 6233 records (24 MB)
2022-08-11 15:15:10 source > 2022-08-11 15:15:10 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 20000
2022-08-11 15:15:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 20000 (19 MB)
2022-08-11 15:15:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 21000 (20 MB)
2022-08-11 15:15:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 22000 (21 MB)
2022-08-11 15:15:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 23000 (22 MB)
2022-08-11 15:15:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 24000 (23 MB)
2022-08-11 15:15:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 25000 (24 MB)
2022-08-11 15:15:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 26000 (24 MB)
2022-08-11 15:15:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 27000 (25 MB)
2022-08-11 15:15:12 destination > 2022-08-11 15:15:12 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 7459 records (24 MB)
2022-08-11 15:15:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 28000 (26 MB)
2022-08-11 15:15:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 29000 (27 MB)
2022-08-11 15:15:13 source > 2022-08-11 15:15:13 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 30000
2022-08-11 15:15:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 30000 (28 MB)
2022-08-11 15:15:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 31000 (29 MB)
2022-08-11 15:15:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 32000 (30 MB)
2022-08-11 15:15:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 33000 (31 MB)
2022-08-11 15:15:14 destination > 2022-08-11 15:15:14 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 6529 records (24 MB)
2022-08-11 15:15:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 34000 (32 MB)
2022-08-11 15:15:15 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 35000 (32 MB)
2022-08-11 15:15:15 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 36000 (33 MB)
2022-08-11 15:15:16 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 37000 (34 MB)
2022-08-11 15:15:16 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 38000 (35 MB)
2022-08-11 15:15:16 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 39000 (36 MB)
2022-08-11 15:15:16 source > 2022-08-11 15:15:16 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 40000
2022-08-11 15:15:16 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 40000 (37 MB)
2022-08-11 15:15:16 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 41000 (38 MB)
2022-08-11 15:15:16 destination > 2022-08-11 15:15:16 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 7675 records (24 MB)
2022-08-11 15:15:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 42000 (39 MB)
2022-08-11 15:15:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 43000 (40 MB)
2022-08-11 15:15:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 44000 (41 MB)
2022-08-11 15:15:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 45000 (41 MB)
2022-08-11 15:15:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 46000 (42 MB)
2022-08-11 15:15:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 47000 (43 MB)
2022-08-11 15:15:18 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 48000 (44 MB)
2022-08-11 15:15:18 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 49000 (45 MB)
2022-08-11 15:15:18 destination > 2022-08-11 15:15:18 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 7869 records (24 MB)
2022-08-11 15:15:18 source > 2022-08-11 15:15:18 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 50000
2022-08-11 15:15:18 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 50000 (46 MB)
2022-08-11 15:15:18 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 51000 (46 MB)
2022-08-11 15:15:19 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 52000 (47 MB)
2022-08-11 15:15:19 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 53000 (48 MB)
2022-08-11 15:15:19 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 54000 (49 MB)
2022-08-11 15:15:19 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 55000 (50 MB)
2022-08-11 15:15:19 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 56000 (50 MB)
2022-08-11 15:15:19 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 57000 (51 MB)
2022-08-11 15:15:19 destination > 2022-08-11 15:15:19 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 7826 records (24 MB)
2022-08-11 15:15:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 58000 (52 MB)
2022-08-11 15:15:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 59000 (53 MB)
2022-08-11 15:15:20 source > 2022-08-11 15:15:20 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 60000
2022-08-11 15:15:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 60000 (53 MB)
2022-08-11 15:15:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 61000 (54 MB)
2022-08-11 15:15:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 62000 (55 MB)
2022-08-11 15:15:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 63000 (56 MB)
2022-08-11 15:15:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 64000 (57 MB)
2022-08-11 15:15:21 destination > 2022-08-11 15:15:21 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 7494 records (24 MB)
2022-08-11 15:15:21 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 65000 (58 MB)
2022-08-11 15:15:21 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 66000 (59 MB)
2022-08-11 15:15:21 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 67000 (60 MB)
2022-08-11 15:15:21 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 68000 (61 MB)
2022-08-11 15:15:22 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 69000 (61 MB)
2022-08-11 15:15:22 source > 2022-08-11 15:15:22 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 70000
2022-08-11 15:15:22 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 70000 (62 MB)
2022-08-11 15:15:22 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 71000 (63 MB)
2022-08-11 15:15:22 destination > 2022-08-11 15:15:22 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 7303 records (24 MB)
2022-08-11 15:15:22 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 72000 (64 MB)
2022-08-11 15:15:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 73000 (65 MB)
2022-08-11 15:15:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 74000 (66 MB)
2022-08-11 15:15:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 75000 (66 MB)
2022-08-11 15:15:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 76000 (67 MB)
2022-08-11 15:15:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 77000 (68 MB)
2022-08-11 15:15:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 78000 (69 MB)
2022-08-11 15:15:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 79000 (70 MB)
2022-08-11 15:15:23 destination > 2022-08-11 15:15:23 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 7879 records (24 MB)
2022-08-11 15:15:24 source > 2022-08-11 15:15:23 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 80000
2022-08-11 15:15:24 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 80000 (71 MB)
2022-08-11 15:15:24 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 81000 (72 MB)
2022-08-11 15:15:24 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 82000 (72 MB)
2022-08-11 15:15:24 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 83000 (73 MB)
2022-08-11 15:15:24 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 84000 (74 MB)
2022-08-11 15:15:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 85000 (75 MB)
2022-08-11 15:15:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 86000 (76 MB)
2022-08-11 15:15:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 87000 (77 MB)
2022-08-11 15:15:25 destination > 2022-08-11 15:15:25 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 8138 records (24 MB)
2022-08-11 15:15:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 88000 (77 MB)
2022-08-11 15:15:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 89000 (78 MB)
2022-08-11 15:15:26 source > 2022-08-11 15:15:25 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 90000
2022-08-11 15:15:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 90000 (79 MB)
2022-08-11 15:15:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 91000 (80 MB)
2022-08-11 15:15:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 92000 (80 MB)
2022-08-11 15:15:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 93000 (81 MB)
2022-08-11 15:15:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 94000 (82 MB)
2022-08-11 15:15:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 95000 (83 MB)
2022-08-11 15:15:26 destination > 2022-08-11 15:15:26 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 7981 records (24 MB)
2022-08-11 15:15:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 96000 (83 MB)
2022-08-11 15:15:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 97000 (84 MB)
2022-08-11 15:15:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 98000 (85 MB)
2022-08-11 15:15:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 99000 (86 MB)
2022-08-11 15:15:27 source > 2022-08-11 15:15:27 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 100000
2022-08-11 15:15:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 100000 (87 MB)
2022-08-11 15:15:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 101000 (88 MB)
2022-08-11 15:15:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 102000 (89 MB)
2022-08-11 15:15:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 103000 (89 MB)
2022-08-11 15:15:28 destination > 2022-08-11 15:15:28 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 7475 records (24 MB)
2022-08-11 15:15:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 104000 (90 MB)
2022-08-11 15:15:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 105000 (91 MB)
2022-08-11 15:15:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 106000 (92 MB)
2022-08-11 15:15:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 107000 (93 MB)
2022-08-11 15:15:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 108000 (94 MB)
2022-08-11 15:15:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 109000 (95 MB)
2022-08-11 15:15:29 destination > 2022-08-11 15:15:29 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 6413 records (24 MB)
2022-08-11 15:15:29 source > 2022-08-11 15:15:29 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 110000
2022-08-11 15:15:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 110000 (96 MB)
2022-08-11 15:15:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 111000 (97 MB)
2022-08-11 15:15:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 112000 (97 MB)
2022-08-11 15:15:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 113000 (98 MB)
2022-08-11 15:15:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 114000 (99 MB)
2022-08-11 15:15:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 115000 (100 MB)
2022-08-11 15:15:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 116000 (101 MB)
2022-08-11 15:15:30 destination > 2022-08-11 15:15:30 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 6986 records (24 MB)
2022-08-11 15:15:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 117000 (102 MB)
2022-08-11 15:15:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 118000 (103 MB)
2022-08-11 15:15:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 119000 (104 MB)
2022-08-11 15:15:31 source > 2022-08-11 15:15:31 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 120000
2022-08-11 15:15:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 120000 (105 MB)
2022-08-11 15:15:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 121000 (106 MB)
2022-08-11 15:15:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 122000 (106 MB)
2022-08-11 15:15:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 123000 (107 MB)
2022-08-11 15:15:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 124000 (108 MB)
2022-08-11 15:15:32 destination > 2022-08-11 15:15:32 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 7485 records (24 MB)
2022-08-11 15:15:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 125000 (109 MB)
2022-08-11 15:15:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 126000 (109 MB)
2022-08-11 15:15:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 127000 (110 MB)
2022-08-11 15:15:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 128000 (111 MB)
2022-08-11 15:15:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 129000 (112 MB)
2022-08-11 15:15:33 source > 2022-08-11 15:15:33 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 130000
2022-08-11 15:15:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 130000 (112 MB)
2022-08-11 15:15:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 131000 (113 MB)
2022-08-11 15:15:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 132000 (114 MB)
2022-08-11 15:15:34 destination > 2022-08-11 15:15:34 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 7787 records (24 MB)
2022-08-11 15:15:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 133000 (115 MB)
2022-08-11 15:15:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 134000 (116 MB)
2022-08-11 15:15:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 135000 (117 MB)
2022-08-11 15:15:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 136000 (118 MB)
2022-08-11 15:15:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 137000 (118 MB)
2022-08-11 15:15:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 138000 (119 MB)
2022-08-11 15:15:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 139000 (120 MB)
2022-08-11 15:15:35 source > 2022-08-11 15:15:35 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 140000
2022-08-11 15:15:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 140000 (121 MB)
2022-08-11 15:15:35 destination > 2022-08-11 15:15:35 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 8132 records (24 MB)
2022-08-11 15:15:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 141000 (121 MB)
2022-08-11 15:15:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 142000 (122 MB)
2022-08-11 15:15:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 143000 (123 MB)
2022-08-11 15:15:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 144000 (124 MB)
2022-08-11 15:15:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 145000 (125 MB)
2022-08-11 15:15:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 146000 (125 MB)
2022-08-11 15:15:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 147000 (126 MB)
2022-08-11 15:15:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 148000 (127 MB)
2022-08-11 15:15:37 destination > 2022-08-11 15:15:37 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 8121 records (24 MB)
2022-08-11 15:15:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 149000 (128 MB)
2022-08-11 15:15:38 source > 2022-08-11 15:15:37 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 150000
2022-08-11 15:15:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 150000 (129 MB)
2022-08-11 15:15:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 151000 (129 MB)
2022-08-11 15:15:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 152000 (130 MB)
2022-08-11 15:15:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 153000 (131 MB)
2022-08-11 15:15:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 154000 (132 MB)
2022-08-11 15:15:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 155000 (132 MB)
2022-08-11 15:15:39 destination > 2022-08-11 15:15:39 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 7385 records (24 MB)
2022-08-11 15:15:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 156000 (133 MB)
2022-08-11 15:15:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 157000 (134 MB)
2022-08-11 15:15:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 158000 (135 MB)
2022-08-11 15:15:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 159000 (136 MB)
2022-08-11 15:15:40 source > 2022-08-11 15:15:40 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 160000
2022-08-11 15:15:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 160000 (136 MB)
2022-08-11 15:15:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 161000 (137 MB)
2022-08-11 15:15:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 162000 (138 MB)
2022-08-11 15:15:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 163000 (139 MB)
2022-08-11 15:15:41 destination > 2022-08-11 15:15:41 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 7869 records (24 MB)
2022-08-11 15:15:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 164000 (140 MB)
2022-08-11 15:15:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 165000 (140 MB)
2022-08-11 15:15:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 166000 (141 MB)
2022-08-11 15:15:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 167000 (142 MB)
2022-08-11 15:15:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 168000 (143 MB)
2022-08-11 15:15:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 169000 (144 MB)
2022-08-11 15:15:42 source > 2022-08-11 15:15:42 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 170000
2022-08-11 15:15:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 170000 (144 MB)
2022-08-11 15:15:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 171000 (145 MB)
2022-08-11 15:15:42 destination > 2022-08-11 15:15:42 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 7704 records (24 MB)
2022-08-11 15:15:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 172000 (146 MB)
2022-08-11 15:15:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 173000 (147 MB)
2022-08-11 15:15:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 174000 (148 MB)
2022-08-11 15:15:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 175000 (149 MB)
2022-08-11 15:15:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 176000 (150 MB)
2022-08-11 15:15:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 177000 (151 MB)
2022-08-11 15:15:44 destination > 2022-08-11 15:15:44 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 6317 records (24 MB)
2022-08-11 15:15:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 178000 (152 MB)
2022-08-11 15:15:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 179000 (153 MB)
2022-08-11 15:15:44 source > 2022-08-11 15:15:44 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 180000
2022-08-11 15:15:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 180000 (154 MB)
2022-08-11 15:15:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 181000 (155 MB)
2022-08-11 15:15:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 182000 (155 MB)
2022-08-11 15:15:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 183000 (156 MB)
2022-08-11 15:15:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 184000 (157 MB)
2022-08-11 15:15:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 185000 (158 MB)
2022-08-11 15:15:45 destination > 2022-08-11 15:15:45 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 7521 records (24 MB)
2022-08-11 15:15:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 186000 (159 MB)
2022-08-11 15:15:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 187000 (159 MB)
2022-08-11 15:15:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 188000 (160 MB)
2022-08-11 15:15:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 189000 (161 MB)
2022-08-11 15:15:47 source > 2022-08-11 15:15:46 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 190000
2022-08-11 15:15:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 190000 (162 MB)
2022-08-11 15:15:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 191000 (163 MB)
2022-08-11 15:15:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 192000 (164 MB)
2022-08-11 15:15:47 destination > 2022-08-11 15:15:47 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 7630 records (24 MB)
2022-08-11 15:15:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 193000 (164 MB)
2022-08-11 15:15:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 194000 (165 MB)
2022-08-11 15:15:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 195000 (166 MB)
2022-08-11 15:15:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 196000 (167 MB)
2022-08-11 15:15:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 197000 (168 MB)
2022-08-11 15:15:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 198000 (168 MB)
2022-08-11 15:15:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 199000 (169 MB)
2022-08-11 15:15:48 source > 2022-08-11 15:15:48 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 200000
2022-08-11 15:15:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 200000 (170 MB)
2022-08-11 15:15:48 destination > 2022-08-11 15:15:48 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 7742 records (24 MB)
2022-08-11 15:15:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 201000 (171 MB)
2022-08-11 15:15:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 202000 (171 MB)
2022-08-11 15:15:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 203000 (172 MB)
2022-08-11 15:15:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 204000 (173 MB)
2022-08-11 15:15:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 205000 (174 MB)
2022-08-11 15:15:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 206000 (175 MB)
2022-08-11 15:15:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 207000 (175 MB)
2022-08-11 15:15:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 208000 (176 MB)
2022-08-11 15:15:49 destination > 2022-08-11 15:15:49 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 8004 records (24 MB)
2022-08-11 15:15:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 209000 (177 MB)
2022-08-11 15:15:50 source > 2022-08-11 15:15:49 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 210000
2022-08-11 15:15:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 210000 (178 MB)
2022-08-11 15:15:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 211000 (179 MB)
2022-08-11 15:15:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 212000 (180 MB)
2022-08-11 15:15:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 213000 (181 MB)
2022-08-11 15:15:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 214000 (181 MB)
2022-08-11 15:15:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 215000 (182 MB)
2022-08-11 15:15:52 destination > 2022-08-11 15:15:52 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 6812 records (24 MB)
2022-08-11 15:15:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 216000 (183 MB)
2022-08-11 15:15:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 217000 (184 MB)
2022-08-11 15:15:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 218000 (185 MB)
2022-08-11 15:15:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 219000 (186 MB)
2022-08-11 15:15:53 source > 2022-08-11 15:15:53 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 220000
2022-08-11 15:15:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 220000 (187 MB)
2022-08-11 15:15:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 221000 (188 MB)
2022-08-11 15:15:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 222000 (189 MB)
2022-08-11 15:15:53 destination > 2022-08-11 15:15:53 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 7128 records (24 MB)
2022-08-11 15:15:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 223000 (189 MB)
2022-08-11 15:15:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 224000 (190 MB)
2022-08-11 15:15:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 225000 (191 MB)
2022-08-11 15:15:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 226000 (192 MB)
2022-08-11 15:15:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 227000 (192 MB)
2022-08-11 15:15:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 228000 (193 MB)
2022-08-11 15:15:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 229000 (194 MB)
2022-08-11 15:15:54 source > 2022-08-11 15:15:54 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 230000
2022-08-11 15:15:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 230000 (195 MB)
2022-08-11 15:15:54 destination > 2022-08-11 15:15:54 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 7901 records (24 MB)
2022-08-11 15:15:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 231000 (196 MB)
2022-08-11 15:15:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 232000 (196 MB)
2022-08-11 15:15:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 233000 (197 MB)
2022-08-11 15:15:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 234000 (198 MB)
2022-08-11 15:15:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 235000 (199 MB)
2022-08-11 15:15:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 236000 (199 MB)
2022-08-11 15:15:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 237000 (200 MB)
2022-08-11 15:15:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 238000 (201 MB)
2022-08-11 15:15:56 destination > 2022-08-11 15:15:56 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 8301 records (24 MB)
2022-08-11 15:15:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 239000 (202 MB)
2022-08-11 15:15:57 source > 2022-08-11 15:15:56 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 240000
2022-08-11 15:15:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 240000 (202 MB)
2022-08-11 15:15:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 241000 (203 MB)
2022-08-11 15:15:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 242000 (204 MB)
2022-08-11 15:15:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 243000 (205 MB)
2022-08-11 15:15:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 244000 (205 MB)
2022-08-11 15:15:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 245000 (206 MB)
2022-08-11 15:15:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 246000 (207 MB)
2022-08-11 15:15:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 247000 (208 MB)
2022-08-11 15:15:57 destination > 2022-08-11 15:15:57 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 8538 records (24 MB)
2022-08-11 15:15:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 248000 (208 MB)
2022-08-11 15:15:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 249000 (209 MB)
2022-08-11 15:15:58 source > 2022-08-11 15:15:58 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 250000
2022-08-11 15:15:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 250000 (210 MB)
2022-08-11 15:15:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 251000 (211 MB)
2022-08-11 15:15:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 252000 (212 MB)
2022-08-11 15:15:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 253000 (213 MB)
2022-08-11 15:15:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 254000 (213 MB)
2022-08-11 15:15:59 destination > 2022-08-11 15:15:59 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 7498 records (24 MB)
2022-08-11 15:15:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 255000 (214 MB)
2022-08-11 15:15:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 256000 (215 MB)
2022-08-11 15:15:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 257000 (216 MB)
2022-08-11 15:16:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 258000 (216 MB)
2022-08-11 15:16:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 259000 (217 MB)
2022-08-11 15:16:00 source > 2022-08-11 15:16:00 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 260000
2022-08-11 15:16:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 260000 (218 MB)
2022-08-11 15:16:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 261000 (219 MB)
2022-08-11 15:16:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 262000 (220 MB)
2022-08-11 15:16:00 destination > 2022-08-11 15:16:00 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 7720 records (24 MB)
2022-08-11 15:16:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 263000 (221 MB)
2022-08-11 15:16:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 264000 (221 MB)
2022-08-11 15:16:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 265000 (222 MB)
2022-08-11 15:16:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 266000 (223 MB)
2022-08-11 15:16:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 267000 (224 MB)
2022-08-11 15:16:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 268000 (225 MB)
2022-08-11 15:16:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 269000 (226 MB)
2022-08-11 15:16:01 destination > 2022-08-11 15:16:01 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 6761 records (24 MB)
2022-08-11 15:16:02 source > 2022-08-11 15:16:01 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 270000
2022-08-11 15:16:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 270000 (227 MB)
2022-08-11 15:16:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 271000 (228 MB)
2022-08-11 15:16:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 272000 (229 MB)
2022-08-11 15:16:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 273000 (230 MB)
2022-08-11 15:16:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 274000 (231 MB)
2022-08-11 15:16:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 275000 (231 MB)
2022-08-11 15:16:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 276000 (232 MB)
2022-08-11 15:16:03 destination > 2022-08-11 15:16:03 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 7683 records (24 MB)
2022-08-11 15:16:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 277000 (233 MB)
2022-08-11 15:16:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 278000 (234 MB)
2022-08-11 15:16:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 279000 (235 MB)
2022-08-11 15:16:05 source > 2022-08-11 15:16:04 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 280000
2022-08-11 15:16:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 280000 (235 MB)
2022-08-11 15:16:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 281000 (236 MB)
2022-08-11 15:16:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 282000 (237 MB)
2022-08-11 15:16:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 283000 (238 MB)
2022-08-11 15:16:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 284000 (239 MB)
2022-08-11 15:16:05 destination > 2022-08-11 15:16:05 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 7545 records (24 MB)
2022-08-11 15:16:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 285000 (240 MB)
2022-08-11 15:16:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 286000 (241 MB)
2022-08-11 15:16:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 287000 (241 MB)
2022-08-11 15:16:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 288000 (242 MB)
2022-08-11 15:16:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 289000 (243 MB)
2022-08-11 15:16:06 source > 2022-08-11 15:16:06 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 290000
2022-08-11 15:16:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 290000 (244 MB)
2022-08-11 15:16:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 291000 (245 MB)
2022-08-11 15:16:06 destination > 2022-08-11 15:16:06 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 7341 records (24 MB)
2022-08-11 15:16:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 292000 (246 MB)
2022-08-11 15:16:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 293000 (246 MB)
2022-08-11 15:16:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 294000 (247 MB)
2022-08-11 15:16:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 295000 (248 MB)
2022-08-11 15:16:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 296000 (249 MB)
2022-08-11 15:16:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 297000 (250 MB)
2022-08-11 15:16:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 298000 (251 MB)
2022-08-11 15:16:08 destination > 2022-08-11 15:16:08 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 7298 records (24 MB)
2022-08-11 15:16:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 299000 (251 MB)
2022-08-11 15:16:08 source > 2022-08-11 15:16:08 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 300000
2022-08-11 15:16:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 300000 (252 MB)
2022-08-11 15:16:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 301000 (253 MB)
2022-08-11 15:16:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 302000 (254 MB)
2022-08-11 15:16:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 303000 (255 MB)
2022-08-11 15:16:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 304000 (256 MB)
2022-08-11 15:16:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 305000 (257 MB)
2022-08-11 15:16:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 306000 (258 MB)
2022-08-11 15:16:10 destination > 2022-08-11 15:16:10 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 7444 records (24 MB)
2022-08-11 15:16:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 307000 (259 MB)
2022-08-11 15:16:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 308000 (259 MB)
2022-08-11 15:16:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 309000 (260 MB)
2022-08-11 15:16:11 source > 2022-08-11 15:16:10 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 310000
2022-08-11 15:16:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 310000 (261 MB)
2022-08-11 15:16:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 311000 (262 MB)
2022-08-11 15:16:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 312000 (263 MB)
2022-08-11 15:16:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 313000 (264 MB)
2022-08-11 15:16:11 destination > 2022-08-11 15:16:11 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 7562 records (24 MB)
2022-08-11 15:16:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 314000 (265 MB)
2022-08-11 15:16:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 315000 (266 MB)
2022-08-11 15:16:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 316000 (267 MB)
2022-08-11 15:16:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 317000 (267 MB)
2022-08-11 15:16:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 318000 (268 MB)
2022-08-11 15:16:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 319000 (269 MB)
2022-08-11 15:16:12 source > 2022-08-11 15:16:12 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 320000
2022-08-11 15:16:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 320000 (270 MB)
2022-08-11 15:16:12 destination > 2022-08-11 15:16:12 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 6680 records (24 MB)
2022-08-11 15:16:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 321000 (270 MB)
2022-08-11 15:16:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 322000 (271 MB)
2022-08-11 15:16:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 323000 (272 MB)
2022-08-11 15:16:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 324000 (273 MB)
2022-08-11 15:16:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 325000 (273 MB)
2022-08-11 15:16:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 326000 (274 MB)
2022-08-11 15:16:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 327000 (275 MB)
2022-08-11 15:16:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 328000 (276 MB)
2022-08-11 15:16:14 destination > 2022-08-11 15:16:14 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 7717 records (24 MB)
2022-08-11 15:16:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 329000 (277 MB)
2022-08-11 15:16:14 source > 2022-08-11 15:16:14 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 330000
2022-08-11 15:16:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 330000 (278 MB)
2022-08-11 15:16:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 331000 (278 MB)
2022-08-11 15:16:15 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 332000 (279 MB)
2022-08-11 15:16:15 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 333000 (280 MB)
2022-08-11 15:16:15 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 334000 (281 MB)
2022-08-11 15:16:15 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 335000 (282 MB)
2022-08-11 15:16:16 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 336000 (283 MB)
2022-08-11 15:16:16 destination > 2022-08-11 15:16:16 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 7945 records (24 MB)
2022-08-11 15:16:16 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 337000 (283 MB)
2022-08-11 15:16:16 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 338000 (284 MB)
2022-08-11 15:16:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 339000 (285 MB)
2022-08-11 15:16:17 source > 2022-08-11 15:16:16 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 340000
2022-08-11 15:16:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 340000 (286 MB)
2022-08-11 15:16:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 341000 (286 MB)
2022-08-11 15:16:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 342000 (287 MB)
2022-08-11 15:16:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 343000 (288 MB)
2022-08-11 15:16:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 344000 (289 MB)
2022-08-11 15:16:17 destination > 2022-08-11 15:16:17 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 8340 records (24 MB)
2022-08-11 15:16:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 345000 (289 MB)
2022-08-11 15:16:18 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 346000 (290 MB)
2022-08-11 15:16:18 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 347000 (291 MB)
2022-08-11 15:16:18 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 348000 (291 MB)
2022-08-11 15:16:18 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 349000 (292 MB)
2022-08-11 15:16:19 source > 2022-08-11 15:16:18 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 350000
2022-08-11 15:16:19 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 350000 (293 MB)
2022-08-11 15:16:19 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 351000 (294 MB)
2022-08-11 15:16:19 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 352000 (294 MB)
2022-08-11 15:16:19 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 353000 (295 MB)
2022-08-11 15:16:19 destination > 2022-08-11 15:16:19 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 8388 records (24 MB)
2022-08-11 15:16:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 354000 (296 MB)
2022-08-11 15:16:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 355000 (296 MB)
2022-08-11 15:16:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 356000 (297 MB)
2022-08-11 15:16:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 357000 (298 MB)
2022-08-11 15:16:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 358000 (299 MB)
2022-08-11 15:16:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 359000 (300 MB)
2022-08-11 15:16:20 source > 2022-08-11 15:16:20 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 360000
2022-08-11 15:16:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 360000 (300 MB)
2022-08-11 15:16:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 361000 (301 MB)
2022-08-11 15:16:20 destination > 2022-08-11 15:16:20 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 8528 records (24 MB)
2022-08-11 15:16:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 362000 (302 MB)
2022-08-11 15:16:21 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 363000 (303 MB)
2022-08-11 15:16:21 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 364000 (303 MB)
2022-08-11 15:16:21 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 365000 (304 MB)
2022-08-11 15:16:21 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 366000 (305 MB)
2022-08-11 15:16:21 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 367000 (306 MB)
2022-08-11 15:16:22 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 368000 (306 MB)
2022-08-11 15:16:22 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 369000 (307 MB)
2022-08-11 15:16:22 destination > 2022-08-11 15:16:22 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 8174 records (24 MB)
2022-08-11 15:16:22 source > 2022-08-11 15:16:22 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 370000
2022-08-11 15:16:22 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 370000 (308 MB)
2022-08-11 15:16:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 371000 (308 MB)
2022-08-11 15:16:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 372000 (309 MB)
2022-08-11 15:16:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 373000 (310 MB)
2022-08-11 15:16:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 374000 (311 MB)
2022-08-11 15:16:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 375000 (311 MB)
2022-08-11 15:16:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 376000 (312 MB)
2022-08-11 15:16:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 377000 (313 MB)
2022-08-11 15:16:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 378000 (314 MB)
2022-08-11 15:16:23 destination > 2022-08-11 15:16:23 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 8853 records (24 MB)
2022-08-11 15:16:24 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 379000 (314 MB)
2022-08-11 15:16:24 source > 2022-08-11 15:16:23 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 380000
2022-08-11 15:16:24 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 380000 (315 MB)
2022-08-11 15:16:24 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 381000 (316 MB)
2022-08-11 15:16:24 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 382000 (316 MB)
2022-08-11 15:16:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 383000 (317 MB)
2022-08-11 15:16:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 384000 (318 MB)
2022-08-11 15:16:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 385000 (319 MB)
2022-08-11 15:16:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 386000 (319 MB)
2022-08-11 15:16:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 387000 (320 MB)
2022-08-11 15:16:25 destination > 2022-08-11 15:16:25 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 8525 records (24 MB)
2022-08-11 15:16:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 388000 (321 MB)
2022-08-11 15:16:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 389000 (322 MB)
2022-08-11 15:16:26 source > 2022-08-11 15:16:25 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 390000
2022-08-11 15:16:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 390000 (322 MB)
2022-08-11 15:16:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 391000 (323 MB)
2022-08-11 15:16:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 392000 (324 MB)
2022-08-11 15:16:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 393000 (324 MB)
2022-08-11 15:16:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 394000 (325 MB)
2022-08-11 15:16:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 395000 (326 MB)
2022-08-11 15:16:27 destination > 2022-08-11 15:16:27 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 8756 records (24 MB)
2022-08-11 15:16:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 396000 (326 MB)
2022-08-11 15:16:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 397000 (327 MB)
2022-08-11 15:16:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 398000 (328 MB)
2022-08-11 15:16:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 399000 (329 MB)
2022-08-11 15:16:28 source > 2022-08-11 15:16:28 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 400000
2022-08-11 15:16:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 400000 (329 MB)
2022-08-11 15:16:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 401000 (330 MB)
2022-08-11 15:16:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 402000 (331 MB)
2022-08-11 15:16:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 403000 (331 MB)
2022-08-11 15:16:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 404000 (332 MB)
2022-08-11 15:16:29 destination > 2022-08-11 15:16:29 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 8859 records (24 MB)
2022-08-11 15:16:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 405000 (333 MB)
2022-08-11 15:16:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 406000 (334 MB)
2022-08-11 15:16:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 407000 (334 MB)
2022-08-11 15:16:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 408000 (335 MB)
2022-08-11 15:16:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 409000 (336 MB)
2022-08-11 15:16:30 source > 2022-08-11 15:16:30 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 410000
2022-08-11 15:16:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 410000 (336 MB)
2022-08-11 15:16:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 411000 (337 MB)
2022-08-11 15:16:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 412000 (338 MB)
2022-08-11 15:16:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 413000 (339 MB)
2022-08-11 15:16:30 destination > 2022-08-11 15:16:30 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 8581 records (24 MB)
2022-08-11 15:16:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 414000 (339 MB)
2022-08-11 15:16:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 415000 (340 MB)
2022-08-11 15:16:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 416000 (341 MB)
2022-08-11 15:16:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 417000 (341 MB)
2022-08-11 15:16:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 418000 (342 MB)
2022-08-11 15:16:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 419000 (343 MB)
2022-08-11 15:16:31 source > 2022-08-11 15:16:31 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):265 - Reading stream c3_log_dtl. Records read: 420000
2022-08-11 15:16:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 420000 (343 MB)
2022-08-11 15:16:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 421000 (344 MB)
2022-08-11 15:16:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 422000 (345 MB)
2022-08-11 15:16:32 destination > 2022-08-11 15:16:32 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 9051 records (24 MB)
2022-08-11 15:16:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 423000 (345 MB)
2022-08-11 15:16:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 424000 (346 MB)
2022-08-11 15:16:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 425000 (347 MB)
2022-08-11 15:16:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 426000 (348 MB)
2022-08-11 15:16:33 source > 2022-08-11 15:16:33 INFO i.a.i.s.r.AbstractDbSource(lambda$read$2):139 - Closing database connection pool.
2022-08-11 15:16:33 source > 2022-08-11 15:16:33 INFO c.z.h.HikariDataSource(close):350 - HikariPool-2 - Shutdown initiated...
2022-08-11 15:16:33 source > 2022-08-11 15:16:33 INFO c.z.h.HikariDataSource(close):352 - HikariPool-2 - Shutdown completed.
2022-08-11 15:16:33 source > 2022-08-11 15:16:33 INFO i.a.i.s.r.AbstractDbSource(lambda$read$2):141 - Closed database connection pool.
2022-08-11 15:16:33 source > 2022-08-11 15:16:33 INFO i.a.i.b.IntegrationRunner(runInternal):152 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-08-11 15:16:33 source > 2022-08-11 15:16:33 INFO i.a.i.b.a.AdaptiveSourceRunner$Runner(run):87 - Completed source: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-08-11 15:16:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):328 - Source has no more messages, closing connection.
2022-08-11 15:16:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):336 - Total records read: 426332 (348 MB)
2022-08-11 15:16:33 WARN i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$5):339 - Schema validation errors found for stream c3idbc3_log_dtl. Error messages: [$.mapping_id is of an incorrect type. Expected it to be string]
2022-08-11 15:16:33 INFO i.a.w.g.DefaultReplicationWorker(run):175 - One of source or destination thread complete. Waiting on the other.
2022-08-11 15:16:33 destination > 2022-08-11 15:16:33 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded.
2022-08-11 15:16:33 destination > 2022-08-11 15:16:33 INFO i.a.i.d.b.BufferedStreamConsumer(close):171 - executing on success close procedure.
2022-08-11 15:16:33 destination > 2022-08-11 15:16:33 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing nocdclast_c3_log_dtl: 3984 records (10 MB)
2022-08-11 15:16:33 destination > 2022-08-11 15:16:33 INFO i.a.i.d.j.SqlOperations(onDestinationCloseOperations):137 - No onDestinationCloseOperations required for this destination.
2022-08-11 15:16:33 destination > 2022-08-11 15:16:33 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):162 - Finalizing tables in destination started for 1 streams
2022-08-11 15:16:33 destination > 2022-08-11 15:16:33 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):167 - Finalizing stream nocdclast_c3_log_dtl. schema c3stat, tmp table _airbyte_tmp_mdu_nocdclast_c3_log_dtl, final table _airbyte_raw_nocdclast_c3_log_dtl
2022-08-11 15:16:33 destination > 2022-08-11 15:16:33 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):180 - Executing finalization of tables.
2022-08-11 15:16:40 destination > 2022-08-11 15:16:40 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):182 - Finalizing tables in destination completed.
2022-08-11 15:16:40 destination > 2022-08-11 15:16:40 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):185 - Cleaning tmp tables in destination started for 1 streams
2022-08-11 15:16:40 destination > 2022-08-11 15:16:40 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):189 - Cleaning tmp table in destination started for stream nocdclast_c3_log_dtl. schema c3stat, tmp table name: _airbyte_tmp_mdu_nocdclast_c3_log_dtl
2022-08-11 15:16:40 destination > 2022-08-11 15:16:40 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):194 - Cleaning tmp tables in destination completed.
2022-08-11 15:16:40 destination > 2022-08-11 15:16:40 INFO i.a.i.b.IntegrationRunner(runInternal):171 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2022-08-11 15:16:40 destination > 2022-08-11 15:16:40 INFO i.a.i.d.p.PostgresDestination(main):92 - completed destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2022-08-11 15:16:40 INFO i.a.w.g.DefaultReplicationWorker(run):177 - Source and destination threads complete.
2022-08-11 15:16:40 INFO i.a.w.g.DefaultReplicationWorker(run):240 - sync summary: io.airbyte.config.ReplicationAttemptSummary@6777723e[status=completed,recordsSynced=426332,bytesSynced=365244784,startTime=1660230803136,endTime=1660231000454,totalStats=io.airbyte.config.SyncStats@252c5bdc[recordsEmitted=426332,bytesEmitted=365244784,stateMessagesEmitted=0,recordsCommitted=426332],streamStats=[io.airbyte.config.StreamSyncStats@3201652d[streamName=nocdclast_c3_log_dtl,stats=io.airbyte.config.SyncStats@b536ad0[recordsEmitted=426332,bytesEmitted=365244784,stateMessagesEmitted=<null>,recordsCommitted=426332]]]]
2022-08-11 15:16:40 INFO i.a.w.g.DefaultReplicationWorker(run):269 - Source did not output any state messages
2022-08-11 15:16:40 WARN i.a.w.g.DefaultReplicationWorker(run):277 - State capture: No new state, falling back on input state: io.airbyte.config.State@57690f06[state={}]
2022-08-11 15:16:40 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-08-11 15:16:40 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):161 - sync summary: io.airbyte.config.StandardSyncOutput@215def3a[standardSyncSummary=io.airbyte.config.StandardSyncSummary@2ede1cb4[status=completed,recordsSynced=426332,bytesSynced=365244784,startTime=1660230803136,endTime=1660231000454,totalStats=io.airbyte.config.SyncStats@252c5bdc[recordsEmitted=426332,bytesEmitted=365244784,stateMessagesEmitted=0,recordsCommitted=426332],streamStats=[io.airbyte.config.StreamSyncStats@3201652d[streamName=nocdclast_c3_log_dtl,stats=io.airbyte.config.SyncStats@b536ad0[recordsEmitted=426332,bytesEmitted=365244784,stateMessagesEmitted=<null>,recordsCommitted=426332]]]],normalizationSummary=<null>,state=io.airbyte.config.State@57690f06[state={}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@48124c99[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@4a57317f[stream=io.airbyte.protocol.models.AirbyteStream@43d2330[name=nocdclast_c3_log_dtl,jsonSchema={"type":"object","properties":{"stage":{"type":"string"},"row_cnt":{"type":"string"},"run_seq":{"type":"string"},"end_time":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"log_type":{"type":"string"},"severity":{"type":"string"},"sql_query":{"type":"string"},"error_code":{"type":"string"},"mapping_id":{"type":"string"},"start_time":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"description":{"type":"string"},"log_dtl_seq":{"type":"number","airbyte_type":"integer"},"mapping_seq":{"type":"string"},"error_detail":{"type":"string"},"mapping_order":{"type":"string"},"source_artefact_seq":{"type":"string"},"target_artefact_seq":{"type":"string"},"source_artefact_type_seq":{"type":"string"},"target_artefact_type_seq":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=<null>,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}]],additionalProperties={}],failures=[]]
2022-08-11 15:16:40 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):291 - Stopping temporal heartbeating...
2022-08-11 15:16:40 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/24/0/logs.log
2022-08-11 15:16:40 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.39.41-alpha
2022-08-11 15:16:40 INFO i.a.w.g.DefaultNormalizationWorker(run):50 - Running normalization.
2022-08-11 15:16:40 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):122 - Running with normalization version: airbyte/normalization:0.2.12
2022-08-11 15:16:40 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/normalization:0.2.12 exists...
2022-08-11 15:16:40 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/normalization:0.2.12 was found locally.
2022-08-11 15:16:40 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 24
2022-08-11 15:16:40 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/24/0/normalize --log-driver none --name normalization-normalize-24-0-bpxha --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e AIRBYTE_VERSION=0.39.41-alpha --cpus=0.7 --memory=8g airbyte/normalization:0.2.12 run --integration-type postgres --config destination_config.json --catalog destination_catalog.json
2022-08-11 15:16:40 normalization > WARNING: Your kernel does not support swap limit capabilities or the cgroup is not mounted. Memory limited without swap.
2022-08-11 15:16:40 normalization > Running: transform-config --config destination_config.json --integration-type postgres --out /data/24/0/normalize
2022-08-11 15:16:41 normalization > Namespace(config='destination_config.json', integration_type=<DestinationType.POSTGRES: 'postgres'>, out='/data/24/0/normalize')
2022-08-11 15:16:41 normalization > transform_postgres
2022-08-11 15:16:41 normalization > Running: transform-catalog --integration-type postgres --profile-config-dir /data/24/0/normalize --catalog destination_catalog.json --out /data/24/0/normalize/models/generated/ --json-column _airbyte_data
2022-08-11 15:16:41 normalization > Processing destination_catalog.json...
2022-08-11 15:16:41 normalization >   Generating airbyte_ctes/c3stat/nocdclast_c3_log_dtl_ab1.sql from nocdclast_c3_log_dtl
2022-08-11 15:16:41 normalization >   Generating airbyte_ctes/c3stat/nocdclast_c3_log_dtl_ab2.sql from nocdclast_c3_log_dtl
2022-08-11 15:16:41 normalization >   Generating airbyte_ctes/c3stat/nocdclast_c3_log_dtl_ab3.sql from nocdclast_c3_log_dtl
2022-08-11 15:16:41 normalization >   Generating airbyte_incremental/c3stat/nocdclast_c3_log_dtl.sql from nocdclast_c3_log_dtl
2022-08-11 15:16:41 normalization > detected no config file for ssh, assuming ssh is off.
2022-08-11 15:16:45 normalization >            [--event-buffer-size EVENT_BUFFER_SIZE]
2022-08-11 15:16:45 normalization >   --event-buffer-size EVENT_BUFFER_SIZE
2022-08-11 15:16:45 normalization > 
2022-08-11 15:16:45 normalization > DBT >=1.0.0 detected; using 10K event buffer size
2022-08-11 15:16:45 normalization > 
2022-08-11 15:16:48 normalization > 15:16:48  Running with dbt=1.0.0
2022-08-11 15:16:48 normalization > 15:16:48  Partial parse save file not found. Starting full parse.
2022-08-11 15:16:50 normalization > 15:16:50  [WARNING]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources.
2022-08-11 15:16:50 normalization > There are 2 unused configuration paths:
2022-08-11 15:16:50 normalization > - models.airbyte_utils.generated.airbyte_tables
2022-08-11 15:16:50 normalization > - models.airbyte_utils.generated.airbyte_views
2022-08-11 15:16:50 normalization > 
2022-08-11 15:16:50 normalization > 15:16:50  Found 4 models, 0 tests, 0 snapshots, 0 analyses, 558 macros, 0 operations, 0 seed files, 1 source, 0 exposures, 0 metrics
2022-08-11 15:16:50 normalization > 15:16:50  
2022-08-11 15:16:52 normalization > 15:16:52  Concurrency: 8 threads (target='prod')
2022-08-11 15:16:52 normalization > 15:16:52  
2022-08-11 15:16:53 normalization > 15:16:53  1 of 1 START incremental model c3stat.nocdclast_c3_log_dtl.............................................................. [RUN]
2022-08-11 15:16:54 normalization > 15:16:54  1 of 1 ERROR creating incremental model c3stat.nocdclast_c3_log_dtl..................................................... [ERROR in 0.67s]
2022-08-11 15:16:54 normalization > 15:16:54  
2022-08-11 15:16:54 normalization > 15:16:54  Finished running 1 incremental model in 4.17s.
2022-08-11 15:16:54 normalization > 15:16:54  
2022-08-11 15:16:54 normalization > 15:16:54  Completed with 1 error and 0 warnings:
2022-08-11 15:16:54 normalization > 15:16:54  
2022-08-11 15:16:54 normalization > 15:16:54  Database Error in model nocdclast_c3_log_dtl (models/generated/airbyte_incremental/c3stat/nocdclast_c3_log_dtl.sql)
2022-08-11 15:16:54 normalization > 15:16:54    date/time field value out of range: "2021-06-01T18:41:54.977728"
2022-08-11 15:16:54 normalization > 15:16:54    CONTEXT:  PL/pgSQL function text_timestamp(text) line 4 at RETURN
2022-08-11 15:16:54 normalization > 15:16:54  
2022-08-11 15:16:54 normalization > 15:16:54  Done. PASS=0 WARN=0 ERROR=1 SKIP=0 TOTAL=1
2022-08-11 15:16:55 normalization > 
2022-08-11 15:16:55 normalization > Diagnosing dbt debug to check if destination is available for dbt and well configured (1):
2022-08-11 15:16:55 normalization > 
2022-08-11 15:16:58 normalization > 15:16:58  Running with dbt=1.0.0
2022-08-11 15:16:58 normalization > dbt version: 1.0.0
2022-08-11 15:16:58 normalization > python version: 3.9.9
2022-08-11 15:16:58 normalization > python path: /usr/local/bin/python
2022-08-11 15:16:58 normalization > os info: Linux-5.4.0-122-generic-x86_64-with-glibc2.31
2022-08-11 15:16:58 normalization > Using profiles.yml file at /data/24/0/normalize/profiles.yml
2022-08-11 15:16:58 normalization > Using dbt_project.yml file at /data/24/0/normalize/dbt_project.yml
2022-08-11 15:16:58 normalization > 
2022-08-11 15:16:58 normalization > Configuration:
2022-08-11 15:16:58 normalization >   profiles.yml file [OK found and valid]
2022-08-11 15:16:58 normalization >   dbt_project.yml file [OK found and valid]
2022-08-11 15:16:58 normalization > 
2022-08-11 15:16:58 normalization > Required dependencies:
2022-08-11 15:16:58 normalization >  - git [OK found]
2022-08-11 15:16:58 normalization > 
2022-08-11 15:16:58 normalization > Connection:
2022-08-11 15:16:58 normalization >   host: c3pg.cetzxrhgj7au.eu-central-1.rds.amazonaws.com
2022-08-11 15:16:58 normalization >   port: 5432
2022-08-11 15:16:58 normalization >   user: C3STAT
2022-08-11 15:16:58 normalization >   database: C3MAIN
2022-08-11 15:16:58 normalization >   schema: c3stat
2022-08-11 15:16:58 normalization >   search_path: None
2022-08-11 15:16:58 normalization >   keepalives_idle: 0
2022-08-11 15:16:58 normalization >   sslmode: None
2022-08-11 15:16:59 normalization >   Connection test: [OK connection ok]
2022-08-11 15:16:59 normalization > 
2022-08-11 15:16:59 normalization > All checks passed!
2022-08-11 15:16:59 normalization > 
2022-08-11 15:16:59 normalization > Forward dbt output logs to diagnose/debug errors (0):
2022-08-11 15:16:59 normalization > 
2022-08-11 15:16:59 normalization > 
2022-08-11 15:16:59 normalization > 
2022-08-11 15:16:59 normalization > ============================== 2022-08-11 15:16:48.668315 | 8a8707f6-e029-4fd5-b7c8-6e649df55556 ==============================
2022-08-11 15:16:59 normalization > 15:16:48.668315 [info ] [MainThread]: Running with dbt=1.0.0
2022-08-11 15:16:59 normalization > 15:16:48.668673 [debug] [MainThread]: running dbt with arguments Namespace(record_timing_info=None, debug=None, log_format=None, write_json=None, use_colors=None, printer_width=None, warn_error=None, version_check=None, partial_parse=None, single_threaded=False, use_experimental_parser=None, static_parser=None, profiles_dir='/data/24/0/normalize', send_anonymous_usage_stats=None, fail_fast=None, event_buffer_size='10000', project_dir='/data/24/0/normalize', profile=None, target=None, vars='{}', log_cache_events=False, threads=None, select=None, exclude=None, selector_name=None, state=None, defer=None, full_refresh=False, cls=<class 'dbt.task.run.RunTask'>, which='run', rpc_method='run')
2022-08-11 15:16:59 normalization > 15:16:48.668821 [debug] [MainThread]: Tracking: do not track
2022-08-11 15:16:59 normalization > 15:16:48.739101 [info ] [MainThread]: Partial parse save file not found. Starting full parse.
2022-08-11 15:16:59 normalization > 15:16:48.758438 [debug] [MainThread]: Parsing macros/get_custom_schema.sql
2022-08-11 15:16:59 normalization > 15:16:48.759345 [debug] [MainThread]: Parsing macros/incremental.sql
2022-08-11 15:16:59 normalization > 15:16:48.767261 [debug] [MainThread]: Parsing macros/configuration.sql
2022-08-11 15:16:59 normalization > 15:16:48.829902 [debug] [MainThread]: Parsing macros/clean_tmp_tables.sql
2022-08-11 15:16:59 normalization > 15:16:48.834488 [debug] [MainThread]: Parsing macros/star_intersect.sql
2022-08-11 15:16:59 normalization > 15:16:48.842117 [debug] [MainThread]: Parsing macros/should_full_refresh.sql
2022-08-11 15:16:59 normalization > 15:16:48.846925 [debug] [MainThread]: Parsing macros/schema_tests/equal_rowcount.sql
2022-08-11 15:16:59 normalization > 15:16:48.848069 [debug] [MainThread]: Parsing macros/schema_tests/equality.sql
2022-08-11 15:16:59 normalization > 15:16:48.854872 [debug] [MainThread]: Parsing macros/cross_db_utils/type_conversions.sql
2022-08-11 15:16:59 normalization > 15:16:48.863352 [debug] [MainThread]: Parsing macros/cross_db_utils/concat.sql
2022-08-11 15:16:59 normalization > 15:16:48.865814 [debug] [MainThread]: Parsing macros/cross_db_utils/quote.sql
2022-08-11 15:16:59 normalization > 15:16:48.867710 [debug] [MainThread]: Parsing macros/cross_db_utils/current_timestamp.sql
2022-08-11 15:16:59 normalization > 15:16:48.868607 [debug] [MainThread]: Parsing macros/cross_db_utils/except.sql
2022-08-11 15:16:59 normalization > 15:16:48.869384 [debug] [MainThread]: Parsing macros/cross_db_utils/columns.sql
2022-08-11 15:16:59 normalization > 15:16:48.872187 [debug] [MainThread]: Parsing macros/cross_db_utils/surrogate_key.sql
2022-08-11 15:16:59 normalization > 15:16:48.874151 [debug] [MainThread]: Parsing macros/cross_db_utils/datatypes.sql
2022-08-11 15:16:59 normalization > 15:16:48.891927 [debug] [MainThread]: Parsing macros/cross_db_utils/json_operations.sql
2022-08-11 15:16:59 normalization > 15:16:48.962790 [debug] [MainThread]: Parsing macros/cross_db_utils/array.sql
2022-08-11 15:16:59 normalization > 15:16:48.977648 [debug] [MainThread]: Parsing macros/cross_db_utils/hash.sql
2022-08-11 15:16:59 normalization > 15:16:48.978226 [debug] [MainThread]: Parsing macros/catalog.sql
2022-08-11 15:16:59 normalization > 15:16:48.980427 [debug] [MainThread]: Parsing macros/adapters.sql
2022-08-11 15:16:59 normalization > 15:16:49.038011 [debug] [MainThread]: Parsing macros/relations.sql
2022-08-11 15:16:59 normalization > 15:16:49.039285 [debug] [MainThread]: Parsing macros/materializations/snapshot_merge.sql
2022-08-11 15:16:59 normalization > 15:16:49.040956 [debug] [MainThread]: Parsing macros/adapters/metadata.sql
2022-08-11 15:16:59 normalization > 15:16:49.048203 [debug] [MainThread]: Parsing macros/adapters/freshness.sql
2022-08-11 15:16:59 normalization > 15:16:49.051291 [debug] [MainThread]: Parsing macros/adapters/columns.sql
2022-08-11 15:16:59 normalization > 15:16:49.062563 [debug] [MainThread]: Parsing macros/adapters/schema.sql
2022-08-11 15:16:59 normalization > 15:16:49.064936 [debug] [MainThread]: Parsing macros/adapters/persist_docs.sql
2022-08-11 15:16:59 normalization > 15:16:49.069787 [debug] [MainThread]: Parsing macros/adapters/indexes.sql
2022-08-11 15:16:59 normalization > 15:16:49.072828 [debug] [MainThread]: Parsing macros/adapters/relation.sql
2022-08-11 15:16:59 normalization > 15:16:49.082597 [debug] [MainThread]: Parsing macros/materializations/configs.sql
2022-08-11 15:16:59 normalization > 15:16:49.085013 [debug] [MainThread]: Parsing macros/materializations/hooks.sql
2022-08-11 15:16:59 normalization > 15:16:49.089272 [debug] [MainThread]: Parsing macros/materializations/seeds/helpers.sql
2022-08-11 15:16:59 normalization > 15:16:49.139475 [debug] [MainThread]: Parsing macros/materializations/seeds/seed.sql
2022-08-11 15:16:59 normalization > 15:16:49.145906 [debug] [MainThread]: Parsing macros/materializations/snapshots/strategies.sql
2022-08-11 15:16:59 normalization > 15:16:49.164432 [debug] [MainThread]: Parsing macros/materializations/snapshots/helpers.sql
2022-08-11 15:16:59 normalization > 15:16:49.175586 [debug] [MainThread]: Parsing macros/materializations/snapshots/snapshot.sql
2022-08-11 15:16:59 normalization > 15:16:49.248733 [debug] [MainThread]: Parsing macros/materializations/snapshots/snapshot_merge.sql
2022-08-11 15:16:59 normalization > 15:16:49.250572 [debug] [MainThread]: Parsing macros/materializations/tests/helpers.sql
2022-08-11 15:16:59 normalization > 15:16:49.252493 [debug] [MainThread]: Parsing macros/materializations/tests/where_subquery.sql
2022-08-11 15:16:59 normalization > 15:16:49.254385 [debug] [MainThread]: Parsing macros/materializations/tests/test.sql
2022-08-11 15:16:59 normalization > 15:16:49.259290 [debug] [MainThread]: Parsing macros/materializations/models/table/create_table_as.sql
2022-08-11 15:16:59 normalization > 15:16:49.262346 [debug] [MainThread]: Parsing macros/materializations/models/table/table.sql
2022-08-11 15:16:59 normalization > 15:16:49.269935 [debug] [MainThread]: Parsing macros/materializations/models/view/view.sql
2022-08-11 15:16:59 normalization > 15:16:49.277084 [debug] [MainThread]: Parsing macros/materializations/models/view/create_or_replace_view.sql
2022-08-11 15:16:59 normalization > 15:16:49.279947 [debug] [MainThread]: Parsing macros/materializations/models/view/helpers.sql
2022-08-11 15:16:59 normalization > 15:16:49.281272 [debug] [MainThread]: Parsing macros/materializations/models/view/create_view_as.sql
2022-08-11 15:16:59 normalization > 15:16:49.283749 [debug] [MainThread]: Parsing macros/materializations/models/incremental/column_helpers.sql
2022-08-11 15:16:59 normalization > 15:16:49.291965 [debug] [MainThread]: Parsing macros/materializations/models/incremental/incremental.sql
2022-08-11 15:16:59 normalization > 15:16:49.327357 [debug] [MainThread]: Parsing macros/materializations/models/incremental/merge.sql
2022-08-11 15:16:59 normalization > 15:16:49.343456 [debug] [MainThread]: Parsing macros/materializations/models/incremental/on_schema_change.sql
2022-08-11 15:16:59 normalization > 15:16:49.358736 [debug] [MainThread]: Parsing macros/materializations/models/incremental/is_incremental.sql
2022-08-11 15:16:59 normalization > 15:16:49.360666 [debug] [MainThread]: Parsing macros/generic_test_sql/relationships.sql
2022-08-11 15:16:59 normalization > 15:16:49.361566 [debug] [MainThread]: Parsing macros/generic_test_sql/accepted_values.sql
2022-08-11 15:16:59 normalization > 15:16:49.362976 [debug] [MainThread]: Parsing macros/generic_test_sql/not_null.sql
2022-08-11 15:16:59 normalization > 15:16:49.363546 [debug] [MainThread]: Parsing macros/generic_test_sql/unique.sql
2022-08-11 15:16:59 normalization > 15:16:49.364211 [debug] [MainThread]: Parsing macros/get_custom_name/get_custom_database.sql
2022-08-11 15:16:59 normalization > 15:16:49.365829 [debug] [MainThread]: Parsing macros/get_custom_name/get_custom_schema.sql
2022-08-11 15:16:59 normalization > 15:16:49.368401 [debug] [MainThread]: Parsing macros/get_custom_name/get_custom_alias.sql
2022-08-11 15:16:59 normalization > 15:16:49.369931 [debug] [MainThread]: Parsing macros/etc/statement.sql
2022-08-11 15:16:59 normalization > 15:16:49.374714 [debug] [MainThread]: Parsing macros/etc/datetime.sql
2022-08-11 15:16:59 normalization > 15:16:49.383642 [debug] [MainThread]: Parsing tests/generic/builtin.sql
2022-08-11 15:16:59 normalization > 15:16:49.386876 [debug] [MainThread]: Parsing macros/web/get_url_host.sql
2022-08-11 15:16:59 normalization > 15:16:49.388979 [debug] [MainThread]: Parsing macros/web/get_url_parameter.sql
2022-08-11 15:16:59 normalization > 15:16:49.390659 [debug] [MainThread]: Parsing macros/web/get_url_path.sql
2022-08-11 15:16:59 normalization > 15:16:49.393445 [debug] [MainThread]: Parsing macros/materializations/insert_by_period_materialization.sql
2022-08-11 15:16:59 normalization > 15:16:49.452329 [debug] [MainThread]: Parsing macros/jinja_helpers/pretty_time.sql
2022-08-11 15:16:59 normalization > 15:16:49.453647 [debug] [MainThread]: Parsing macros/jinja_helpers/slugify.sql
2022-08-11 15:16:59 normalization > 15:16:49.454922 [debug] [MainThread]: Parsing macros/jinja_helpers/pretty_log_format.sql
2022-08-11 15:16:59 normalization > 15:16:49.456066 [debug] [MainThread]: Parsing macros/jinja_helpers/log_info.sql
2022-08-11 15:16:59 normalization > 15:16:49.457226 [debug] [MainThread]: Parsing macros/schema_tests/not_accepted_values.sql
2022-08-11 15:16:59 normalization > 15:16:49.459439 [debug] [MainThread]: Parsing macros/schema_tests/at_least_one.sql
2022-08-11 15:16:59 normalization > 15:16:49.460741 [debug] [MainThread]: Parsing macros/schema_tests/mutually_exclusive_ranges.sql
2022-08-11 15:16:59 normalization > 15:16:49.469280 [debug] [MainThread]: Parsing macros/schema_tests/equal_rowcount.sql
2022-08-11 15:16:59 normalization > 15:16:49.470994 [debug] [MainThread]: Parsing macros/schema_tests/cardinality_equality.sql
2022-08-11 15:16:59 normalization > 15:16:49.473055 [debug] [MainThread]: Parsing macros/schema_tests/not_constant.sql
2022-08-11 15:16:59 normalization > 15:16:49.474355 [debug] [MainThread]: Parsing macros/schema_tests/recency.sql
2022-08-11 15:16:59 normalization > 15:16:49.476243 [debug] [MainThread]: Parsing macros/schema_tests/sequential_values.sql
2022-08-11 15:16:59 normalization > 15:16:49.479252 [debug] [MainThread]: Parsing macros/schema_tests/relationships_where.sql
2022-08-11 15:16:59 normalization > 15:16:49.481552 [debug] [MainThread]: Parsing macros/schema_tests/accepted_range.sql
2022-08-11 15:16:59 normalization > 15:16:49.484172 [debug] [MainThread]: Parsing macros/schema_tests/test_unique_where.sql
2022-08-11 15:16:59 normalization > 15:16:49.485719 [debug] [MainThread]: Parsing macros/schema_tests/equality.sql
2022-08-11 15:16:59 normalization > 15:16:49.489843 [debug] [MainThread]: Parsing macros/schema_tests/expression_is_true.sql
2022-08-11 15:16:59 normalization > 15:16:49.491784 [debug] [MainThread]: Parsing macros/schema_tests/test_not_null_where.sql
2022-08-11 15:16:59 normalization > 15:16:49.493313 [debug] [MainThread]: Parsing macros/schema_tests/unique_combination_of_columns.sql
2022-08-11 15:16:59 normalization > 15:16:49.527528 [debug] [MainThread]: Parsing macros/schema_tests/fewer_rows_than.sql
2022-08-11 15:16:59 normalization > 15:16:49.531209 [debug] [MainThread]: Parsing macros/schema_tests/not_null_proportion.sql
2022-08-11 15:16:59 normalization > 15:16:49.536451 [debug] [MainThread]: Parsing macros/sql/get_relations_by_pattern.sql
2022-08-11 15:16:59 normalization > 15:16:49.540667 [debug] [MainThread]: Parsing macros/sql/haversine_distance.sql
2022-08-11 15:16:59 normalization > 15:16:49.548146 [debug] [MainThread]: Parsing macros/sql/get_tables_by_pattern_sql.sql
2022-08-11 15:16:59 normalization > 15:16:49.554566 [debug] [MainThread]: Parsing macros/sql/unpivot.sql
2022-08-11 15:16:59 normalization > 15:16:49.563003 [debug] [MainThread]: Parsing macros/sql/get_relations_by_prefix.sql
2022-08-11 15:16:59 normalization > 15:16:49.566642 [debug] [MainThread]: Parsing macros/sql/get_tables_by_prefix_sql.sql
2022-08-11 15:16:59 normalization > 15:16:49.568463 [debug] [MainThread]: Parsing macros/sql/generate_series.sql
2022-08-11 15:16:59 normalization > 15:16:49.572996 [debug] [MainThread]: Parsing macros/sql/union.sql
2022-08-11 15:16:59 normalization > 15:16:49.584156 [debug] [MainThread]: Parsing macros/sql/star.sql
2022-08-11 15:16:59 normalization > 15:16:49.588939 [debug] [MainThread]: Parsing macros/sql/get_column_values.sql
2022-08-11 15:16:59 normalization > 15:16:49.594591 [debug] [MainThread]: Parsing macros/sql/surrogate_key.sql
2022-08-11 15:16:59 normalization > 15:16:49.631200 [debug] [MainThread]: Parsing macros/sql/nullcheck.sql
2022-08-11 15:16:59 normalization > 15:16:49.634048 [debug] [MainThread]: Parsing macros/sql/pivot.sql
2022-08-11 15:16:59 normalization > 15:16:49.638557 [debug] [MainThread]: Parsing macros/sql/nullcheck_table.sql
2022-08-11 15:16:59 normalization > 15:16:49.640290 [debug] [MainThread]: Parsing macros/sql/date_spine.sql
2022-08-11 15:16:59 normalization > 15:16:49.644741 [debug] [MainThread]: Parsing macros/sql/safe_add.sql
2022-08-11 15:16:59 normalization > 15:16:49.646450 [debug] [MainThread]: Parsing macros/sql/get_table_types_sql.sql
2022-08-11 15:16:59 normalization > 15:16:49.647764 [debug] [MainThread]: Parsing macros/sql/groupby.sql
2022-08-11 15:16:59 normalization > 15:16:49.649143 [debug] [MainThread]: Parsing macros/sql/get_query_results_as_dict.sql
2022-08-11 15:16:59 normalization > 15:16:49.651566 [debug] [MainThread]: Parsing macros/cross_db_utils/literal.sql
2022-08-11 15:16:59 normalization > 15:16:49.652548 [debug] [MainThread]: Parsing macros/cross_db_utils/replace.sql
2022-08-11 15:16:59 normalization > 15:16:49.653818 [debug] [MainThread]: Parsing macros/cross_db_utils/intersect.sql
2022-08-11 15:16:59 normalization > 15:16:49.654896 [debug] [MainThread]: Parsing macros/cross_db_utils/concat.sql
2022-08-11 15:16:59 normalization > 15:16:49.655903 [debug] [MainThread]: Parsing macros/cross_db_utils/width_bucket.sql
2022-08-11 15:16:59 normalization > 15:16:49.661285 [debug] [MainThread]: Parsing macros/cross_db_utils/current_timestamp.sql
2022-08-11 15:16:59 normalization > 15:16:49.664744 [debug] [MainThread]: Parsing macros/cross_db_utils/except.sql
2022-08-11 15:16:59 normalization > 15:16:49.665773 [debug] [MainThread]: Parsing macros/cross_db_utils/_is_relation.sql
2022-08-11 15:16:59 normalization > 15:16:49.666914 [debug] [MainThread]: Parsing macros/cross_db_utils/split_part.sql
2022-08-11 15:16:59 normalization > 15:16:49.668769 [debug] [MainThread]: Parsing macros/cross_db_utils/dateadd.sql
2022-08-11 15:16:59 normalization > 15:16:49.671765 [debug] [MainThread]: Parsing macros/cross_db_utils/last_day.sql
2022-08-11 15:16:59 normalization > 15:16:49.675360 [debug] [MainThread]: Parsing macros/cross_db_utils/length.sql
2022-08-11 15:16:59 normalization > 15:16:49.676663 [debug] [MainThread]: Parsing macros/cross_db_utils/any_value.sql
2022-08-11 15:16:59 normalization > 15:16:49.677944 [debug] [MainThread]: Parsing macros/cross_db_utils/escape_single_quotes.sql
2022-08-11 15:16:59 normalization > 15:16:49.679828 [debug] [MainThread]: Parsing macros/cross_db_utils/bool_or.sql
2022-08-11 15:16:59 normalization > 15:16:49.681418 [debug] [MainThread]: Parsing macros/cross_db_utils/_is_ephemeral.sql
2022-08-11 15:16:59 normalization > 15:16:49.683567 [debug] [MainThread]: Parsing macros/cross_db_utils/date_trunc.sql
2022-08-11 15:16:59 normalization > 15:16:49.685095 [debug] [MainThread]: Parsing macros/cross_db_utils/datatypes.sql
2022-08-11 15:16:59 normalization > 15:16:49.691248 [debug] [MainThread]: Parsing macros/cross_db_utils/safe_cast.sql
2022-08-11 15:16:59 normalization > 15:16:49.693123 [debug] [MainThread]: Parsing macros/cross_db_utils/position.sql
2022-08-11 15:16:59 normalization > 15:16:49.694659 [debug] [MainThread]: Parsing macros/cross_db_utils/cast_bool_to_text.sql
2022-08-11 15:16:59 normalization > 15:16:49.726462 [debug] [MainThread]: Parsing macros/cross_db_utils/hash.sql
2022-08-11 15:16:59 normalization > 15:16:49.729105 [debug] [MainThread]: Parsing macros/cross_db_utils/identifier.sql
2022-08-11 15:16:59 normalization > 15:16:49.732852 [debug] [MainThread]: Parsing macros/cross_db_utils/datediff.sql
2022-08-11 15:16:59 normalization > 15:16:49.745346 [debug] [MainThread]: Parsing macros/cross_db_utils/right.sql
2022-08-11 15:16:59 normalization > 15:16:50.442233 [debug] [MainThread]: 1603: static parser failed on generated/airbyte_incremental/c3stat/nocdclast_c3_log_dtl.sql
2022-08-11 15:16:59 normalization > 15:16:50.467773 [debug] [MainThread]: 1602: parser fallback to jinja rendering on generated/airbyte_incremental/c3stat/nocdclast_c3_log_dtl.sql
2022-08-11 15:16:59 normalization > 15:16:50.469331 [debug] [MainThread]: 1603: static parser failed on generated/airbyte_ctes/c3stat/nocdclast_c3_log_dtl_ab2.sql
2022-08-11 15:16:59 normalization > 15:16:50.491825 [debug] [MainThread]: 1602: parser fallback to jinja rendering on generated/airbyte_ctes/c3stat/nocdclast_c3_log_dtl_ab2.sql
2022-08-11 15:16:59 normalization > 15:16:50.493461 [debug] [MainThread]: 1603: static parser failed on generated/airbyte_ctes/c3stat/nocdclast_c3_log_dtl_ab1.sql
2022-08-11 15:16:59 normalization > 15:16:50.558520 [debug] [MainThread]: 1602: parser fallback to jinja rendering on generated/airbyte_ctes/c3stat/nocdclast_c3_log_dtl_ab1.sql
2022-08-11 15:16:59 normalization > 15:16:50.559839 [debug] [MainThread]: 1603: static parser failed on generated/airbyte_ctes/c3stat/nocdclast_c3_log_dtl_ab3.sql
2022-08-11 15:16:59 normalization > 15:16:50.584596 [debug] [MainThread]: 1602: parser fallback to jinja rendering on generated/airbyte_ctes/c3stat/nocdclast_c3_log_dtl_ab3.sql
2022-08-11 15:16:59 normalization > 15:16:50.676088 [warn ] [MainThread]: [WARNING]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources.
2022-08-11 15:16:59 normalization > There are 2 unused configuration paths:
2022-08-11 15:16:59 normalization > - models.airbyte_utils.generated.airbyte_tables
2022-08-11 15:16:59 normalization > - models.airbyte_utils.generated.airbyte_views
2022-08-11 15:16:59 normalization > 
2022-08-11 15:16:59 normalization > 15:16:50.691973 [info ] [MainThread]: Found 4 models, 0 tests, 0 snapshots, 0 analyses, 558 macros, 0 operations, 0 seed files, 1 source, 0 exposures, 0 metrics
2022-08-11 15:16:59 normalization > 15:16:50.693104 [info ] [MainThread]: 
2022-08-11 15:16:59 normalization > 15:16:50.693662 [debug] [MainThread]: Acquiring new postgres connection "master"
2022-08-11 15:16:59 normalization > 15:16:50.726987 [debug] [ThreadPool]: Acquiring new postgres connection "list_C3MAIN"
2022-08-11 15:16:59 normalization > 15:16:50.742591 [debug] [ThreadPool]: Using postgres connection "list_C3MAIN"
2022-08-11 15:16:59 normalization > 15:16:50.742739 [debug] [ThreadPool]: On list_C3MAIN: /* {"app": "dbt", "dbt_version": "1.0.0", "profile_name": "normalize", "target_name": "prod", "connection_name": "list_C3MAIN"} */
2022-08-11 15:16:59 normalization > 
2022-08-11 15:16:59 normalization >     select distinct nspname from pg_namespace
2022-08-11 15:16:59 normalization >   
2022-08-11 15:16:59 normalization > 15:16:50.742847 [debug] [ThreadPool]: Opening a new connection, currently in state init
2022-08-11 15:16:59 normalization > 15:16:51.190684 [debug] [ThreadPool]: SQL status: SELECT 848 in 0.45 seconds
2022-08-11 15:16:59 normalization > 15:16:51.197983 [debug] [ThreadPool]: On list_C3MAIN: Close
2022-08-11 15:16:59 normalization > 15:16:51.200375 [debug] [ThreadPool]: Acquiring new postgres connection "list_C3MAIN_c3stat"
2022-08-11 15:16:59 normalization > 15:16:51.210749 [debug] [ThreadPool]: Using postgres connection "list_C3MAIN_c3stat"
2022-08-11 15:16:59 normalization > 15:16:51.210907 [debug] [ThreadPool]: On list_C3MAIN_c3stat: BEGIN
2022-08-11 15:16:59 normalization > 15:16:51.211009 [debug] [ThreadPool]: Opening a new connection, currently in state closed
2022-08-11 15:16:59 normalization > 15:16:51.561326 [debug] [ThreadPool]: SQL status: BEGIN in 0.35 seconds
2022-08-11 15:16:59 normalization > 15:16:51.561672 [debug] [ThreadPool]: Using postgres connection "list_C3MAIN_c3stat"
2022-08-11 15:16:59 normalization > 15:16:51.561886 [debug] [ThreadPool]: On list_C3MAIN_c3stat: /* {"app": "dbt", "dbt_version": "1.0.0", "profile_name": "normalize", "target_name": "prod", "connection_name": "list_C3MAIN_c3stat"} */
2022-08-11 15:16:59 normalization > select
2022-08-11 15:16:59 normalization >       'C3MAIN' as database,
2022-08-11 15:16:59 normalization >       tablename as name,
2022-08-11 15:16:59 normalization >       schemaname as schema,
2022-08-11 15:16:59 normalization >       'table' as type
2022-08-11 15:16:59 normalization >     from pg_tables
2022-08-11 15:16:59 normalization >     where schemaname ilike 'c3stat'
2022-08-11 15:16:59 normalization >     union all
2022-08-11 15:16:59 normalization >     select
2022-08-11 15:16:59 normalization >       'C3MAIN' as database,
2022-08-11 15:16:59 normalization >       viewname as name,
2022-08-11 15:16:59 normalization >       schemaname as schema,
2022-08-11 15:16:59 normalization >       'view' as type
2022-08-11 15:16:59 normalization >     from pg_views
2022-08-11 15:16:59 normalization >     where schemaname ilike 'c3stat'
2022-08-11 15:16:59 normalization >   
2022-08-11 15:16:59 normalization > 15:16:51.629037 [debug] [ThreadPool]: SQL status: SELECT 95 in 0.07 seconds
2022-08-11 15:16:59 normalization > 15:16:51.666550 [debug] [ThreadPool]: On list_C3MAIN_c3stat: ROLLBACK
2022-08-11 15:16:59 normalization > 15:16:51.708128 [debug] [ThreadPool]: On list_C3MAIN_c3stat: Close
2022-08-11 15:16:59 normalization > 15:16:51.730155 [debug] [MainThread]: Using postgres connection "master"
2022-08-11 15:16:59 normalization > 15:16:51.730288 [debug] [MainThread]: On master: BEGIN
2022-08-11 15:16:59 normalization > 15:16:51.730385 [debug] [MainThread]: Opening a new connection, currently in state init
2022-08-11 15:16:59 normalization > 15:16:52.079357 [debug] [MainThread]: SQL status: BEGIN in 0.35 seconds
2022-08-11 15:16:59 normalization > 15:16:52.079832 [debug] [MainThread]: Using postgres connection "master"
2022-08-11 15:16:59 normalization > 15:16:52.080069 [debug] [MainThread]: On master: /* {"app": "dbt", "dbt_version": "1.0.0", "profile_name": "normalize", "target_name": "prod", "connection_name": "master"} */
2022-08-11 15:16:59 normalization > with relation as (
2022-08-11 15:16:59 normalization >         select
2022-08-11 15:16:59 normalization >             pg_rewrite.ev_class as class,
2022-08-11 15:16:59 normalization >             pg_rewrite.oid as id
2022-08-11 15:16:59 normalization >         from pg_rewrite
2022-08-11 15:16:59 normalization >     ),
2022-08-11 15:16:59 normalization >     class as (
2022-08-11 15:16:59 normalization >         select
2022-08-11 15:16:59 normalization >             oid as id,
2022-08-11 15:16:59 normalization >             relname as name,
2022-08-11 15:16:59 normalization >             relnamespace as schema,
2022-08-11 15:16:59 normalization >             relkind as kind
2022-08-11 15:16:59 normalization >         from pg_class
2022-08-11 15:16:59 normalization >     ),
2022-08-11 15:16:59 normalization >     dependency as (
2022-08-11 15:16:59 normalization >         select
2022-08-11 15:16:59 normalization >             pg_depend.objid as id,
2022-08-11 15:16:59 normalization >             pg_depend.refobjid as ref
2022-08-11 15:16:59 normalization >         from pg_depend
2022-08-11 15:16:59 normalization >     ),
2022-08-11 15:16:59 normalization >     schema as (
2022-08-11 15:16:59 normalization >         select
2022-08-11 15:16:59 normalization >             pg_namespace.oid as id,
2022-08-11 15:16:59 normalization >             pg_namespace.nspname as name
2022-08-11 15:16:59 normalization >         from pg_namespace
2022-08-11 15:16:59 normalization >         where nspname != 'information_schema' and nspname not like 'pg\_%'
2022-08-11 15:16:59 normalization >     ),
2022-08-11 15:16:59 normalization >     referenced as (
2022-08-11 15:16:59 normalization >         select
2022-08-11 15:16:59 normalization >             relation.id AS id,
2022-08-11 15:16:59 normalization >             referenced_class.name ,
2022-08-11 15:16:59 normalization >             referenced_class.schema ,
2022-08-11 15:16:59 normalization >             referenced_class.kind
2022-08-11 15:16:59 normalization >         from relation
2022-08-11 15:16:59 normalization >         join class as referenced_class on relation.class=referenced_class.id
2022-08-11 15:16:59 normalization >         where referenced_class.kind in ('r', 'v')
2022-08-11 15:16:59 normalization >     ),
2022-08-11 15:16:59 normalization >     relationships as (
2022-08-11 15:16:59 normalization >         select
2022-08-11 15:16:59 normalization >             referenced.name as referenced_name,
2022-08-11 15:16:59 normalization >             referenced.schema as referenced_schema_id,
2022-08-11 15:16:59 normalization >             dependent_class.name as dependent_name,
2022-08-11 15:16:59 normalization >             dependent_class.schema as dependent_schema_id,
2022-08-11 15:16:59 normalization >             referenced.kind as kind
2022-08-11 15:16:59 normalization >         from referenced
2022-08-11 15:16:59 normalization >         join dependency on referenced.id=dependency.id
2022-08-11 15:16:59 normalization >         join class as dependent_class on dependency.ref=dependent_class.id
2022-08-11 15:16:59 normalization >         where
2022-08-11 15:16:59 normalization >             (referenced.name != dependent_class.name or
2022-08-11 15:16:59 normalization >              referenced.schema != dependent_class.schema)
2022-08-11 15:16:59 normalization >     )
2022-08-11 15:16:59 normalization > 
2022-08-11 15:16:59 normalization >     select
2022-08-11 15:16:59 normalization >         referenced_schema.name as referenced_schema,
2022-08-11 15:16:59 normalization >         relationships.referenced_name as referenced_name,
2022-08-11 15:16:59 normalization >         dependent_schema.name as dependent_schema,
2022-08-11 15:16:59 normalization >         relationships.dependent_name as dependent_name
2022-08-11 15:16:59 normalization >     from relationships
2022-08-11 15:16:59 normalization >     join schema as dependent_schema on relationships.dependent_schema_id=dependent_schema.id
2022-08-11 15:16:59 normalization >     join schema as referenced_schema on relationships.referenced_schema_id=referenced_schema.id
2022-08-11 15:16:59 normalization >     group by referenced_schema, referenced_name, dependent_schema, dependent_name
2022-08-11 15:16:59 normalization >     order by referenced_schema, referenced_name, dependent_schema, dependent_name;
2022-08-11 15:16:59 normalization > 15:16:52.208004 [debug] [MainThread]: SQL status: SELECT 120 in 0.13 seconds
2022-08-11 15:16:59 normalization > 15:16:52.217300 [debug] [MainThread]: On master: ROLLBACK
2022-08-11 15:16:59 normalization > 15:16:52.258908 [debug] [MainThread]: Using postgres connection "master"
2022-08-11 15:16:59 normalization > 15:16:52.259173 [debug] [MainThread]: On master: BEGIN
2022-08-11 15:16:59 normalization > 15:16:52.342150 [debug] [MainThread]: SQL status: BEGIN in 0.08 seconds
2022-08-11 15:16:59 normalization > 15:16:52.342471 [debug] [MainThread]: On master: COMMIT
2022-08-11 15:16:59 normalization > 15:16:52.342696 [debug] [MainThread]: Using postgres connection "master"
2022-08-11 15:16:59 normalization > 15:16:52.342919 [debug] [MainThread]: On master: COMMIT
2022-08-11 15:16:59 normalization > 15:16:52.384395 [debug] [MainThread]: SQL status: COMMIT in 0.04 seconds
2022-08-11 15:16:59 normalization > 15:16:52.384703 [debug] [MainThread]: On master: Close
2022-08-11 15:16:59 normalization > 15:16:52.385904 [info ] [MainThread]: Concurrency: 8 threads (target='prod')
2022-08-11 15:16:59 normalization > 15:16:52.386361 [info ] [MainThread]: 
2022-08-11 15:16:59 normalization > 15:16:52.403270 [debug] [Thread-1  ]: Began running node model.airbyte_utils.nocdclast_c3_log_dtl_ab1
2022-08-11 15:16:59 normalization > 15:16:52.403880 [debug] [Thread-1  ]: Acquiring new postgres connection "model.airbyte_utils.nocdclast_c3_log_dtl_ab1"
2022-08-11 15:16:59 normalization > 15:16:52.404004 [debug] [Thread-1  ]: Began compiling node model.airbyte_utils.nocdclast_c3_log_dtl_ab1
2022-08-11 15:16:59 normalization > 15:16:52.404130 [debug] [Thread-1  ]: Compiling model.airbyte_utils.nocdclast_c3_log_dtl_ab1
2022-08-11 15:16:59 normalization > 15:16:52.425743 [debug] [Thread-1  ]: On "model.airbyte_utils.nocdclast_c3_log_dtl_ab1": cache miss for schema "{self.database}.{self.schema}", this is inefficient
2022-08-11 15:16:59 normalization > 15:16:52.428709 [debug] [Thread-1  ]: Using postgres connection "model.airbyte_utils.nocdclast_c3_log_dtl_ab1"
2022-08-11 15:16:59 normalization > 15:16:52.428904 [debug] [Thread-1  ]: On model.airbyte_utils.nocdclast_c3_log_dtl_ab1: BEGIN
2022-08-11 15:16:59 normalization > 15:16:52.429003 [debug] [Thread-1  ]: Opening a new connection, currently in state closed
2022-08-11 15:16:59 normalization > 15:16:52.757165 [debug] [Thread-1  ]: SQL status: BEGIN in 0.33 seconds
2022-08-11 15:16:59 normalization > 15:16:52.757552 [debug] [Thread-1  ]: Using postgres connection "model.airbyte_utils.nocdclast_c3_log_dtl_ab1"
2022-08-11 15:16:59 normalization > 15:16:52.757782 [debug] [Thread-1  ]: On model.airbyte_utils.nocdclast_c3_log_dtl_ab1: /* {"app": "dbt", "dbt_version": "1.0.0", "profile_name": "normalize", "target_name": "prod", "node_id": "model.airbyte_utils.nocdclast_c3_log_dtl_ab1"} */
2022-08-11 15:16:59 normalization > select
2022-08-11 15:16:59 normalization >       'C3MAIN' as database,
2022-08-11 15:16:59 normalization >       tablename as name,
2022-08-11 15:16:59 normalization >       schemaname as schema,
2022-08-11 15:16:59 normalization >       'table' as type
2022-08-11 15:16:59 normalization >     from pg_tables
2022-08-11 15:16:59 normalization >     where schemaname ilike '_airbyte_c3stat'
2022-08-11 15:16:59 normalization >     union all
2022-08-11 15:16:59 normalization >     select
2022-08-11 15:16:59 normalization >       'C3MAIN' as database,
2022-08-11 15:16:59 normalization >       viewname as name,
2022-08-11 15:16:59 normalization >       schemaname as schema,
2022-08-11 15:16:59 normalization >       'view' as type
2022-08-11 15:16:59 normalization >     from pg_views
2022-08-11 15:16:59 normalization >     where schemaname ilike '_airbyte_c3stat'
2022-08-11 15:16:59 normalization >   
2022-08-11 15:16:59 normalization > 15:16:52.804417 [debug] [Thread-1  ]: SQL status: SELECT 0 in 0.05 seconds
2022-08-11 15:16:59 normalization > 15:16:52.806694 [debug] [Thread-1  ]: with database=C3MAIN, schema=_airbyte_c3stat, relations=[]
2022-08-11 15:16:59 normalization > 15:16:52.807132 [debug] [Thread-1  ]: Writing injected SQL for node "model.airbyte_utils.nocdclast_c3_log_dtl_ab1"
2022-08-11 15:16:59 normalization > 15:16:52.807852 [debug] [Thread-1  ]: finished collecting timing info
2022-08-11 15:16:59 normalization > 15:16:52.808142 [debug] [Thread-1  ]: On model.airbyte_utils.nocdclast_c3_log_dtl_ab1: ROLLBACK
2022-08-11 15:16:59 normalization > 15:16:52.847177 [debug] [Thread-1  ]: On model.airbyte_utils.nocdclast_c3_log_dtl_ab1: Close
2022-08-11 15:16:59 normalization > 15:16:52.848462 [debug] [Thread-1  ]: Finished running node model.airbyte_utils.nocdclast_c3_log_dtl_ab1
2022-08-11 15:16:59 normalization > 15:16:52.849626 [debug] [Thread-3  ]: Began running node model.airbyte_utils.nocdclast_c3_log_dtl_ab2
2022-08-11 15:16:59 normalization > 15:16:52.850657 [debug] [Thread-3  ]: Acquiring new postgres connection "model.airbyte_utils.nocdclast_c3_log_dtl_ab2"
2022-08-11 15:16:59 normalization > 15:16:52.850928 [debug] [Thread-3  ]: Began compiling node model.airbyte_utils.nocdclast_c3_log_dtl_ab2
2022-08-11 15:16:59 normalization > 15:16:52.851188 [debug] [Thread-3  ]: Compiling model.airbyte_utils.nocdclast_c3_log_dtl_ab2
2022-08-11 15:16:59 normalization > 15:16:52.868891 [debug] [Thread-3  ]: On "model.airbyte_utils.nocdclast_c3_log_dtl_ab2": cache miss for schema "{self.database}.{self.schema}", this is inefficient
2022-08-11 15:16:59 normalization > 15:16:52.871248 [debug] [Thread-3  ]: Using postgres connection "model.airbyte_utils.nocdclast_c3_log_dtl_ab2"
2022-08-11 15:16:59 normalization > 15:16:52.871379 [debug] [Thread-3  ]: On model.airbyte_utils.nocdclast_c3_log_dtl_ab2: BEGIN
2022-08-11 15:16:59 normalization > 15:16:52.871476 [debug] [Thread-3  ]: Opening a new connection, currently in state init
2022-08-11 15:16:59 normalization > 15:16:53.222210 [debug] [Thread-3  ]: SQL status: BEGIN in 0.35 seconds
2022-08-11 15:16:59 normalization > 15:16:53.222671 [debug] [Thread-3  ]: Using postgres connection "model.airbyte_utils.nocdclast_c3_log_dtl_ab2"
2022-08-11 15:16:59 normalization > 15:16:53.222985 [debug] [Thread-3  ]: On model.airbyte_utils.nocdclast_c3_log_dtl_ab2: /* {"app": "dbt", "dbt_version": "1.0.0", "profile_name": "normalize", "target_name": "prod", "node_id": "model.airbyte_utils.nocdclast_c3_log_dtl_ab2"} */
2022-08-11 15:16:59 normalization > select
2022-08-11 15:16:59 normalization >       'C3MAIN' as database,
2022-08-11 15:16:59 normalization >       tablename as name,
2022-08-11 15:16:59 normalization >       schemaname as schema,
2022-08-11 15:16:59 normalization >       'table' as type
2022-08-11 15:16:59 normalization >     from pg_tables
2022-08-11 15:16:59 normalization >     where schemaname ilike '_airbyte_c3stat'
2022-08-11 15:16:59 normalization >     union all
2022-08-11 15:16:59 normalization >     select
2022-08-11 15:16:59 normalization >       'C3MAIN' as database,
2022-08-11 15:16:59 normalization >       viewname as name,
2022-08-11 15:16:59 normalization >       schemaname as schema,
2022-08-11 15:16:59 normalization >       'view' as type
2022-08-11 15:16:59 normalization >     from pg_views
2022-08-11 15:16:59 normalization >     where schemaname ilike '_airbyte_c3stat'
2022-08-11 15:16:59 normalization >   
2022-08-11 15:16:59 normalization > 15:16:53.272285 [debug] [Thread-3  ]: SQL status: SELECT 0 in 0.05 seconds
2022-08-11 15:16:59 normalization > 15:16:53.274866 [debug] [Thread-3  ]: with database=C3MAIN, schema=_airbyte_c3stat, relations=[]
2022-08-11 15:16:59 normalization > 15:16:53.300244 [debug] [Thread-3  ]: Writing injected SQL for node "model.airbyte_utils.nocdclast_c3_log_dtl_ab2"
2022-08-11 15:16:59 normalization > 15:16:53.300509 [debug] [Thread-3  ]: finished collecting timing info
2022-08-11 15:16:59 normalization > 15:16:53.300644 [debug] [Thread-3  ]: On model.airbyte_utils.nocdclast_c3_log_dtl_ab2: ROLLBACK
2022-08-11 15:16:59 normalization > 15:16:53.342089 [debug] [Thread-3  ]: On model.airbyte_utils.nocdclast_c3_log_dtl_ab2: Close
2022-08-11 15:16:59 normalization > 15:16:53.343321 [debug] [Thread-3  ]: Finished running node model.airbyte_utils.nocdclast_c3_log_dtl_ab2
2022-08-11 15:16:59 normalization > 15:16:53.344149 [debug] [Thread-5  ]: Began running node model.airbyte_utils.nocdclast_c3_log_dtl_ab3
2022-08-11 15:16:59 normalization > 15:16:53.345255 [debug] [Thread-5  ]: Acquiring new postgres connection "model.airbyte_utils.nocdclast_c3_log_dtl_ab3"
2022-08-11 15:16:59 normalization > 15:16:53.345566 [debug] [Thread-5  ]: Began compiling node model.airbyte_utils.nocdclast_c3_log_dtl_ab3
2022-08-11 15:16:59 normalization > 15:16:53.346193 [debug] [Thread-5  ]: Compiling model.airbyte_utils.nocdclast_c3_log_dtl_ab3
2022-08-11 15:16:59 normalization > 15:16:53.357676 [debug] [Thread-5  ]: On "model.airbyte_utils.nocdclast_c3_log_dtl_ab3": cache miss for schema "{self.database}.{self.schema}", this is inefficient
2022-08-11 15:16:59 normalization > 15:16:53.360826 [debug] [Thread-5  ]: Using postgres connection "model.airbyte_utils.nocdclast_c3_log_dtl_ab3"
2022-08-11 15:16:59 normalization > 15:16:53.360953 [debug] [Thread-5  ]: On model.airbyte_utils.nocdclast_c3_log_dtl_ab3: BEGIN
2022-08-11 15:16:59 normalization > 15:16:53.361049 [debug] [Thread-5  ]: Opening a new connection, currently in state init
2022-08-11 15:16:59 normalization > 15:16:53.690996 [debug] [Thread-5  ]: SQL status: BEGIN in 0.33 seconds
2022-08-11 15:16:59 normalization > 15:16:53.691389 [debug] [Thread-5  ]: Using postgres connection "model.airbyte_utils.nocdclast_c3_log_dtl_ab3"
2022-08-11 15:16:59 normalization > 15:16:53.691641 [debug] [Thread-5  ]: On model.airbyte_utils.nocdclast_c3_log_dtl_ab3: /* {"app": "dbt", "dbt_version": "1.0.0", "profile_name": "normalize", "target_name": "prod", "node_id": "model.airbyte_utils.nocdclast_c3_log_dtl_ab3"} */
2022-08-11 15:16:59 normalization > select
2022-08-11 15:16:59 normalization >       'C3MAIN' as database,
2022-08-11 15:16:59 normalization >       tablename as name,
2022-08-11 15:16:59 normalization >       schemaname as schema,
2022-08-11 15:16:59 normalization >       'table' as type
2022-08-11 15:16:59 normalization >     from pg_tables
2022-08-11 15:16:59 normalization >     where schemaname ilike '_airbyte_c3stat'
2022-08-11 15:16:59 normalization >     union all
2022-08-11 15:16:59 normalization >     select
2022-08-11 15:16:59 normalization >       'C3MAIN' as database,
2022-08-11 15:16:59 normalization >       viewname as name,
2022-08-11 15:16:59 normalization >       schemaname as schema,
2022-08-11 15:16:59 normalization >       'view' as type
2022-08-11 15:16:59 normalization >     from pg_views
2022-08-11 15:16:59 normalization >     where schemaname ilike '_airbyte_c3stat'
2022-08-11 15:16:59 normalization >   
2022-08-11 15:16:59 normalization > 15:16:53.738591 [debug] [Thread-5  ]: SQL status: SELECT 0 in 0.05 seconds
2022-08-11 15:16:59 normalization > 15:16:53.740817 [debug] [Thread-5  ]: with database=C3MAIN, schema=_airbyte_c3stat, relations=[]
2022-08-11 15:16:59 normalization > 15:16:53.770933 [debug] [Thread-5  ]: Writing injected SQL for node "model.airbyte_utils.nocdclast_c3_log_dtl_ab3"
2022-08-11 15:16:59 normalization > 15:16:53.771184 [debug] [Thread-5  ]: finished collecting timing info
2022-08-11 15:16:59 normalization > 15:16:53.771324 [debug] [Thread-5  ]: On model.airbyte_utils.nocdclast_c3_log_dtl_ab3: ROLLBACK
2022-08-11 15:16:59 normalization > 15:16:53.810236 [debug] [Thread-5  ]: On model.airbyte_utils.nocdclast_c3_log_dtl_ab3: Close
2022-08-11 15:16:59 normalization > 15:16:53.811474 [debug] [Thread-5  ]: Finished running node model.airbyte_utils.nocdclast_c3_log_dtl_ab3
2022-08-11 15:16:59 normalization > 15:16:53.812311 [debug] [Thread-7  ]: Began running node model.airbyte_utils.nocdclast_c3_log_dtl
2022-08-11 15:16:59 normalization > 15:16:53.812867 [info ] [Thread-7  ]: 1 of 1 START incremental model c3stat.nocdclast_c3_log_dtl.............................................................. [RUN]
2022-08-11 15:16:59 normalization > 15:16:53.814229 [debug] [Thread-7  ]: Acquiring new postgres connection "model.airbyte_utils.nocdclast_c3_log_dtl"
2022-08-11 15:16:59 normalization > 15:16:53.814608 [debug] [Thread-7  ]: Began compiling node model.airbyte_utils.nocdclast_c3_log_dtl
2022-08-11 15:16:59 normalization > 15:16:53.815159 [debug] [Thread-7  ]: Compiling model.airbyte_utils.nocdclast_c3_log_dtl
2022-08-11 15:16:59 normalization > 15:16:53.839811 [debug] [Thread-7  ]: Using postgres connection "model.airbyte_utils.nocdclast_c3_log_dtl"
2022-08-11 15:16:59 normalization > 15:16:53.839958 [debug] [Thread-7  ]: On model.airbyte_utils.nocdclast_c3_log_dtl: BEGIN
2022-08-11 15:16:59 normalization > 15:16:53.840056 [debug] [Thread-7  ]: Opening a new connection, currently in state init
2022-08-11 15:16:59 normalization > 15:16:54.186871 [debug] [Thread-7  ]: SQL status: BEGIN in 0.35 seconds
2022-08-11 15:16:59 normalization > 15:16:54.187312 [debug] [Thread-7  ]: Using postgres connection "model.airbyte_utils.nocdclast_c3_log_dtl"
2022-08-11 15:16:59 normalization > 15:16:54.187549 [debug] [Thread-7  ]: On model.airbyte_utils.nocdclast_c3_log_dtl: /* {"app": "dbt", "dbt_version": "1.0.0", "profile_name": "normalize", "target_name": "prod", "node_id": "model.airbyte_utils.nocdclast_c3_log_dtl"} */
2022-08-11 15:16:59 normalization > 
2022-08-11 15:16:59 normalization >       select
2022-08-11 15:16:59 normalization >           column_name,
2022-08-11 15:16:59 normalization >           data_type,
2022-08-11 15:16:59 normalization >           character_maximum_length,
2022-08-11 15:16:59 normalization >           numeric_precision,
2022-08-11 15:16:59 normalization >           numeric_scale
2022-08-11 15:16:59 normalization > 
2022-08-11 15:16:59 normalization >       from "C3MAIN".INFORMATION_SCHEMA.columns
2022-08-11 15:16:59 normalization >       where table_name = 'nocdclast_c3_log_dtl'
2022-08-11 15:16:59 normalization >         
2022-08-11 15:16:59 normalization >         and table_schema = 'c3stat'
2022-08-11 15:16:59 normalization >         
2022-08-11 15:16:59 normalization >       order by ordinal_position
2022-08-11 15:16:59 normalization > 
2022-08-11 15:16:59 normalization >   
2022-08-11 15:16:59 normalization > 15:16:54.246866 [debug] [Thread-7  ]: SQL status: SELECT 23 in 0.06 seconds
2022-08-11 15:16:59 normalization > 15:16:54.268487 [debug] [Thread-7  ]: Writing injected SQL for node "model.airbyte_utils.nocdclast_c3_log_dtl"
2022-08-11 15:16:59 normalization > 15:16:54.268848 [debug] [Thread-7  ]: finished collecting timing info
2022-08-11 15:16:59 normalization > 15:16:54.268968 [debug] [Thread-7  ]: Began executing node model.airbyte_utils.nocdclast_c3_log_dtl
2022-08-11 15:16:59 normalization > 15:16:54.306324 [debug] [Thread-7  ]: Using postgres connection "model.airbyte_utils.nocdclast_c3_log_dtl"
2022-08-11 15:16:59 normalization > 15:16:54.306477 [debug] [Thread-7  ]: On model.airbyte_utils.nocdclast_c3_log_dtl: /* {"app": "dbt", "dbt_version": "1.0.0", "profile_name": "normalize", "target_name": "prod", "node_id": "model.airbyte_utils.nocdclast_c3_log_dtl"} */
2022-08-11 15:16:59 normalization > 
2022-08-11 15:16:59 normalization >       select
2022-08-11 15:16:59 normalization >           column_name,
2022-08-11 15:16:59 normalization >           data_type,
2022-08-11 15:16:59 normalization >           character_maximum_length,
2022-08-11 15:16:59 normalization >           numeric_precision,
2022-08-11 15:16:59 normalization >           numeric_scale
2022-08-11 15:16:59 normalization > 
2022-08-11 15:16:59 normalization >       from "C3MAIN".INFORMATION_SCHEMA.columns
2022-08-11 15:16:59 normalization >       where table_name = 'nocdclast_c3_log_dtl'
2022-08-11 15:16:59 normalization >         
2022-08-11 15:16:59 normalization >         and table_schema = 'c3stat'
2022-08-11 15:16:59 normalization >         
2022-08-11 15:16:59 normalization >       order by ordinal_position
2022-08-11 15:16:59 normalization > 
2022-08-11 15:16:59 normalization >   
2022-08-11 15:16:59 normalization > 15:16:54.351346 [debug] [Thread-7  ]: SQL status: SELECT 23 in 0.04 seconds
2022-08-11 15:16:59 normalization > 15:16:54.382403 [debug] [Thread-7  ]: Using postgres connection "model.airbyte_utils.nocdclast_c3_log_dtl"
2022-08-11 15:16:59 normalization > 15:16:54.382672 [debug] [Thread-7  ]: On model.airbyte_utils.nocdclast_c3_log_dtl: /* {"app": "dbt", "dbt_version": "1.0.0", "profile_name": "normalize", "target_name": "prod", "node_id": "model.airbyte_utils.nocdclast_c3_log_dtl"} */
2022-08-11 15:16:59 normalization > 
2022-08-11 15:16:59 normalization >     
2022-08-11 15:16:59 normalization > 
2022-08-11 15:16:59 normalization >   create temporary table "nocdclast_c3_log_dtl__dbt_tmp151654302655"
2022-08-11 15:16:59 normalization >   as (
2022-08-11 15:16:59 normalization >     
2022-08-11 15:16:59 normalization > with __dbt__cte__nocdclast_c3_log_dtl_ab1 as (
2022-08-11 15:16:59 normalization > 
2022-08-11 15:16:59 normalization > -- SQL model to parse JSON blob stored in a single column and extract into separated field columns as described by the JSON Schema
2022-08-11 15:16:59 normalization > -- depends_on: "C3MAIN".c3stat._airbyte_raw_nocdclast_c3_log_dtl
2022-08-11 15:16:59 normalization > select
2022-08-11 15:16:59 normalization >     jsonb_extract_path_text(_airbyte_data, 'stage') as stage,
2022-08-11 15:16:59 normalization >     jsonb_extract_path_text(_airbyte_data, 'row_cnt') as row_cnt,
2022-08-11 15:16:59 normalization >     jsonb_extract_path_text(_airbyte_data, 'run_seq') as run_seq,
2022-08-11 15:16:59 normalization >     jsonb_extract_path_text(_airbyte_data, 'end_time') as end_time,
2022-08-11 15:16:59 normalization >     jsonb_extract_path_text(_airbyte_data, 'log_type') as log_type,
2022-08-11 15:16:59 normalization >     jsonb_extract_path_text(_airbyte_data, 'severity') as severity,
2022-08-11 15:16:59 normalization >     jsonb_extract_path_text(_airbyte_data, 'sql_query') as sql_query,
2022-08-11 15:16:59 normalization >     jsonb_extract_path_text(_airbyte_data, 'error_code') as error_code,
2022-08-11 15:16:59 normalization >     jsonb_extract_path_text(_airbyte_data, 'mapping_id') as mapping_id,
2022-08-11 15:16:59 normalization >     jsonb_extract_path_text(_airbyte_data, 'start_time') as start_time,
2022-08-11 15:16:59 normalization >     jsonb_extract_path_text(_airbyte_data, 'description') as description,
2022-08-11 15:16:59 normalization >     jsonb_extract_path_text(_airbyte_data, 'log_dtl_seq') as log_dtl_seq,
2022-08-11 15:16:59 normalization >     jsonb_extract_path_text(_airbyte_data, 'mapping_seq') as mapping_seq,
2022-08-11 15:16:59 normalization >     jsonb_extract_path_text(_airbyte_data, 'error_detail') as error_detail,
2022-08-11 15:16:59 normalization >     jsonb_extract_path_text(_airbyte_data, 'mapping_order') as mapping_order,
2022-08-11 15:16:59 normalization >     jsonb_extract_path_text(_airbyte_data, 'source_artefact_seq') as source_artefact_seq,
2022-08-11 15:16:59 normalization >     jsonb_extract_path_text(_airbyte_data, 'target_artefact_seq') as target_artefact_seq,
2022-08-11 15:16:59 normalization >     jsonb_extract_path_text(_airbyte_data, 'source_artefact_type_seq') as source_artefact_type_seq,
2022-08-11 15:16:59 normalization >     jsonb_extract_path_text(_airbyte_data, 'target_artefact_type_seq') as target_artefact_type_seq,
2022-08-11 15:16:59 normalization >     _airbyte_ab_id,
2022-08-11 15:16:59 normalization >     _airbyte_emitted_at,
2022-08-11 15:16:59 normalization >     now() as _airbyte_normalized_at
2022-08-11 15:16:59 normalization > from "C3MAIN".c3stat._airbyte_raw_nocdclast_c3_log_dtl as table_alias
2022-08-11 15:16:59 normalization > -- nocdclast_c3_log_dtl
2022-08-11 15:16:59 normalization > where 1 = 1
2022-08-11 15:16:59 normalization > 
2022-08-11 15:16:59 normalization > ),  __dbt__cte__nocdclast_c3_log_dtl_ab2 as (
2022-08-11 15:16:59 normalization > 
2022-08-11 15:16:59 normalization > -- SQL model to cast each column to its adequate SQL type converted from the JSON schema type
2022-08-11 15:16:59 normalization > -- depends_on: __dbt__cte__nocdclast_c3_log_dtl_ab1
2022-08-11 15:16:59 normalization > select
2022-08-11 15:16:59 normalization >     cast(stage as text) as stage,
2022-08-11 15:16:59 normalization >     cast(row_cnt as text) as row_cnt,
2022-08-11 15:16:59 normalization >     cast(run_seq as text) as run_seq,
2022-08-11 15:16:59 normalization >     cast(nullif(end_time, '') as 
2022-08-11 15:16:59 normalization >     timestamp
2022-08-11 15:16:59 normalization > ) as end_time,
2022-08-11 15:16:59 normalization >     cast(log_type as text) as log_type,
2022-08-11 15:16:59 normalization >     cast(severity as text) as severity,
2022-08-11 15:16:59 normalization >     cast(sql_query as text) as sql_query,
2022-08-11 15:16:59 normalization >     cast(error_code as text) as error_code,
2022-08-11 15:16:59 normalization >     cast(mapping_id as text) as mapping_id,
2022-08-11 15:16:59 normalization >     cast(nullif(start_time, '') as 
2022-08-11 15:16:59 normalization >     timestamp
2022-08-11 15:16:59 normalization > ) as start_time,
2022-08-11 15:16:59 normalization >     cast(description as text) as description,
2022-08-11 15:16:59 normalization >     cast(log_dtl_seq as 
2022-08-11 15:16:59 normalization >     bigint
2022-08-11 15:16:59 normalization > ) as log_dtl_seq,
2022-08-11 15:16:59 normalization >     cast(mapping_seq as text) as mapping_seq,
2022-08-11 15:16:59 normalization >     cast(error_detail as text) as error_detail,
2022-08-11 15:16:59 normalization >     cast(mapping_order as text) as mapping_order,
2022-08-11 15:16:59 normalization >     cast(source_artefact_seq as text) as source_artefact_seq,
2022-08-11 15:16:59 normalization >     cast(target_artefact_seq as text) as target_artefact_seq,
2022-08-11 15:16:59 normalization >     cast(source_artefact_type_seq as text) as source_artefact_type_seq,
2022-08-11 15:16:59 normalization >     cast(target_artefact_type_seq as text) as target_artefact_type_seq,
2022-08-11 15:16:59 normalization >     _airbyte_ab_id,
2022-08-11 15:16:59 normalization >     _airbyte_emitted_at,
2022-08-11 15:16:59 normalization >     now() as _airbyte_normalized_at
2022-08-11 15:16:59 normalization > from __dbt__cte__nocdclast_c3_log_dtl_ab1
2022-08-11 15:16:59 normalization > -- nocdclast_c3_log_dtl
2022-08-11 15:16:59 normalization > where 1 = 1
2022-08-11 15:16:59 normalization > 
2022-08-11 15:16:59 normalization > ),  __dbt__cte__nocdclast_c3_log_dtl_ab3 as (
2022-08-11 15:16:59 normalization > 
2022-08-11 15:16:59 normalization > -- SQL model to build a hash column based on the values of this record
2022-08-11 15:16:59 normalization > -- depends_on: __dbt__cte__nocdclast_c3_log_dtl_ab2
2022-08-11 15:16:59 normalization > select
2022-08-11 15:16:59 normalization >     md5(cast(coalesce(cast(stage as text), '') || '-' || coalesce(cast(row_cnt as text), '') || '-' || coalesce(cast(run_seq as text), '') || '-' || coalesce(cast(end_time as text), '') || '-' || coalesce(cast(log_type as text), '') || '-' || coalesce(cast(severity as text), '') || '-' || coalesce(cast(sql_query as text), '') || '-' || coalesce(cast(error_code as text), '') || '-' || coalesce(cast(mapping_id as text), '') || '-' || coalesce(cast(start_time as text), '') || '-' || coalesce(cast(description as text), '') || '-' || coalesce(cast(log_dtl_seq as text), '') || '-' || coalesce(cast(mapping_seq as text), '') || '-' || coalesce(cast(error_detail as text), '') || '-' || coalesce(cast(mapping_order as text), '') || '-' || coalesce(cast(source_artefact_seq as text), '') || '-' || coalesce(cast(target_artefact_seq as text), '') || '-' || coalesce(cast(source_artefact_type_seq as text), '') || '-' || coalesce(cast(target_artefact_type_seq as text), '') as text)) as _airbyte_nocdclast_c3_log_dtl_hashid,
2022-08-11 15:16:59 normalization >     tmp.*
2022-08-11 15:16:59 normalization > from __dbt__cte__nocdclast_c3_log_dtl_ab2 tmp
2022-08-11 15:16:59 normalization > -- nocdclast_c3_log_dtl
2022-08-11 15:16:59 normalization > where 1 = 1
2022-08-11 15:16:59 normalization > 
2022-08-11 15:16:59 normalization > )-- Final base SQL model
2022-08-11 15:16:59 normalization > -- depends_on: __dbt__cte__nocdclast_c3_log_dtl_ab3
2022-08-11 15:16:59 normalization > select
2022-08-11 15:16:59 normalization >     stage,
2022-08-11 15:16:59 normalization >     row_cnt,
2022-08-11 15:16:59 normalization >     run_seq,
2022-08-11 15:16:59 normalization >     end_time,
2022-08-11 15:16:59 normalization >     log_type,
2022-08-11 15:16:59 normalization >     severity,
2022-08-11 15:16:59 normalization >     sql_query,
2022-08-11 15:16:59 normalization >     error_code,
2022-08-11 15:16:59 normalization >     mapping_id,
2022-08-11 15:16:59 normalization >     start_time,
2022-08-11 15:16:59 normalization >     description,
2022-08-11 15:16:59 normalization >     log_dtl_seq,
2022-08-11 15:16:59 normalization >     mapping_seq,
2022-08-11 15:16:59 normalization >     error_detail,
2022-08-11 15:16:59 normalization >     mapping_order,
2022-08-11 15:16:59 normalization >     source_artefact_seq,
2022-08-11 15:16:59 normalization >     target_artefact_seq,
2022-08-11 15:16:59 normalization >     source_artefact_type_seq,
2022-08-11 15:16:59 normalization >     target_artefact_type_seq,
2022-08-11 15:16:59 normalization >     _airbyte_ab_id,
2022-08-11 15:16:59 normalization >     _airbyte_emitted_at,
2022-08-11 15:16:59 normalization >     now() as _airbyte_normalized_at,
2022-08-11 15:16:59 normalization >     _airbyte_nocdclast_c3_log_dtl_hashid
2022-08-11 15:16:59 normalization > from __dbt__cte__nocdclast_c3_log_dtl_ab3
2022-08-11 15:16:59 normalization > -- nocdclast_c3_log_dtl from "C3MAIN".c3stat._airbyte_raw_nocdclast_c3_log_dtl
2022-08-11 15:16:59 normalization > where 1 = 1
2022-08-11 15:16:59 normalization > 
2022-08-11 15:16:59 normalization > and coalesce(
2022-08-11 15:16:59 normalization >     cast(_airbyte_emitted_at as 
2022-08-11 15:16:59 normalization >     timestamp with time zone
2022-08-11 15:16:59 normalization > ) >= (select max(cast(_airbyte_emitted_at as 
2022-08-11 15:16:59 normalization >     timestamp with time zone
2022-08-11 15:16:59 normalization > )) from "C3MAIN".c3stat."nocdclast_c3_log_dtl"),
2022-08-11 15:16:59 normalization >     
2022-08-11 15:16:59 normalization >     
2022-08-11 15:16:59 normalization >     true)
2022-08-11 15:16:59 normalization > 
2022-08-11 15:16:59 normalization >   );
2022-08-11 15:16:59 normalization >   
2022-08-11 15:16:59 normalization > 15:16:54.435560 [debug] [Thread-7  ]: Postgres adapter: Postgres error: date/time field value out of range: "2021-06-01T18:41:54.977728"
2022-08-11 15:16:59 normalization > CONTEXT:  PL/pgSQL function text_timestamp(text) line 4 at RETURN
2022-08-11 15:16:59 normalization > 
2022-08-11 15:16:59 normalization > 15:16:54.435926 [debug] [Thread-7  ]: On model.airbyte_utils.nocdclast_c3_log_dtl: ROLLBACK
2022-08-11 15:16:59 normalization > 15:16:54.477080 [debug] [Thread-7  ]: finished collecting timing info
2022-08-11 15:16:59 normalization > 15:16:54.477379 [debug] [Thread-7  ]: On model.airbyte_utils.nocdclast_c3_log_dtl: Close
2022-08-11 15:16:59 normalization > 15:16:54.478518 [debug] [Thread-7  ]: Database Error in model nocdclast_c3_log_dtl (models/generated/airbyte_incremental/c3stat/nocdclast_c3_log_dtl.sql)
2022-08-11 15:16:59 normalization >   date/time field value out of range: "2021-06-01T18:41:54.977728"
2022-08-11 15:16:59 normalization >   CONTEXT:  PL/pgSQL function text_timestamp(text) line 4 at RETURN
2022-08-11 15:16:59 normalization > 15:16:54.479127 [error] [Thread-7  ]: 1 of 1 ERROR creating incremental model c3stat.nocdclast_c3_log_dtl..................................................... [ERROR in 0.67s]
2022-08-11 15:16:59 normalization > 15:16:54.479858 [debug] [Thread-7  ]: Finished running node model.airbyte_utils.nocdclast_c3_log_dtl
2022-08-11 15:16:59 normalization > 15:16:54.482675 [debug] [MainThread]: Acquiring new postgres connection "master"
2022-08-11 15:16:59 normalization > 15:16:54.483005 [debug] [MainThread]: Using postgres connection "master"
2022-08-11 15:16:59 normalization > 15:16:54.483224 [debug] [MainThread]: On master: BEGIN
2022-08-11 15:16:59 normalization > 15:16:54.483424 [debug] [MainThread]: Opening a new connection, currently in state closed
2022-08-11 15:16:59 normalization > 15:16:54.821978 [debug] [MainThread]: SQL status: BEGIN in 0.34 seconds
2022-08-11 15:16:59 normalization > 15:16:54.822389 [debug] [MainThread]: On master: COMMIT
2022-08-11 15:16:59 normalization > 15:16:54.822605 [debug] [MainThread]: Using postgres connection "master"
2022-08-11 15:16:59 normalization > 15:16:54.822834 [debug] [MainThread]: On master: COMMIT
2022-08-11 15:16:59 normalization > 15:16:54.861855 [debug] [MainThread]: SQL status: COMMIT in 0.04 seconds
2022-08-11 15:16:59 normalization > 15:16:54.862199 [debug] [MainThread]: On master: Close
2022-08-11 15:16:59 normalization > 15:16:54.863507 [info ] [MainThread]: 
2022-08-11 15:16:59 normalization > 15:16:54.864055 [info ] [MainThread]: Finished running 1 incremental model in 4.17s.
2022-08-11 15:16:59 normalization > 15:16:54.864455 [debug] [MainThread]: Connection 'master' was properly closed.
2022-08-11 15:16:59 normalization > 15:16:54.864671 [debug] [MainThread]: Connection 'model.airbyte_utils.nocdclast_c3_log_dtl_ab1' was properly closed.
2022-08-11 15:16:59 normalization > 15:16:54.864884 [debug] [MainThread]: Connection 'model.airbyte_utils.nocdclast_c3_log_dtl_ab2' was properly closed.
2022-08-11 15:16:59 normalization > 15:16:54.865089 [debug] [MainThread]: Connection 'model.airbyte_utils.nocdclast_c3_log_dtl_ab3' was properly closed.
2022-08-11 15:16:59 normalization > 15:16:54.865277 [debug] [MainThread]: Connection 'model.airbyte_utils.nocdclast_c3_log_dtl' was properly closed.
2022-08-11 15:16:59 normalization > 15:16:54.881503 [info ] [MainThread]: 
2022-08-11 15:16:59 normalization > 15:16:54.881765 [info ] [MainThread]: Completed with 1 error and 0 warnings:
2022-08-11 15:16:59 normalization > 15:16:54.882032 [info ] [MainThread]: 
2022-08-11 15:16:59 normalization > 15:16:54.882229 [error] [MainThread]: Database Error in model nocdclast_c3_log_dtl (models/generated/airbyte_incremental/c3stat/nocdclast_c3_log_dtl.sql)
2022-08-11 15:16:59 normalization > 15:16:54.882432 [error] [MainThread]:   date/time field value out of range: "2021-06-01T18:41:54.977728"
2022-08-11 15:16:59 normalization > 15:16:54.882619 [error] [MainThread]:   CONTEXT:  PL/pgSQL function text_timestamp(text) line 4 at RETURN
2022-08-11 15:16:59 normalization > 15:16:54.882805 [info ] [MainThread]: 
2022-08-11 15:16:59 normalization > 15:16:54.882991 [info ] [MainThread]: Done. PASS=0 WARN=0 ERROR=1 SKIP=0 TOTAL=1
2022-08-11 15:16:59 INFO i.a.w.t.TemporalAttemptExecution(lambda$getWorkerThread$2):158 - Completing future exceptionally...
io.airbyte.workers.exception.WorkerException: Normalization Failed.
	at io.airbyte.workers.general.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:64) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?]
	at io.airbyte.workers.general.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:21) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?]
	at java.lang.Thread.run(Thread.java:1589) [?:?]
Caused by: io.airbyte.workers.exception.WorkerException: Normalization Failed.
	at io.airbyte.workers.general.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:61) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?]
	... 3 more
	Suppressed: io.airbyte.workers.exception.WorkerException: Normalization process wasn't successful
		at io.airbyte.workers.normalization.DefaultNormalizationRunner.close(DefaultNormalizationRunner.java:162) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?]
		at io.airbyte.workers.general.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:49) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?]
		at io.airbyte.workers.general.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:21) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?]
		at java.lang.Thread.run(Thread.java:1589) [?:?]
2022-08-11 15:16:59 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-08-11 15:16:59 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):291 - Stopping temporal heartbeating...
2022-08-11 15:16:59 WARN i.t.i.a.POJOActivityTaskHandler(activityFailureToResult):307 - Activity failure. ActivityId=09d8c844-e472-3487-b972-e5a6103c2a18, activityType=Normalize, attempt=1
java.lang.RuntimeException: io.temporal.serviceclient.CheckedExceptionWrapper: java.util.concurrent.ExecutionException: io.airbyte.workers.exception.WorkerException: Normalization Failed.
	at io.airbyte.workers.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:289) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?]
	at io.airbyte.workers.temporal.sync.NormalizationActivityImpl.normalize(NormalizationActivityImpl.java:75) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?]
	at jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:104) ~[?:?]
	at java.lang.reflect.Method.invoke(Method.java:578) ~[?:?]
	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:1144) [?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) [?:?]
	at java.lang.Thread.run(Thread.java:1589) [?:?]
Caused by: io.temporal.serviceclient.CheckedExceptionWrapper: java.util.concurrent.ExecutionException: io.airbyte.workers.exception.WorkerException: Normalization Failed.
	at io.temporal.serviceclient.CheckedExceptionWrapper.wrap(CheckedExceptionWrapper.java:56) ~[temporal-serviceclient-1.8.1.jar:?]
	at io.temporal.internal.sync.WorkflowInternal.wrap(WorkflowInternal.java:448) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.activity.Activity.wrap(Activity.java:51) ~[temporal-sdk-1.8.1.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.get(TemporalAttemptExecution.java:135) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?]
	at io.airbyte.workers.temporal.sync.NormalizationActivityImpl.lambda$normalize$3(NormalizationActivityImpl.java:103) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:284) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?]
	... 12 more
Caused by: java.util.concurrent.ExecutionException: io.airbyte.workers.exception.WorkerException: Normalization Failed.
	at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) ~[?:?]
	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) ~[?:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.get(TemporalAttemptExecution.java:129) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?]
	at io.airbyte.workers.temporal.sync.NormalizationActivityImpl.lambda$normalize$3(NormalizationActivityImpl.java:103) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:284) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?]
	... 12 more
Caused by: io.airbyte.workers.exception.WorkerException: Normalization Failed.
	at io.airbyte.workers.general.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:64) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?]
	at io.airbyte.workers.general.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:21) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?]
	... 1 more
Caused by: io.airbyte.workers.exception.WorkerException: Normalization Failed.
	at io.airbyte.workers.general.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:61) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?]
	at io.airbyte.workers.general.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:21) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?]
	... 1 more
	Suppressed: io.airbyte.workers.exception.WorkerException: Normalization process wasn't successful
		at io.airbyte.workers.normalization.DefaultNormalizationRunner.close(DefaultNormalizationRunner.java:162) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?]
		at io.airbyte.workers.general.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:49) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?]
		at io.airbyte.workers.general.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:21) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?]
		at java.lang.Thread.run(Thread.java:1589) [?:?]
2022-08-11 15:16:59 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/24/1/logs.log
2022-08-11 15:16:59 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.39.41-alpha
2022-08-11 15:16:59 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-postgres:0.4.38 exists...
2022-08-11 15:16:59 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-postgres:0.4.38 was found locally.
2022-08-11 15:16:59 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 24
2022-08-11 15:16:59 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/24/1 --log-driver none --name source-postgres-check-24-1-tpbha --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_CONNECTOR_IMAGE=airbyte/source-postgres:0.4.38 -e WORKER_JOB_ATTEMPT=1 -e AIRBYTE_VERSION=0.39.41-alpha -e WORKER_JOB_ID=24 --cpus=0.7 --memory=8g airbyte/source-postgres:0.4.38 check --config source_config.json
2022-08-11 15:16:59 ERROR i.a.c.i.LineGobbler(voidCall):82 - WARNING: Your kernel does not support swap limit capabilities or the cgroup is not mounted. Memory limited without swap.
2022-08-11 15:17:02 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:17:02 INFO i.a.i.b.a.AdaptiveSourceRunner$Runner(getSource):73 - Running source under deployment mode: OSS
2022-08-11 15:17:02 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:17:02 INFO i.a.i.b.a.AdaptiveSourceRunner$Runner(run):85 - Starting source: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-08-11 15:17:02 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:17:02 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json}
2022-08-11 15:17:02 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:17:02 INFO i.a.i.b.IntegrationRunner(runInternal):104 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-08-11 15:17:02 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:17:02 INFO i.a.i.b.IntegrationRunner(runInternal):105 - Command: CHECK
2022-08-11 15:17:02 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:17:02 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'}
2022-08-11 15:17:03 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:17:03 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-08-11 15:17:03 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:17:03 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-08-11 15:17:03 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:17:03 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-08-11 15:17:03 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:17:03 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-08-11 15:17:03 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:17:03 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword min - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-08-11 15:17:03 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:17:03 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword max - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-08-11 15:17:03 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:17:03 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL
2022-08-11 15:17:03 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:17:03 INFO c.z.h.HikariDataSource(<init>):80 - HikariPool-1 - Starting...
2022-08-11 15:17:03 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:17:03 INFO c.z.h.HikariDataSource(<init>):82 - HikariPool-1 - Start completed.
2022-08-11 15:17:05 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:17:05 INFO i.a.i.s.p.PostgresUtils(isCdc):29 - using CDC: false
2022-08-11 15:17:05 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:17:05 INFO i.a.i.s.j.AbstractJdbcSource(lambda$getCheckOperations$1):95 - Attempting to get metadata from the database to see if we can connect.
2022-08-11 15:17:05 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:17:05 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated...
2022-08-11 15:17:05 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:17:05 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed.
2022-08-11 15:17:05 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:17:05 INFO i.a.i.b.IntegrationRunner(runInternal):152 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-08-11 15:17:05 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:17:05 INFO i.a.i.b.a.AdaptiveSourceRunner$Runner(run):87 - Completed source: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-08-11 15:17:05 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-08-11 15:17:05 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/24/1/logs.log
2022-08-11 15:17:05 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.39.41-alpha
2022-08-11 15:17:05 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-postgres:0.3.21 exists...
2022-08-11 15:17:05 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-postgres:0.3.21 was found locally.
2022-08-11 15:17:05 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 24
2022-08-11 15:17:05 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/24/1 --log-driver none --name destination-postgres-check-24-1-gerxt --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_CONNECTOR_IMAGE=airbyte/destination-postgres:0.3.21 -e WORKER_JOB_ATTEMPT=1 -e AIRBYTE_VERSION=0.39.41-alpha -e WORKER_JOB_ID=24 --cpus=0.7 --memory=8g airbyte/destination-postgres:0.3.21 check --config source_config.json
2022-08-11 15:17:05 ERROR i.a.c.i.LineGobbler(voidCall):82 - WARNING: Your kernel does not support swap limit capabilities or the cgroup is not mounted. Memory limited without swap.
2022-08-11 15:17:06 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings.
2022-08-11 15:17:06 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-08-11 15:17:06 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-reload4j-1.7.36.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-08-11 15:17:06 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-08-11 15:17:06 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-08-11 15:17:06 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-08-11 15:17:06 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-08-11 15:17:08 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:17:08 INFO i.a.i.d.p.PostgresDestination(main):90 - starting destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2022-08-11 15:17:08 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:17:08 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json}
2022-08-11 15:17:08 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:17:08 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2022-08-11 15:17:08 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:17:08 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: CHECK
2022-08-11 15:17:08 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:17:08 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'}
2022-08-11 15:17:08 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:17:08 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-08-11 15:17:08 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:17:08 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-08-11 15:17:08 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:17:08 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-08-11 15:17:08 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:17:08 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-08-11 15:17:09 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:17:09 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL
2022-08-11 15:17:09 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:17:09 INFO c.z.h.HikariDataSource(<init>):80 - HikariPool-1 - Starting...
2022-08-11 15:17:09 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:17:09 INFO c.z.h.HikariDataSource(<init>):82 - HikariPool-1 - Start completed.
2022-08-11 15:17:10 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:17:10 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated...
2022-08-11 15:17:10 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:17:10 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed.
2022-08-11 15:17:10 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:17:10 INFO i.a.i.b.IntegrationRunner(runInternal):171 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2022-08-11 15:17:10 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-11 15:17:10 INFO i.a.i.d.p.PostgresDestination(main):92 - completed destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2022-08-11 15:17:11 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-08-11 15:17:11 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/24/1/logs.log
2022-08-11 15:17:11 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.39.41-alpha
2022-08-11 15:17:11 INFO i.a.w.g.DefaultReplicationWorker(run):116 - start sync worker. job id: 24 attempt id: 1
2022-08-11 15:17:11 INFO i.a.w.g.DefaultReplicationWorker(run):128 - configured sync modes: {c3idb.c3_log_dtl=full_refresh - append}
2022-08-11 15:17:11 INFO i.a.w.i.DefaultAirbyteDestination(start):69 - Running destination...
2022-08-11 15:17:11 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-postgres:0.3.21 exists...
2022-08-11 15:17:11 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-postgres:0.3.21 was found locally.
2022-08-11 15:17:11 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 24
2022-08-11 15:17:11 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/24/1 --log-driver none --name destination-postgres-write-24-1-effpp --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_CONNECTOR_IMAGE=airbyte/destination-postgres:0.3.21 -e WORKER_JOB_ATTEMPT=1 -e AIRBYTE_VERSION=0.39.41-alpha -e WORKER_JOB_ID=24 --cpus=0.7 --memory=8g airbyte/destination-postgres:0.3.21 write --config destination_config.json --catalog destination_catalog.json
2022-08-11 15:17:11 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-postgres:0.4.38 exists...
2022-08-11 15:17:11 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-postgres:0.4.38 was found locally.
2022-08-11 15:17:11 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 24
2022-08-11 15:17:11 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/24/1 --log-driver none --name source-postgres-read-24-1-vzpmk --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_CONNECTOR_IMAGE=airbyte/source-postgres:0.4.38 -e WORKER_JOB_ATTEMPT=1 -e AIRBYTE_VERSION=0.39.41-alpha -e WORKER_JOB_ID=24 --cpus=0.7 --memory=8g airbyte/source-postgres:0.4.38 read --config source_config.json --catalog source_catalog.json --state input_state.json
2022-08-11 15:17:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):406 - Destination output thread started.
2022-08-11 15:17:11 INFO i.a.w.g.DefaultReplicationWorker(run):170 - Waiting for source and destination threads to complete.
2022-08-11 15:17:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):299 - Replication thread started.
2022-08-11 15:17:11 destination > WARNING: Your kernel does not support swap limit capabilities or the cgroup is not mounted. Memory limited without swap.
2022-08-11 15:17:11 source > WARNING: Your kernel does not support swap limit capabilities or the cgroup is not mounted. Memory limited without swap.
2022-08-11 15:17:11 destination > SLF4J: Class path contains multiple SLF4J bindings.
2022-08-11 15:17:11 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-08-11 15:17:11 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-reload4j-1.7.36.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-08-11 15:17:11 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-08-11 15:17:11 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-08-11 15:17:11 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-08-11 15:17:12 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-08-11 15:17:13 source > 2022-08-11 15:17:13 INFO i.a.i.b.a.AdaptiveSourceRunner$Runner(getSource):73 - Running source under deployment mode: OSS
2022-08-11 15:17:13 destination > 2022-08-11 15:17:13 INFO i.a.i.d.p.PostgresDestination(main):90 - starting destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2022-08-11 15:17:13 source > 2022-08-11 15:17:13 INFO i.a.i.b.a.AdaptiveSourceRunner$Runner(run):85 - Starting source: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-08-11 15:17:13 destination > 2022-08-11 15:17:13 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-08-11 15:17:13 destination > 2022-08-11 15:17:13 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2022-08-11 15:17:13 destination > 2022-08-11 15:17:13 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: WRITE
2022-08-11 15:17:13 destination > 2022-08-11 15:17:13 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2022-08-11 15:17:13 source > 2022-08-11 15:17:13 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-08-11 15:17:13 source > 2022-08-11 15:17:13 INFO i.a.i.b.IntegrationRunner(runInternal):104 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-08-11 15:17:13 source > 2022-08-11 15:17:13 INFO i.a.i.b.IntegrationRunner(runInternal):105 - Command: READ
2022-08-11 15:17:13 source > 2022-08-11 15:17:13 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Integration config: IntegrationConfig{command=READ, configPath='source_config.json', catalogPath='source_catalog.json', statePath='input_state.json'}
2022-08-11 15:17:14 destination > 2022-08-11 15:17:14 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-08-11 15:17:14 destination > 2022-08-11 15:17:14 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-08-11 15:17:14 destination > 2022-08-11 15:17:14 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-08-11 15:17:14 destination > 2022-08-11 15:17:14 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-08-11 15:17:14 source > 2022-08-11 15:17:14 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-08-11 15:17:14 source > 2022-08-11 15:17:14 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-08-11 15:17:14 source > 2022-08-11 15:17:14 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-08-11 15:17:14 source > 2022-08-11 15:17:14 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-08-11 15:17:14 source > 2022-08-11 15:17:14 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword min - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-08-11 15:17:14 source > 2022-08-11 15:17:14 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword max - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-08-11 15:17:14 destination > 2022-08-11 15:17:14 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL
2022-08-11 15:17:14 destination > 2022-08-11 15:17:14 INFO c.z.h.HikariDataSource(<init>):80 - HikariPool-1 - Starting...
2022-08-11 15:17:14 destination > 2022-08-11 15:17:14 INFO c.z.h.HikariDataSource(<init>):82 - HikariPool-1 - Start completed.
2022-08-11 15:17:14 source > 2022-08-11 15:17:14 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL
2022-08-11 15:17:15 destination > 2022-08-11 15:17:15 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):97 - Write config: WriteConfig{streamName=nocdclast_c3_log_dtl, namespace=null, outputSchemaName=c3stat, tmpTableName=_airbyte_tmp_nvj_nocdclast_c3_log_dtl, outputTableName=_airbyte_raw_nocdclast_c3_log_dtl, syncMode=append}
2022-08-11 15:17:15 source > 2022-08-11 15:17:15 INFO c.z.h.HikariDataSource(<init>):80 - HikariPool-1 - Starting...
2022-08-11 15:17:15 source > 2022-08-11 15:17:15 INFO c.z.h.HikariDataSource(<init>):82 - HikariPool-1 - Start completed.
2022-08-11 15:17:15 destination > 2022-08-11 15:17:15 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-08-11 15:17:15 destination > 2022-08-11 15:17:15 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):122 - Preparing tmp tables in destination started for 1 streams
2022-08-11 15:17:15 destination > 2022-08-11 15:17:15 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):126 - Preparing tmp table in destination started for stream nocdclast_c3_log_dtl. schema: c3stat, tmp table name: _airbyte_tmp_nvj_nocdclast_c3_log_dtl
2022-08-11 15:17:16 destination > 2022-08-11 15:17:16 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):132 - Preparing tables in destination completed.
2022-08-11 15:17:16 source > 2022-08-11 15:17:16 INFO i.a.i.s.p.PostgresUtils(isCdc):29 - using CDC: false
2022-08-11 15:17:16 source > 2022-08-11 15:17:16 INFO i.a.i.s.j.AbstractJdbcSource(lambda$getCheckOperations$1):95 - Attempting to get metadata from the database to see if we can connect.
2022-08-11 15:17:16 source > 2022-08-11 15:17:16 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated...
2022-08-11 15:17:16 source > 2022-08-11 15:17:16 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed.
2022-08-11 15:17:16 source > 2022-08-11 15:17:16 INFO i.a.i.s.r.s.StateManagerFactory(createStateManager):48 - Legacy state manager selected to manage state object with type LEGACY.
2022-08-11 15:17:16 source > 2022-08-11 15:17:16 INFO i.a.i.s.r.s.CursorManager(createCursorInfoForStream):161 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='c3_log_dtl', namespace='c3idb'}, New Cursor Field: null. Resetting cursor value
2022-08-11 15:17:16 source > 2022-08-11 15:17:16 INFO i.a.i.s.r.CdcStateManager(<init>):29 - Initialized CDC state with: null
2022-08-11 15:17:16 source > 2022-08-11 15:17:16 INFO c.z.h.HikariDataSource(<init>):80 - HikariPool-2 - Starting...
2022-08-11 15:17:16 source > 2022-08-11 15:17:16 INFO c.z.h.HikariDataSource(<init>):82 - HikariPool-2 - Start completed.
2022-08-11 15:17:16 source > 2022-08-11 15:17:16 INFO i.a.i.s.p.PostgresSource(discoverRawTables):207 - Checking schema: c3idb
2022-08-11 15:17:16 source > 2022-08-11 15:17:16 INFO i.a.i.s.j.AbstractJdbcSource(discoverInternal):123 - Internal schemas to exclude: [catalog_history, information_schema, pg_catalog, pg_internal]
2022-08-11 15:17:17 source > 2022-08-11 15:17:17 INFO i.a.d.j.s.AdaptiveStreamingQueryConfig(initialize):38 - Set initial fetch size: 10 rows
2022-08-11 15:17:41 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):191 - Running sync worker cancellation...
2022-08-11 15:17:41 INFO i.a.w.g.DefaultReplicationWorker(cancel):444 - Cancelling replication worker...
2022-08-11 15:17:51 INFO i.a.w.g.DefaultReplicationWorker(cancel):452 - Cancelling destination...
2022-08-11 15:17:51 INFO i.a.w.i.DefaultAirbyteDestination(cancel):125 - Attempting to cancel destination process...
2022-08-11 15:17:51 INFO i.a.w.i.DefaultAirbyteDestination(cancel):130 - Destination process exists, cancelling...
2022-08-11 15:17:51 INFO i.a.w.g.DefaultReplicationWorker(run):175 - One of source or destination thread complete. Waiting on the other.
2022-08-11 15:17:51 WARN i.a.c.i.LineGobbler(voidCall):86 - airbyte-destination gobbler IOException: Stream closed. Typically happens when cancelling a job.
2022-08-11 15:17:51 INFO i.a.w.i.DefaultAirbyteDestination(cancel):132 - Cancelled destination process!
2022-08-11 15:17:51 INFO i.a.w.g.DefaultReplicationWorker(cancel):459 - Cancelling source...
2022-08-11 15:17:51 INFO i.a.w.i.DefaultAirbyteSource(cancel):142 - Attempting to cancel source process...
2022-08-11 15:17:51 INFO i.a.w.i.DefaultAirbyteSource(cancel):147 - Source process exists, cancelling...
2022-08-11 15:17:51 INFO i.a.w.i.DefaultAirbyteSource(cancel):149 - Cancelled source process!
2022-08-11 15:17:51 INFO i.a.w.g.DefaultReplicationWorker(run):177 - Source and destination threads complete.
2022-08-11 15:17:51 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):195 - Interrupting worker thread...
2022-08-11 15:17:51 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):198 - Cancelling completable future...
2022-08-11 15:17:51 WARN i.a.w.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled.
2022-08-11 15:17:51 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-08-11 15:17:51 WARN i.a.w.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled.
2022-08-11 15:17:51 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):291 - Stopping temporal heartbeating...
2022-08-11 15:17:51 WARN i.t.i.a.POJOActivityTaskHandler(activityFailureToResult):307 - Activity failure. ActivityId=4ca7b5af-cc71-3ffd-85d2-404864ea3b3d, activityType=Replicate, attempt=1
java.lang.RuntimeException: java.util.concurrent.CancellationException
	at io.airbyte.workers.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:289) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?]
	at io.airbyte.workers.temporal.sync.ReplicationActivityImpl.replicate(ReplicationActivityImpl.java:115) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?]
	at jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:104) ~[?:?]
	at java.lang.reflect.Method.invoke(Method.java:578) ~[?:?]
	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:1144) [?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) [?:?]
	at java.lang.Thread.run(Thread.java:1589) [?:?]
Caused by: java.util.concurrent.CancellationException
	at java.util.concurrent.CompletableFuture.cancel(CompletableFuture.java:2510) ~[?:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$3(TemporalAttemptExecution.java:201) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?]
	at io.airbyte.workers.temporal.CancellationHandler$TemporalCancellationHandler.checkAndHandleCancellation(CancellationHandler.java:52) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$4(TemporalAttemptExecution.java:204) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:577) ~[?:?]
	at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:358) ~[?:?]
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) ~[?:?]
	... 3 more
2022-08-11 15:17:51 ERROR i.a.w.g.DefaultReplicationWorker(run):181 - Sync worker failed.
io.airbyte.workers.exception.WorkerException: Source process exit with code 143. This warning is normal if the job was cancelled.
	at io.airbyte.workers.internal.DefaultAirbyteSource.close(DefaultAirbyteSource.java:136) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:179) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:65) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?]
	at java.lang.Thread.run(Thread.java:1589) [?:?]
	Suppressed: io.airbyte.workers.exception.WorkerException: Destination process exit with code 1. This warning is normal if the job was cancelled.
		at io.airbyte.workers.internal.DefaultAirbyteDestination.close(DefaultAirbyteDestination.java:119) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?]
		at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:138) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?]
		at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:65) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.39.41-alpha.jar:?]
		at java.lang.Thread.run(Thread.java:1589) [?:?]
2022-08-11 15:17:51 INFO i.a.w.g.DefaultReplicationWorker(run):240 - sync summary: io.airbyte.config.ReplicationAttemptSummary@f744e9c[status=cancelled,recordsSynced=0,bytesSynced=0,startTime=1660231031139,endTime=1660231071284,totalStats=io.airbyte.config.SyncStats@7e1cf621[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[]]
2022-08-11 15:17:51 INFO i.a.w.g.DefaultReplicationWorker(run):269 - Source did not output any state messages
2022-08-11 15:17:51 WARN i.a.w.g.DefaultReplicationWorker(run):277 - State capture: No new state, falling back on input state: io.airbyte.config.State@762d6f67[state={}]