2023-01-19 10:38:29 INFO i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/102/0/logs.log
2023-01-19 10:38:29 INFO i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.26
2023-01-19 10:38:29 INFO i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2023-01-19 10:38:29 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):64 - Using default value for environment variable LOG_CONNECTOR_MESSAGES: 'false'
2023-01-19 10:38:29 INFO i.a.c.EnvConfigs(getEnvOrDefault):1161 - Using default value for environment variable METRIC_CLIENT: ''
2023-01-19 10:38:29 WARN i.a.m.l.MetricClientFactory(initialize):60 - Metric client is already initialized to 
2023-01-19 10:38:29 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):64 - Using default value for environment variable LOG_CONNECTOR_MESSAGES: 'false'
2023-01-19 10:38:29 INFO i.a.w.g.DefaultReplicationWorker(run):142 - start sync worker. job id: 102 attempt id: 0
2023-01-19 10:38:29 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-01-19 10:38:29 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- START REPLICATION -----
2023-01-19 10:38:29 INFO i.a.w.g.DefaultReplicationWorker(run):157 - configured sync modes: {null.GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL=full_refresh - overwrite}
2023-01-19 10:38:29 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-01-19 10:38:29 INFO i.a.w.i.DefaultAirbyteDestination(start):72 - Running destination...
2023-01-19 10:38:29 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):64 - Using default value for environment variable AUTO_DETECT_SCHEMA: 'false'
2023-01-19 10:38:29 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/destination-mysql:0.1.20 exists...
2023-01-19 10:38:29 INFO i.a.c.i.LineGobbler(voidCall):114 - airbyte/destination-mysql:0.1.20 was found locally.
2023-01-19 10:38:29 INFO i.a.w.p.DockerProcessFactory(create):120 - Creating docker container = destination-mysql-write-102-0-bciee with resources io.airbyte.config.ResourceRequirements@42aa7dc[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2023-01-19 10:38:29 INFO i.a.w.p.DockerProcessFactory(create):164 - Preparing command: docker run --rm --init -i -w /data/102/0 --log-driver none --name destination-mysql-write-102-0-bciee --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_CONNECTOR_IMAGE=airbyte/destination-mysql:0.1.20 -e WORKER_JOB_ATTEMPT=0 -e AUTO_DETECT_SCHEMA=false -e AIRBYTE_VERSION=0.40.26 -e WORKER_JOB_ID=102 airbyte/destination-mysql:0.1.20 write --config destination_config.json --catalog destination_catalog.json
2023-01-19 10:38:29 INFO i.a.w.i.VersionedAirbyteMessageBufferedWriterFactory(createWriter):33 - Writing messages to protocol version 0.2.0
2023-01-19 10:38:29 INFO i.a.w.i.VersionedAirbyteStreamFactory(create):97 - Reading messages from protocol version 0.2.0
2023-01-19 10:38:29 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):64 - Using default value for environment variable AUTO_DETECT_SCHEMA: 'false'
2023-01-19 10:38:29 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/source-amazon-seller-partner:0.2.30 exists...
2023-01-19 10:38:29 INFO i.a.w.p.DockerProcessFactory(create):120 - Creating docker container = source-amazon-seller-partner-read-102-0-xekuh with resources io.airbyte.config.ResourceRequirements@4b851ce0[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2023-01-19 10:38:29 INFO i.a.w.p.DockerProcessFactory(create):164 - Preparing command: docker run --rm --init -i -w /data/102/0 --log-driver none --name source-amazon-seller-partner-read-102-0-xekuh --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_CONNECTOR_IMAGE=airbyte/source-amazon-seller-partner:0.2.30 -e WORKER_JOB_ATTEMPT=0 -e AUTO_DETECT_SCHEMA=false -e AIRBYTE_VERSION=0.40.26 -e WORKER_JOB_ID=102 airbyte/source-amazon-seller-partner:0.2.30 read --config source_config.json --catalog source_catalog.json --state input_state.json
2023-01-19 10:38:29 INFO i.a.c.i.LineGobbler(voidCall):114 - airbyte/source-amazon-seller-partner:0.2.30 was found locally.
2023-01-19 10:38:29 INFO i.a.w.i.VersionedAirbyteStreamFactory(create):97 - Reading messages from protocol version 0.2.0
2023-01-19 10:38:29 INFO i.a.w.g.DefaultReplicationWorker(replicate):234 - Waiting for source and destination threads to complete.
2023-01-19 10:38:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):260 - Destination output thread started.
2023-01-19 10:38:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):310 - Replication thread started.
2023-01-19 10:38:30 source > Starting syncing SourceAmazonSellerPartner
2023-01-19 10:38:30 source > Syncing stream: GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL 
2023-01-19 10:38:31 destination > SLF4J: Class path contains multiple SLF4J bindings.
2023-01-19 10:38:31 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2023-01-19 10:38:31 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2023-01-19 10:38:31 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2023-01-19 10:38:31 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2023-01-19 10:38:31 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2023-01-19 10:38:32 destination > 2023-01-19 10:38:32 INFO i.a.i.d.m.MySQLDestination(main):136 - starting destination: class io.airbyte.integrations.destination.mysql.MySQLDestination
2023-01-19 10:38:32 destination > 2023-01-19 10:38:32 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2023-01-19 10:38:32 destination > 2023-01-19 10:38:32 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2023-01-19 10:38:32 destination > 2023-01-19 10:38:32 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: WRITE
2023-01-19 10:38:32 destination > 2023-01-19 10:38:32 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2023-01-19 10:38:32 destination > 2023-01-19 10:38:32 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-01-19 10:38:32 destination > 2023-01-19 10:38:32 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-01-19 10:38:32 destination > 2023-01-19 10:38:32 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-01-19 10:38:32 destination > 2023-01-19 10:38:32 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword multiline - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-01-19 10:38:32 destination > 2023-01-19 10:38:32 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL
2023-01-19 10:38:33 destination > 2023-01-19 10:38:33 INFO c.z.h.HikariDataSource(<init>):80 - HikariPool-1 - Starting...
2023-01-19 10:38:33 destination > 2023-01-19 10:38:33 INFO c.z.h.HikariDataSource(<init>):82 - HikariPool-1 - Start completed.
2023-01-19 10:38:33 destination > 2023-01-19 10:38:33 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):98 - Write config: WriteConfig{streamName=GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL, namespace=null, outputSchemaName=msz_prod, tmpTableName=_airbyte_tmp_tas_get___y_last_update_general, outputTableName=_airbyte_raw_get_flat__y_last_update_general, syncMode=overwrite}
2023-01-19 10:38:33 destination > 2023-01-19 10:38:33 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2023-01-19 10:38:33 destination > 2023-01-19 10:38:33 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):123 - Preparing tmp tables in destination started for 1 streams
2023-01-19 10:38:33 destination > 2023-01-19 10:38:33 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):127 - Preparing tmp table in destination started for stream GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL. schema: msz_prod, tmp table name: _airbyte_tmp_tas_get___y_last_update_general
2023-01-19 10:38:33 destination > 2023-01-19 10:38:33 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):133 - Preparing tables in destination completed.
2023-01-19 10:43:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 1000 (884 KB)
2023-01-19 10:43:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 2000 (1 MB)
2023-01-19 10:43:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 3000 (2 MB)
2023-01-19 10:43:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 4000 (3 MB)
2023-01-19 10:43:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 5000 (4 MB)
2023-01-19 10:43:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 6000 (5 MB)
2023-01-19 10:43:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 7000 (6 MB)
2023-01-19 10:43:05 destination > 2023-01-19 10:43:05 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7181 records (24 MB)
2023-01-19 10:43:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 8000 (6 MB)
2023-01-19 10:43:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 9000 (7 MB)
2023-01-19 10:43:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 10000 (8 MB)
2023-01-19 10:43:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 11000 (9 MB)
2023-01-19 10:43:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 12000 (10 MB)
2023-01-19 10:43:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 13000 (11 MB)
2023-01-19 10:43:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 14000 (12 MB)
2023-01-19 10:43:08 destination > 2023-01-19 10:43:08 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7172 records (24 MB)
2023-01-19 10:43:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 15000 (13 MB)
2023-01-19 10:43:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 16000 (13 MB)
2023-01-19 10:43:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 17000 (14 MB)
2023-01-19 10:43:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 18000 (15 MB)
2023-01-19 10:43:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 19000 (16 MB)
2023-01-19 10:43:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 20000 (17 MB)
2023-01-19 10:43:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 21000 (18 MB)
2023-01-19 10:43:10 destination > 2023-01-19 10:43:10 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7180 records (24 MB)
2023-01-19 10:43:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 22000 (19 MB)
2023-01-19 10:43:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 23000 (20 MB)
2023-01-19 10:43:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 24000 (20 MB)
2023-01-19 10:43:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 25000 (21 MB)
2023-01-19 10:43:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 26000 (22 MB)
2023-01-19 10:43:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 27000 (23 MB)
2023-01-19 10:43:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 28000 (24 MB)
2023-01-19 10:43:13 destination > 2023-01-19 10:43:13 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7188 records (24 MB)
2023-01-19 10:43:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 29000 (25 MB)
2023-01-19 10:43:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 30000 (26 MB)
2023-01-19 10:47:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 31000 (26 MB)
2023-01-19 10:47:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 32000 (27 MB)
2023-01-19 10:47:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 33000 (28 MB)
2023-01-19 10:47:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 34000 (29 MB)
2023-01-19 10:47:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 35000 (30 MB)
2023-01-19 10:47:46 destination > 2023-01-19 10:47:46 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7206 records (24 MB)
2023-01-19 10:47:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 36000 (31 MB)
2023-01-19 10:47:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 37000 (32 MB)
2023-01-19 10:47:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 38000 (33 MB)
2023-01-19 10:47:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 39000 (33 MB)
2023-01-19 10:47:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 40000 (34 MB)
2023-01-19 10:47:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 41000 (35 MB)
2023-01-19 10:47:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 42000 (36 MB)
2023-01-19 10:47:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 43000 (37 MB)
2023-01-19 10:47:49 destination > 2023-01-19 10:47:49 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7180 records (24 MB)
2023-01-19 10:47:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 44000 (38 MB)
2023-01-19 10:47:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 45000 (39 MB)
2023-01-19 10:47:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 46000 (40 MB)
2023-01-19 10:47:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 47000 (40 MB)
2023-01-19 10:47:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 48000 (41 MB)
2023-01-19 10:47:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 49000 (42 MB)
2023-01-19 10:47:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 50000 (43 MB)
2023-01-19 10:47:51 destination > 2023-01-19 10:47:51 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7172 records (24 MB)
2023-01-19 10:47:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 51000 (44 MB)
2023-01-19 10:47:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 52000 (45 MB)
2023-01-19 10:47:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 53000 (46 MB)
2023-01-19 10:47:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 54000 (47 MB)
2023-01-19 10:47:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 55000 (47 MB)
2023-01-19 10:47:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 56000 (48 MB)
2023-01-19 10:47:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 57000 (49 MB)
2023-01-19 10:47:53 destination > 2023-01-19 10:47:53 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7163 records (24 MB)
2023-01-19 10:47:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 58000 (50 MB)
2023-01-19 10:47:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 59000 (51 MB)
2023-01-19 10:47:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 60000 (52 MB)
2023-01-19 10:47:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 61000 (53 MB)
2023-01-19 10:47:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 62000 (53 MB)
2023-01-19 10:47:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 63000 (54 MB)
2023-01-19 10:47:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 64000 (55 MB)
2023-01-19 10:47:55 destination > 2023-01-19 10:47:55 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7164 records (24 MB)
2023-01-19 10:47:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 65000 (56 MB)
2023-01-19 10:47:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 66000 (57 MB)
2023-01-19 10:53:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 67000 (58 MB)
2023-01-19 10:53:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 68000 (59 MB)
2023-01-19 10:53:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 69000 (60 MB)
2023-01-19 10:53:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 70000 (60 MB)
2023-01-19 10:53:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 71000 (61 MB)
2023-01-19 10:53:29 destination > 2023-01-19 10:53:29 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7231 records (24 MB)
2023-01-19 10:53:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 72000 (62 MB)
2023-01-19 10:53:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 73000 (63 MB)
2023-01-19 10:53:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 74000 (64 MB)
2023-01-19 10:53:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 75000 (65 MB)
2023-01-19 10:53:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 76000 (66 MB)
2023-01-19 10:53:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 77000 (67 MB)
2023-01-19 10:53:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 78000 (67 MB)
2023-01-19 10:53:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 79000 (68 MB)
2023-01-19 10:53:32 destination > 2023-01-19 10:53:32 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7167 records (24 MB)
2023-01-19 10:53:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 80000 (69 MB)
2023-01-19 10:53:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 81000 (70 MB)
2023-01-19 10:53:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 82000 (71 MB)
2023-01-19 10:53:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 83000 (72 MB)
2023-01-19 10:53:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 84000 (73 MB)
2023-01-19 10:53:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 85000 (73 MB)
2023-01-19 10:53:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 86000 (74 MB)
2023-01-19 10:53:34 destination > 2023-01-19 10:53:34 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7148 records (24 MB)
2023-01-19 10:53:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 87000 (75 MB)
2023-01-19 10:53:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 88000 (76 MB)
2023-01-19 10:53:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 89000 (77 MB)
2023-01-19 10:53:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 90000 (78 MB)
2023-01-19 10:53:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 91000 (79 MB)
2023-01-19 10:53:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 92000 (80 MB)
2023-01-19 10:53:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 93000 (80 MB)
2023-01-19 10:53:36 destination > 2023-01-19 10:53:36 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7179 records (24 MB)
2023-01-19 10:53:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 94000 (81 MB)
2023-01-19 10:53:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 95000 (82 MB)
2023-01-19 10:53:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 96000 (83 MB)
2023-01-19 10:53:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 97000 (84 MB)
2023-01-19 10:53:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 98000 (85 MB)
2023-01-19 10:53:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 99000 (86 MB)
2023-01-19 10:53:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 100000 (87 MB)
2023-01-19 10:53:38 destination > 2023-01-19 10:53:38 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7170 records (24 MB)
2023-01-19 10:53:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 101000 (87 MB)
2023-01-19 10:53:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 102000 (88 MB)
2023-01-19 10:53:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 103000 (89 MB)
2023-01-19 10:53:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 104000 (90 MB)
2023-01-19 10:53:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 105000 (91 MB)
2023-01-19 10:53:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 106000 (92 MB)
2023-01-19 10:53:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 107000 (93 MB)
2023-01-19 10:53:43 destination > 2023-01-19 10:53:43 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7182 records (24 MB)
2023-01-19 10:53:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 108000 (94 MB)
2023-01-19 10:53:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 109000 (94 MB)
2023-01-19 10:53:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 110000 (95 MB)
2023-01-19 10:53:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 111000 (96 MB)
2023-01-19 10:58:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 112000 (97 MB)
2023-01-19 10:58:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 113000 (98 MB)
2023-01-19 10:58:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 114000 (99 MB)
2023-01-19 10:58:49 destination > 2023-01-19 10:58:49 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7250 records (24 MB)
2023-01-19 10:58:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 115000 (100 MB)
2023-01-19 10:58:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 116000 (100 MB)
2023-01-19 10:58:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 117000 (101 MB)
2023-01-19 10:58:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 118000 (102 MB)
2023-01-19 10:58:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 119000 (103 MB)
2023-01-19 10:58:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 120000 (104 MB)
2023-01-19 10:58:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 121000 (105 MB)
2023-01-19 10:58:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 122000 (106 MB)
2023-01-19 10:58:52 destination > 2023-01-19 10:58:52 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7178 records (24 MB)
2023-01-19 10:58:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 123000 (107 MB)
2023-01-19 10:58:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 124000 (107 MB)
2023-01-19 10:58:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 125000 (108 MB)
2023-01-19 10:58:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 126000 (109 MB)
2023-01-19 10:58:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 127000 (110 MB)
2023-01-19 10:58:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 128000 (111 MB)
2023-01-19 10:58:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 129000 (112 MB)
2023-01-19 10:58:55 destination > 2023-01-19 10:58:55 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7168 records (24 MB)
2023-01-19 10:58:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 130000 (113 MB)
2023-01-19 10:58:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 131000 (114 MB)
2023-01-19 10:58:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 132000 (114 MB)
2023-01-19 10:58:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 133000 (115 MB)
2023-01-19 10:58:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 134000 (116 MB)
2023-01-19 10:58:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 135000 (117 MB)
2023-01-19 10:58:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 136000 (118 MB)
2023-01-19 10:58:58 destination > 2023-01-19 10:58:58 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7184 records (24 MB)
2023-01-19 10:59:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 137000 (119 MB)
2023-01-19 10:59:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 138000 (120 MB)
2023-01-19 10:59:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 139000 (121 MB)
2023-01-19 10:59:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 140000 (121 MB)
2023-01-19 10:59:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 141000 (122 MB)
2023-01-19 10:59:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 142000 (123 MB)
2023-01-19 10:59:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 143000 (124 MB)
2023-01-19 10:59:01 destination > 2023-01-19 10:59:01 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7184 records (24 MB)
2023-01-19 10:59:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 144000 (125 MB)
2023-01-19 10:59:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 145000 (126 MB)
2023-01-19 10:59:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 146000 (127 MB)
2023-01-19 10:59:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 147000 (127 MB)
2023-01-19 10:59:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 148000 (128 MB)
2023-01-19 10:59:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 149000 (129 MB)
2023-01-19 11:05:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 150000 (130 MB)
2023-01-19 11:05:06 destination > 2023-01-19 11:05:06 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7223 records (24 MB)
2023-01-19 11:05:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 151000 (131 MB)
2023-01-19 11:05:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 152000 (132 MB)
2023-01-19 11:05:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 153000 (133 MB)
2023-01-19 11:05:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 154000 (134 MB)
2023-01-19 11:05:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 155000 (134 MB)
2023-01-19 11:05:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 156000 (135 MB)
2023-01-19 11:05:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 157000 (136 MB)
2023-01-19 11:05:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 158000 (137 MB)
2023-01-19 11:05:09 destination > 2023-01-19 11:05:09 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7200 records (24 MB)
2023-01-19 11:05:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 159000 (138 MB)
2023-01-19 11:05:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 160000 (139 MB)
2023-01-19 11:05:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 161000 (140 MB)
2023-01-19 11:05:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 162000 (140 MB)
2023-01-19 11:05:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 163000 (141 MB)
2023-01-19 11:05:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 164000 (142 MB)
2023-01-19 11:05:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 165000 (143 MB)
2023-01-19 11:05:11 destination > 2023-01-19 11:05:11 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7149 records (24 MB)
2023-01-19 11:05:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 166000 (144 MB)
2023-01-19 11:05:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 167000 (145 MB)
2023-01-19 11:05:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 168000 (146 MB)
2023-01-19 11:05:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 169000 (147 MB)
2023-01-19 11:05:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 170000 (147 MB)
2023-01-19 11:05:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 171000 (148 MB)
2023-01-19 11:05:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 172000 (149 MB)
2023-01-19 11:05:14 destination > 2023-01-19 11:05:14 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7157 records (24 MB)
2023-01-19 11:05:15 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 173000 (150 MB)
2023-01-19 11:05:15 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 174000 (151 MB)
2023-01-19 11:05:16 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 175000 (152 MB)
2023-01-19 11:05:16 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 176000 (153 MB)
2023-01-19 11:05:16 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 177000 (154 MB)
2023-01-19 11:05:16 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 178000 (154 MB)
2023-01-19 11:05:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 179000 (155 MB)
2023-01-19 11:05:17 destination > 2023-01-19 11:05:17 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7162 records (24 MB)
2023-01-19 11:05:18 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 180000 (156 MB)
2023-01-19 11:05:18 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 181000 (157 MB)
2023-01-19 11:05:18 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 182000 (158 MB)
2023-01-19 11:05:19 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 183000 (159 MB)
2023-01-19 11:05:19 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 184000 (160 MB)
2023-01-19 11:05:19 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 185000 (161 MB)
2023-01-19 11:05:19 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 186000 (161 MB)
2023-01-19 11:05:20 destination > 2023-01-19 11:05:20 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7140 records (24 MB)
2023-01-19 11:05:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 187000 (162 MB)
2023-01-19 11:05:21 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 188000 (163 MB)
2023-01-19 11:05:21 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 189000 (164 MB)
2023-01-19 11:05:21 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 190000 (165 MB)
2023-01-19 11:05:22 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 191000 (166 MB)
2023-01-19 11:05:22 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 192000 (167 MB)
2023-01-19 11:05:22 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 193000 (168 MB)
2023-01-19 11:05:23 destination > 2023-01-19 11:05:23 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7195 records (24 MB)
2023-01-19 11:05:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 194000 (168 MB)
2023-01-19 11:11:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 195000 (169 MB)
2023-01-19 11:11:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 196000 (170 MB)
2023-01-19 11:11:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 197000 (171 MB)
2023-01-19 11:11:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 198000 (172 MB)
2023-01-19 11:11:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 199000 (173 MB)
2023-01-19 11:11:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 200000 (174 MB)
2023-01-19 11:11:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 201000 (174 MB)
2023-01-19 11:11:57 destination > 2023-01-19 11:11:57 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7203 records (24 MB)
2023-01-19 11:11:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 202000 (175 MB)
2023-01-19 11:11:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 203000 (176 MB)
2023-01-19 11:11:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 204000 (177 MB)
2023-01-19 11:11:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 205000 (178 MB)
2023-01-19 11:11:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 206000 (179 MB)
2023-01-19 11:11:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 207000 (180 MB)
2023-01-19 11:12:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 208000 (181 MB)
2023-01-19 11:12:00 destination > 2023-01-19 11:12:00 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7163 records (24 MB)
2023-01-19 11:12:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 209000 (181 MB)
2023-01-19 11:12:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 210000 (182 MB)
2023-01-19 11:12:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 211000 (183 MB)
2023-01-19 11:12:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 212000 (184 MB)
2023-01-19 11:12:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 213000 (185 MB)
2023-01-19 11:12:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 214000 (186 MB)
2023-01-19 11:12:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 215000 (187 MB)
2023-01-19 11:12:03 destination > 2023-01-19 11:12:03 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7153 records (24 MB)
2023-01-19 11:12:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 216000 (188 MB)
2023-01-19 11:12:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 217000 (188 MB)
2023-01-19 11:12:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 218000 (189 MB)
2023-01-19 11:12:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 219000 (190 MB)
2023-01-19 11:12:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 220000 (191 MB)
2023-01-19 11:12:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 221000 (192 MB)
2023-01-19 11:12:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 222000 (193 MB)
2023-01-19 11:12:07 destination > 2023-01-19 11:12:07 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7139 records (24 MB)
2023-01-19 11:12:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 223000 (194 MB)
2023-01-19 11:12:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 224000 (195 MB)
2023-01-19 11:12:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 225000 (195 MB)
2023-01-19 11:12:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 226000 (196 MB)
2023-01-19 11:12:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 227000 (197 MB)
2023-01-19 11:12:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 228000 (198 MB)
2023-01-19 11:12:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 229000 (199 MB)
2023-01-19 11:12:11 destination > 2023-01-19 11:12:11 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7170 records (24 MB)
2023-01-19 11:12:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 230000 (200 MB)
2023-01-19 11:12:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 231000 (201 MB)
2023-01-19 11:12:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 232000 (202 MB)
2023-01-19 11:12:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 233000 (202 MB)
2023-01-19 11:12:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 234000 (203 MB)
2023-01-19 11:12:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 235000 (204 MB)
2023-01-19 11:12:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 236000 (205 MB)
2023-01-19 11:12:14 destination > 2023-01-19 11:12:14 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7199 records (24 MB)
2023-01-19 11:12:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 237000 (206 MB)
2023-01-19 11:12:16 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 238000 (207 MB)
2023-01-19 11:18:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 239000 (208 MB)
2023-01-19 11:18:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 240000 (208 MB)
2023-01-19 11:18:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 241000 (209 MB)
2023-01-19 11:18:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 242000 (210 MB)
2023-01-19 11:18:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 243000 (211 MB)
2023-01-19 11:18:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 244000 (212 MB)
2023-01-19 11:18:48 destination > 2023-01-19 11:18:48 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7232 records (24 MB)
2023-01-19 11:18:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 245000 (213 MB)
2023-01-19 11:18:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 246000 (214 MB)
2023-01-19 11:18:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 247000 (215 MB)
2023-01-19 11:18:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 248000 (215 MB)
2023-01-19 11:19:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 249000 (216 MB)
2023-01-19 11:19:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 250000 (217 MB)
2023-01-19 11:19:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 251000 (218 MB)
2023-01-19 11:19:00 destination > 2023-01-19 11:19:00 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7139 records (24 MB)
2023-01-19 11:19:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 252000 (219 MB)
2023-01-19 11:19:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 253000 (220 MB)
2023-01-19 11:19:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 254000 (221 MB)
2023-01-19 11:19:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 255000 (222 MB)
2023-01-19 11:19:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 256000 (222 MB)
2023-01-19 11:19:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 257000 (223 MB)
2023-01-19 11:19:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 258000 (224 MB)
2023-01-19 11:19:04 destination > 2023-01-19 11:19:04 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7176 records (24 MB)
2023-01-19 11:19:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 259000 (225 MB)
2023-01-19 11:19:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 260000 (226 MB)
2023-01-19 11:19:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 261000 (227 MB)
2023-01-19 11:19:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 262000 (228 MB)
2023-01-19 11:19:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 263000 (229 MB)
2023-01-19 11:19:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 264000 (229 MB)
2023-01-19 11:19:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 265000 (230 MB)
2023-01-19 11:19:08 destination > 2023-01-19 11:19:08 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7160 records (24 MB)
2023-01-19 11:19:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 266000 (231 MB)
2023-01-19 11:19:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 267000 (232 MB)
2023-01-19 11:19:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 268000 (233 MB)
2023-01-19 11:19:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 269000 (234 MB)
2023-01-19 11:19:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 270000 (235 MB)
2023-01-19 11:19:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 271000 (236 MB)
2023-01-19 11:19:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 272000 (236 MB)
2023-01-19 11:19:12 destination > 2023-01-19 11:19:12 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7204 records (24 MB)
2023-01-19 11:19:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 273000 (237 MB)
2023-01-19 11:19:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 274000 (238 MB)
2023-01-19 11:19:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 275000 (239 MB)
2023-01-19 11:19:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 276000 (240 MB)
2023-01-19 11:19:15 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 277000 (241 MB)
2023-01-19 11:19:15 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 278000 (242 MB)
2023-01-19 11:19:15 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 279000 (242 MB)
2023-01-19 11:19:16 destination > 2023-01-19 11:19:16 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7166 records (24 MB)
2023-01-19 11:19:16 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 280000 (243 MB)
2023-01-19 11:19:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 281000 (244 MB)
2023-01-19 11:19:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 282000 (245 MB)
2023-01-19 11:19:21 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 283000 (246 MB)
2023-01-19 11:19:21 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 284000 (247 MB)
2023-01-19 11:19:21 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 285000 (248 MB)
2023-01-19 11:19:21 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 286000 (249 MB)
2023-01-19 11:19:22 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 287000 (249 MB)
2023-01-19 11:19:22 destination > 2023-01-19 11:19:22 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7178 records (24 MB)
2023-01-19 11:19:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 288000 (250 MB)
2023-01-19 11:19:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 289000 (251 MB)
2023-01-19 11:19:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 290000 (252 MB)
2023-01-19 11:19:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 291000 (253 MB)
2023-01-19 11:26:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 292000 (254 MB)
2023-01-19 11:26:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 293000 (255 MB)
2023-01-19 11:26:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 294000 (255 MB)
2023-01-19 11:26:00 destination > 2023-01-19 11:26:00 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7245 records (24 MB)
2023-01-19 11:26:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 295000 (256 MB)
2023-01-19 11:26:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 296000 (257 MB)
2023-01-19 11:26:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 297000 (258 MB)
2023-01-19 11:26:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 298000 (259 MB)
2023-01-19 11:26:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 299000 (260 MB)
2023-01-19 11:26:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 300000 (261 MB)
2023-01-19 11:26:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 301000 (262 MB)
2023-01-19 11:26:04 destination > 2023-01-19 11:26:04 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7151 records (24 MB)
2023-01-19 11:26:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 302000 (262 MB)
2023-01-19 11:26:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 303000 (263 MB)
2023-01-19 11:26:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 304000 (264 MB)
2023-01-19 11:26:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 305000 (265 MB)
2023-01-19 11:26:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 306000 (266 MB)
2023-01-19 11:26:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 307000 (267 MB)
2023-01-19 11:26:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 308000 (268 MB)
2023-01-19 11:26:07 destination > 2023-01-19 11:26:07 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7142 records (24 MB)
2023-01-19 11:26:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 309000 (269 MB)
2023-01-19 11:26:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 310000 (269 MB)
2023-01-19 11:26:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 311000 (270 MB)
2023-01-19 11:26:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 312000 (271 MB)
2023-01-19 11:26:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 313000 (272 MB)
2023-01-19 11:26:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 314000 (273 MB)
2023-01-19 11:26:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 315000 (274 MB)
2023-01-19 11:26:10 destination > 2023-01-19 11:26:10 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7166 records (24 MB)
2023-01-19 11:26:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 316000 (275 MB)
2023-01-19 11:26:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 317000 (276 MB)
2023-01-19 11:26:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 318000 (276 MB)
2023-01-19 11:26:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 319000 (277 MB)
2023-01-19 11:26:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 320000 (278 MB)
2023-01-19 11:26:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 321000 (279 MB)
2023-01-19 11:26:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 322000 (280 MB)
2023-01-19 11:26:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 323000 (281 MB)
2023-01-19 11:26:14 destination > 2023-01-19 11:26:14 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7165 records (24 MB)
2023-01-19 11:26:16 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 324000 (282 MB)
2023-01-19 11:26:16 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 325000 (283 MB)
2023-01-19 11:26:16 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 326000 (283 MB)
2023-01-19 11:26:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 327000 (284 MB)
2023-01-19 11:26:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 328000 (285 MB)
2023-01-19 11:26:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 329000 (286 MB)
2023-01-19 11:26:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 330000 (287 MB)
2023-01-19 11:26:18 destination > 2023-01-19 11:26:18 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7141 records (24 MB)
2023-01-19 11:26:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 331000 (288 MB)
2023-01-19 11:26:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 332000 (289 MB)
2023-01-19 11:26:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 333000 (290 MB)
2023-01-19 11:26:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 334000 (290 MB)
2023-01-19 11:26:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 335000 (291 MB)
2023-01-19 11:26:21 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 336000 (292 MB)
2023-01-19 11:26:21 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 337000 (293 MB)
2023-01-19 11:26:21 destination > 2023-01-19 11:26:21 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7139 records (24 MB)
2023-01-19 11:26:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 338000 (294 MB)
2023-01-19 11:26:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 339000 (295 MB)
2023-01-19 11:26:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 340000 (296 MB)
2023-01-19 11:26:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 341000 (297 MB)
2023-01-19 11:26:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 342000 (297 MB)
2023-01-19 11:26:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 343000 (298 MB)
2023-01-19 11:26:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 344000 (299 MB)
2023-01-19 11:26:27 destination > 2023-01-19 11:26:27 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7171 records (24 MB)
2023-01-19 11:26:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 345000 (300 MB)
2023-01-19 11:32:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 346000 (301 MB)
2023-01-19 11:32:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 347000 (302 MB)
2023-01-19 11:32:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 348000 (303 MB)
2023-01-19 11:32:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 349000 (303 MB)
2023-01-19 11:32:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 350000 (304 MB)
2023-01-19 11:32:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 351000 (305 MB)
2023-01-19 11:32:02 destination > 2023-01-19 11:32:02 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7173 records (24 MB)
2023-01-19 11:32:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 352000 (306 MB)
2023-01-19 11:32:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 353000 (307 MB)
2023-01-19 11:32:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 354000 (308 MB)
2023-01-19 11:32:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 355000 (309 MB)
2023-01-19 11:32:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 356000 (310 MB)
2023-01-19 11:32:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 357000 (311 MB)
2023-01-19 11:32:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 358000 (311 MB)
2023-01-19 11:32:04 destination > 2023-01-19 11:32:04 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7117 records (24 MB)
2023-01-19 11:32:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 359000 (312 MB)
2023-01-19 11:32:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 360000 (313 MB)
2023-01-19 11:32:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 361000 (314 MB)
2023-01-19 11:32:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 362000 (315 MB)
2023-01-19 11:32:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 363000 (316 MB)
2023-01-19 11:32:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 364000 (317 MB)
2023-01-19 11:32:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 365000 (318 MB)
2023-01-19 11:32:08 destination > 2023-01-19 11:32:08 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7124 records (24 MB)
2023-01-19 11:32:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 366000 (318 MB)
2023-01-19 11:32:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 367000 (319 MB)
2023-01-19 11:32:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 368000 (320 MB)
2023-01-19 11:32:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 369000 (321 MB)
2023-01-19 11:32:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 370000 (322 MB)
2023-01-19 11:32:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 371000 (323 MB)
2023-01-19 11:32:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 372000 (324 MB)
2023-01-19 11:32:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 373000 (325 MB)
2023-01-19 11:32:11 destination > 2023-01-19 11:32:11 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7113 records (24 MB)
2023-01-19 11:32:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 374000 (325 MB)
2023-01-19 11:32:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 375000 (326 MB)
2023-01-19 11:32:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 376000 (327 MB)
2023-01-19 11:32:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 377000 (328 MB)
2023-01-19 11:32:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 378000 (329 MB)
2023-01-19 11:32:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 379000 (330 MB)
2023-01-19 11:32:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 380000 (331 MB)
2023-01-19 11:32:14 destination > 2023-01-19 11:32:14 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7106 records (24 MB)
2023-01-19 11:32:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 381000 (332 MB)
2023-01-19 11:32:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 382000 (332 MB)
2023-01-19 11:32:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 383000 (333 MB)
2023-01-19 11:32:18 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 384000 (334 MB)
2023-01-19 11:32:18 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 385000 (335 MB)
2023-01-19 11:32:18 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 386000 (336 MB)
2023-01-19 11:32:18 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 387000 (337 MB)
2023-01-19 11:32:19 destination > 2023-01-19 11:32:19 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7101 records (24 MB)
2023-01-19 11:32:21 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 388000 (338 MB)
2023-01-19 11:32:21 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 389000 (339 MB)
2023-01-19 11:37:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 390000 (339 MB)
2023-01-19 11:37:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 391000 (340 MB)
2023-01-19 11:37:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 392000 (341 MB)
2023-01-19 11:37:24 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 393000 (342 MB)
2023-01-19 11:37:24 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 394000 (343 MB)
2023-01-19 11:37:24 destination > 2023-01-19 11:37:24 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7201 records (24 MB)
2023-01-19 11:37:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 395000 (344 MB)
2023-01-19 11:37:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 396000 (345 MB)
2023-01-19 11:37:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 397000 (346 MB)
2023-01-19 11:37:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 398000 (346 MB)
2023-01-19 11:37:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 399000 (347 MB)
2023-01-19 11:37:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 400000 (348 MB)
2023-01-19 11:37:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 401000 (349 MB)
2023-01-19 11:37:27 destination > 2023-01-19 11:37:27 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7090 records (24 MB)
2023-01-19 11:37:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 402000 (350 MB)
2023-01-19 11:37:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 403000 (351 MB)
2023-01-19 11:37:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 404000 (352 MB)
2023-01-19 11:37:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 405000 (353 MB)
2023-01-19 11:37:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 406000 (353 MB)
2023-01-19 11:37:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 407000 (354 MB)
2023-01-19 11:37:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 408000 (355 MB)
2023-01-19 11:37:30 destination > 2023-01-19 11:37:30 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7081 records (24 MB)
2023-01-19 11:37:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 409000 (356 MB)
2023-01-19 11:37:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 410000 (357 MB)
2023-01-19 11:37:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 411000 (358 MB)
2023-01-19 11:37:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 412000 (359 MB)
2023-01-19 11:37:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 413000 (360 MB)
2023-01-19 11:37:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 414000 (360 MB)
2023-01-19 11:37:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 415000 (361 MB)
2023-01-19 11:37:33 destination > 2023-01-19 11:37:33 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7130 records (24 MB)
2023-01-19 11:37:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 416000 (362 MB)
2023-01-19 11:37:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 417000 (363 MB)
2023-01-19 11:37:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 418000 (364 MB)
2023-01-19 11:37:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 419000 (365 MB)
2023-01-19 11:37:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 420000 (366 MB)
2023-01-19 11:37:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 421000 (367 MB)
2023-01-19 11:37:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 422000 (367 MB)
2023-01-19 11:37:36 destination > 2023-01-19 11:37:36 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 7138 records (24 MB)
2023-01-19 11:37:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 423000 (368 MB)
2023-01-19 11:37:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 424000 (369 MB)
2023-01-19 11:37:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 425000 (370 MB)
2023-01-19 11:37:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 426000 (371 MB)
2023-01-19 11:37:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):347 - Records read: 427000 (372 MB)
2023-01-19 11:38:40 source > Encountered an exception while reading stream GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL
Traceback (most recent call last):
  File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 111, in read
    yield from self._read_stream(
  File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 180, in _read_stream
    for record in record_iterator:
  File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 290, in _read_full_refresh
    for record_data_or_message in record_data_or_messages:
  File "/airbyte/integration_code/source_amazon_seller_partner/streams.py", line 340, in read_records
    report_payload = self._retrieve_report(report_id=report_id)
  File "/airbyte/integration_code/source_amazon_seller_partner/streams.py", line 287, in _retrieve_report
    retrieve_report_response = self._send_request(retrieve_report_request)
  File "/usr/local/lib/python3.9/site-packages/backoff/_sync.py", line 105, in retry
    ret = target(*args, **kwargs)
  File "/airbyte/integration_code/source_amazon_seller_partner/streams.py", line 215, in _send_request
    response.raise_for_status()
  File "/usr/local/lib/python3.9/site-packages/requests/models.py", line 1021, in raise_for_status
    raise HTTPError(http_error_msg, response=self)
requests.exceptions.HTTPError: 403 Client Error: Forbidden for url: https://sellingpartnerapi-eu.amazon.com/reports/2021-06-30/reports/4240572019376
2023-01-19 11:38:40 source > Finished syncing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL
2023-01-19 11:38:40 source > SourceAmazonSellerPartner runtimes:
Syncing stream GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL 1:00:09.725887
2023-01-19 11:38:40 source > 403 Client Error: Forbidden for url: https://sellingpartnerapi-eu.amazon.com/reports/2021-06-30/reports/4240572019376
Traceback (most recent call last):
  File "/airbyte/integration_code/main.py", line 13, in <module>
    launch(source, sys.argv[1:])
  File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/entrypoint.py", line 131, in launch
    for message in source_entrypoint.run(parsed_args):
  File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/entrypoint.py", line 122, in run
    for message in generator:
  File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 125, in read
    raise e
  File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 111, in read
    yield from self._read_stream(
  File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 180, in _read_stream
    for record in record_iterator:
  File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 290, in _read_full_refresh
    for record_data_or_message in record_data_or_messages:
  File "/airbyte/integration_code/source_amazon_seller_partner/streams.py", line 340, in read_records
    report_payload = self._retrieve_report(report_id=report_id)
  File "/airbyte/integration_code/source_amazon_seller_partner/streams.py", line 287, in _retrieve_report
    retrieve_report_response = self._send_request(retrieve_report_request)
  File "/usr/local/lib/python3.9/site-packages/backoff/_sync.py", line 105, in retry
    ret = target(*args, **kwargs)
  File "/airbyte/integration_code/source_amazon_seller_partner/streams.py", line 215, in _send_request
    response.raise_for_status()
  File "/usr/local/lib/python3.9/site-packages/requests/models.py", line 1021, in raise_for_status
    raise HTTPError(http_error_msg, response=self)
requests.exceptions.HTTPError: 403 Client Error: Forbidden for url: https://sellingpartnerapi-eu.amazon.com/reports/2021-06-30/reports/4240572019376
2023-01-19 11:38:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):350 - Source has no more messages, closing connection.
2023-01-19 11:38:41 destination > 2023-01-19 11:38:41 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded.
2023-01-19 11:38:41 destination > 2023-01-19 11:38:41 INFO i.a.i.d.b.BufferedStreamConsumer(close):171 - executing on success close procedure.
2023-01-19 11:38:41 destination > 2023-01-19 11:38:41 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL: 4626 records (16 MB)
2023-01-19 11:38:42 destination > 2023-01-19 11:38:42 INFO i.a.i.d.j.SqlOperations(onDestinationCloseOperations):138 - No onDestinationCloseOperations required for this destination.
2023-01-19 11:38:42 destination > 2023-01-19 11:38:42 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):163 - Finalizing tables in destination started for 1 streams
2023-01-19 11:38:42 destination > 2023-01-19 11:38:42 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):168 - Finalizing stream GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL. schema msz_prod, tmp table _airbyte_tmp_tas_get___y_last_update_general, final table _airbyte_raw_get_flat__y_last_update_general
2023-01-19 11:38:42 destination > 2023-01-19 11:38:42 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):181 - Executing finalization of tables.
2023-01-19 11:38:57 destination > 2023-01-19 11:38:57 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):183 - Finalizing tables in destination completed.
2023-01-19 11:38:57 destination > 2023-01-19 11:38:57 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):186 - Cleaning tmp tables in destination started for 1 streams
2023-01-19 11:38:57 destination > 2023-01-19 11:38:57 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):190 - Cleaning tmp table in destination started for stream GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL. schema msz_prod, tmp table name: _airbyte_tmp_tas_get___y_last_update_general
2023-01-19 11:38:59 destination > 2023-01-19 11:38:59 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):195 - Cleaning tmp tables in destination completed.
2023-01-19 11:38:59 destination > 2023-01-19 11:38:59 INFO i.a.i.b.IntegrationRunner(runInternal):171 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2023-01-19 11:38:59 destination > 2023-01-19 11:38:59 INFO i.a.i.d.m.MySQLDestination(main):138 - completed destination: class io.airbyte.integrations.destination.mysql.MySQLDestination
2023-01-19 11:39:00 ERROR i.a.w.g.DefaultReplicationWorker(replicate):246 - Sync worker failed.
java.util.concurrent.ExecutionException: io.airbyte.workers.general.DefaultReplicationWorker$SourceException: Source cannot be stopped!
	at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) ~[?:?]
	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) ~[?:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.replicate(DefaultReplicationWorker.java:238) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:164) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:84) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$5(TemporalAttemptExecution.java:195) ~[io.airbyte-airbyte-workers-0.40.26.jar:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
	Suppressed: io.airbyte.workers.exception.WorkerException: Source process exit with code 1. This warning is normal if the job was cancelled.
		at io.airbyte.workers.internal.DefaultAirbyteSource.close(DefaultAirbyteSource.java:144) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
		at io.airbyte.workers.general.DefaultReplicationWorker.replicate(DefaultReplicationWorker.java:185) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
		at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:164) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
		at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:84) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$5(TemporalAttemptExecution.java:195) ~[io.airbyte-airbyte-workers-0.40.26.jar:?]
		at java.lang.Thread.run(Thread.java:1589) ~[?:?]
Caused by: io.airbyte.workers.general.DefaultReplicationWorker$SourceException: Source cannot be stopped!
	at io.airbyte.workers.general.DefaultReplicationWorker.lambda$readFromSrcAndWriteToDstRunnable$6(DefaultReplicationWorker.java:354) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
	at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?]
	... 1 more
Caused by: io.airbyte.workers.exception.WorkerException: Source process exit with code 1. This warning is normal if the job was cancelled.
	at io.airbyte.workers.internal.DefaultAirbyteSource.close(DefaultAirbyteSource.java:144) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.lambda$readFromSrcAndWriteToDstRunnable$6(DefaultReplicationWorker.java:352) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
	at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?]
	... 1 more
2023-01-19 11:39:00 INFO i.a.w.g.DefaultReplicationWorker(prepStateForLaterSaving):503 - Source did not output any state messages
2023-01-19 11:39:00 WARN i.a.w.g.DefaultReplicationWorker(prepStateForLaterSaving):511 - State capture: No new state, falling back on input state: io.airbyte.config.State@3b4f204b[state={}]
2023-01-19 11:39:00 INFO i.a.w.g.DefaultReplicationWorker(getReplicationOutput):434 - sync summary: {
  "status" : "failed",
  "recordsSynced" : 427475,
  "bytesSynced" : 390843256,
  "startTime" : 1674124709677,
  "endTime" : 1674128340181,
  "totalStats" : {
    "recordsEmitted" : 427475,
    "bytesEmitted" : 390843256,
    "sourceStateMessagesEmitted" : 0,
    "destinationStateMessagesEmitted" : 0,
    "recordsCommitted" : 0,
    "meanSecondsBeforeSourceStateMessageEmitted" : 0,
    "maxSecondsBeforeSourceStateMessageEmitted" : 0,
    "maxSecondsBetweenStateMessageEmittedandCommitted" : 0,
    "meanSecondsBetweenStateMessageEmittedandCommitted" : 0,
    "replicationStartTime" : 1674124709677,
    "replicationEndTime" : 1674128340181,
    "sourceReadStartTime" : 1674124709709,
    "sourceReadEndTime" : 0,
    "destinationWriteStartTime" : 1674124709746,
    "destinationWriteEndTime" : 1674128340181
  },
  "streamStats" : [ {
    "streamName" : "GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL",
    "stats" : {
      "recordsEmitted" : 427475,
      "bytesEmitted" : 390843256
    }
  } ]
}
2023-01-19 11:39:00 INFO i.a.w.g.DefaultReplicationWorker(getReplicationOutput):435 - failures: [ {
  "failureOrigin" : "source",
  "failureType" : "system_error",
  "internalMessage" : "403 Client Error: Forbidden for url: https://sellingpartnerapi-eu.amazon.com/reports/2021-06-30/reports/4240572019376",
  "externalMessage" : "Something went wrong in the connector. See the logs for more details.",
  "metadata" : {
    "attemptNumber" : 0,
    "jobId" : 102,
    "from_trace_message" : true,
    "connector_command" : "read"
  },
  "stacktrace" : "Traceback (most recent call last):\n  File \"/airbyte/integration_code/main.py\", line 13, in <module>\n    launch(source, sys.argv[1:])\n  File \"/usr/local/lib/python3.9/site-packages/airbyte_cdk/entrypoint.py\", line 131, in launch\n    for message in source_entrypoint.run(parsed_args):\n  File \"/usr/local/lib/python3.9/site-packages/airbyte_cdk/entrypoint.py\", line 122, in run\n    for message in generator:\n  File \"/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py\", line 125, in read\n    raise e\n  File \"/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py\", line 111, in read\n    yield from self._read_stream(\n  File \"/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py\", line 180, in _read_stream\n    for record in record_iterator:\n  File \"/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py\", line 290, in _read_full_refresh\n    for record_data_or_message in record_data_or_messages:\n  File \"/airbyte/integration_code/source_amazon_seller_partner/streams.py\", line 340, in read_records\n    report_payload = self._retrieve_report(report_id=report_id)\n  File \"/airbyte/integration_code/source_amazon_seller_partner/streams.py\", line 287, in _retrieve_report\n    retrieve_report_response = self._send_request(retrieve_report_request)\n  File \"/usr/local/lib/python3.9/site-packages/backoff/_sync.py\", line 105, in retry\n    ret = target(*args, **kwargs)\n  File \"/airbyte/integration_code/source_amazon_seller_partner/streams.py\", line 215, in _send_request\n    response.raise_for_status()\n  File \"/usr/local/lib/python3.9/site-packages/requests/models.py\", line 1021, in raise_for_status\n    raise HTTPError(http_error_msg, response=self)\nrequests.exceptions.HTTPError: 403 Client Error: Forbidden for url: https://sellingpartnerapi-eu.amazon.com/reports/2021-06-30/reports/4240572019376\n",
  "timestamp" : 1674128320487
}, {
  "failureOrigin" : "source",
  "internalMessage" : "io.airbyte.workers.general.DefaultReplicationWorker$SourceException: Source cannot be stopped!",
  "externalMessage" : "Something went wrong within the source connector",
  "metadata" : {
    "attemptNumber" : 0,
    "jobId" : 102,
    "connector_command" : "read"
  },
  "stacktrace" : "java.util.concurrent.CompletionException: io.airbyte.workers.general.DefaultReplicationWorker$SourceException: Source cannot be stopped!\n\tat java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:315)\n\tat java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:320)\n\tat java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1807)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)\n\tat java.base/java.lang.Thread.run(Thread.java:1589)\nCaused by: io.airbyte.workers.general.DefaultReplicationWorker$SourceException: Source cannot be stopped!\n\tat io.airbyte.workers.general.DefaultReplicationWorker.lambda$readFromSrcAndWriteToDstRunnable$6(DefaultReplicationWorker.java:354)\n\tat java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)\n\t... 3 more\nCaused by: io.airbyte.workers.exception.WorkerException: Source process exit with code 1. This warning is normal if the job was cancelled.\n\tat io.airbyte.workers.internal.DefaultAirbyteSource.close(DefaultAirbyteSource.java:144)\n\tat io.airbyte.workers.general.DefaultReplicationWorker.lambda$readFromSrcAndWriteToDstRunnable$6(DefaultReplicationWorker.java:352)\n\t... 4 more\n",
  "timestamp" : 1674128321142
} ]
2023-01-19 11:39:00 INFO i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2023-01-19 11:39:00 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-01-19 11:39:00 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- END REPLICATION -----
2023-01-19 11:39:00 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-01-19 11:39:00 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):205 - sync summary: io.airbyte.config.StandardSyncOutput@42a8ef81[standardSyncSummary=io.airbyte.config.StandardSyncSummary@68f27ad8[status=failed,recordsSynced=427475,bytesSynced=390843256,startTime=1674124709677,endTime=1674128340181,totalStats=io.airbyte.config.SyncStats@58a4203b[recordsEmitted=427475,bytesEmitted=390843256,sourceStateMessagesEmitted=0,destinationStateMessagesEmitted=0,recordsCommitted=0,meanSecondsBeforeSourceStateMessageEmitted=0,maxSecondsBeforeSourceStateMessageEmitted=0,maxSecondsBetweenStateMessageEmittedandCommitted=0,meanSecondsBetweenStateMessageEmittedandCommitted=0,replicationStartTime=1674124709677,replicationEndTime=1674128340181,sourceReadStartTime=1674124709709,sourceReadEndTime=0,destinationWriteStartTime=1674124709746,destinationWriteEndTime=1674128340181,additionalProperties={}],streamStats=[io.airbyte.config.StreamSyncStats@3d18e1b7[streamName=GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL,streamNamespace=<null>,stats=io.airbyte.config.SyncStats@3849c572[recordsEmitted=427475,bytesEmitted=390843256,sourceStateMessagesEmitted=<null>,destinationStateMessagesEmitted=<null>,recordsCommitted=<null>,meanSecondsBeforeSourceStateMessageEmitted=<null>,maxSecondsBeforeSourceStateMessageEmitted=<null>,maxSecondsBetweenStateMessageEmittedandCommitted=<null>,meanSecondsBetweenStateMessageEmittedandCommitted=<null>,replicationStartTime=<null>,replicationEndTime=<null>,sourceReadStartTime=<null>,sourceReadEndTime=<null>,destinationWriteStartTime=<null>,destinationWriteEndTime=<null>,additionalProperties={}]]]],normalizationSummary=<null>,webhookOperationSummary=<null>,state=io.airbyte.config.State@3b4f204b[state={}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@43165c19[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@3a4a09b8[stream=io.airbyte.protocol.models.AirbyteStream@4025521f[name=GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL,jsonSchema={"type":"object","title":"Flat File All Orders Data Reports (by last update)","$schema":"http://json-schema.org/draft-07/schema#","properties":{"sku":{"type":["null","string"]},"asin":{"type":["null","string"]},"currency":{"type":["null","string"]},"item-tax":{"type":["null","string"]},"quantity":{"type":["null","string"]},"ship-city":{"type":["null","string"]},"item-price":{"type":["null","string"]},"ship-state":{"type":["null","string"]},"item-status":{"type":["null","string"]},"order-status":{"type":["null","string"]},"product-name":{"type":["null","string"]},"ship-country":{"type":["null","string"]},"shipping-tax":{"type":["null","string"]},"gift-wrap-tax":{"type":["null","string"]},"order-channel":{"type":["null","string"]},"promotion-ids":{"type":["null","string"]},"purchase-date":{"type":["null","string"],"format":"date-time"},"sales-channel":{"type":["null","string"]},"shipping-price":{"type":["null","string"]},"amazon-order-id":{"type":"string"},"gift-wrap-price":{"type":["null","string"]},"ship-postal-code":{"type":["null","string"]},"is-business-order":{"type":["null","string"]},"last-updated-date":{"type":"string","format":"date-time"},"merchant-order-id":{"type":["null","string"]},"price-designation":{"type":["null","string"]},"ship-service-level":{"type":["null","string"]},"fulfillment-channel":{"type":["null","string"]},"purchase-order-number":{"type":["null","string"]},"item-promotion-discount":{"type":["null","string"]},"ship-promotion-discount":{"type":["null","string"]}},"description":"Flat File All Orders Data by Last Update Date General Reports"},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[last-updated-date],sourceDefinedPrimaryKey=[],namespace=<null>,additionalProperties={}],syncMode=full_refresh,cursorField=[last-updated-date],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}]],additionalProperties={}],failures=[io.airbyte.config.FailureReason@36317d3c[failureOrigin=source,failureType=system_error,internalMessage=403 Client Error: Forbidden for url: https://sellingpartnerapi-eu.amazon.com/reports/2021-06-30/reports/4240572019376,externalMessage=Something went wrong in the connector. See the logs for more details.,metadata=io.airbyte.config.Metadata@47360977[additionalProperties={attemptNumber=0, jobId=102, from_trace_message=true, connector_command=read}],stacktrace=Traceback (most recent call last):
  File "/airbyte/integration_code/main.py", line 13, in <module>
    launch(source, sys.argv[1:])
  File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/entrypoint.py", line 131, in launch
    for message in source_entrypoint.run(parsed_args):
  File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/entrypoint.py", line 122, in run
    for message in generator:
  File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 125, in read
    raise e
  File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 111, in read
    yield from self._read_stream(
  File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 180, in _read_stream
    for record in record_iterator:
  File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 290, in _read_full_refresh
    for record_data_or_message in record_data_or_messages:
  File "/airbyte/integration_code/source_amazon_seller_partner/streams.py", line 340, in read_records
    report_payload = self._retrieve_report(report_id=report_id)
  File "/airbyte/integration_code/source_amazon_seller_partner/streams.py", line 287, in _retrieve_report
    retrieve_report_response = self._send_request(retrieve_report_request)
  File "/usr/local/lib/python3.9/site-packages/backoff/_sync.py", line 105, in retry
    ret = target(*args, **kwargs)
  File "/airbyte/integration_code/source_amazon_seller_partner/streams.py", line 215, in _send_request
    response.raise_for_status()
  File "/usr/local/lib/python3.9/site-packages/requests/models.py", line 1021, in raise_for_status
    raise HTTPError(http_error_msg, response=self)
requests.exceptions.HTTPError: 403 Client Error: Forbidden for url: https://sellingpartnerapi-eu.amazon.com/reports/2021-06-30/reports/4240572019376
,retryable=<null>,timestamp=1674128320487], io.airbyte.config.FailureReason@2ddbcfe0[failureOrigin=source,failureType=<null>,internalMessage=io.airbyte.workers.general.DefaultReplicationWorker$SourceException: Source cannot be stopped!,externalMessage=Something went wrong within the source connector,metadata=io.airbyte.config.Metadata@4784c5ee[additionalProperties={attemptNumber=0, jobId=102, connector_command=read}],stacktrace=java.util.concurrent.CompletionException: io.airbyte.workers.general.DefaultReplicationWorker$SourceException: Source cannot be stopped!
	at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:315)
	at java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:320)
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1807)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	at java.base/java.lang.Thread.run(Thread.java:1589)
Caused by: io.airbyte.workers.general.DefaultReplicationWorker$SourceException: Source cannot be stopped!
	at io.airbyte.workers.general.DefaultReplicationWorker.lambda$readFromSrcAndWriteToDstRunnable$6(DefaultReplicationWorker.java:354)
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
	... 3 more
Caused by: io.airbyte.workers.exception.WorkerException: Source process exit with code 1. This warning is normal if the job was cancelled.
	at io.airbyte.workers.internal.DefaultAirbyteSource.close(DefaultAirbyteSource.java:144)
	at io.airbyte.workers.general.DefaultReplicationWorker.lambda$readFromSrcAndWriteToDstRunnable$6(DefaultReplicationWorker.java:352)
	... 4 more
,retryable=<null>,timestamp=1674128321142]]]
2023-01-19 11:39:00 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):210 - Sync summary length: 8076
2023-01-19 11:39:00 INFO i.a.c.t.TemporalUtils(withBackgroundHeartbeat):283 - Stopping temporal heartbeating...
2023-01-19 11:39:00 INFO i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to get state
2023-01-19 11:39:00 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):64 - Using default value for environment variable NEED_STATE_VALIDATION: 'true'
2023-01-19 11:39:00 INFO i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to create or update state
2023-01-19 11:39:00 INFO i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to get normalization statuses
2023-01-19 11:39:00 INFO i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/102/0/logs.log
2023-01-19 11:39:00 INFO i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.26
2023-01-19 11:39:00 INFO i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2023-01-19 11:39:00 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-01-19 11:39:00 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- START DEFAULT NORMALIZATION -----
2023-01-19 11:39:00 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):121 - Running with normalization version: airbyte/normalization-mysql:0.2.25
2023-01-19 11:39:00 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-01-19 11:39:00 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/normalization-mysql:0.2.25 exists...
2023-01-19 11:39:00 INFO i.a.c.i.LineGobbler(voidCall):114 - airbyte/normalization-mysql:0.2.25 was found locally.
2023-01-19 11:39:00 INFO i.a.w.p.DockerProcessFactory(create):120 - Creating docker container = normalization-mysql-normalize-102-0-ydhws with resources io.airbyte.config.ResourceRequirements@43c56339[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2023-01-19 11:39:00 INFO i.a.w.p.DockerProcessFactory(create):164 - Preparing command: docker run --rm --init -i -w /data/102/0/normalize --log-driver none --name normalization-mysql-normalize-102-0-ydhws --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.40.26 airbyte/normalization-mysql:0.2.25 run --integration-type mysql --config destination_config.json --catalog destination_catalog.json
2023-01-19 11:39:00 normalization > Running: transform-config --config destination_config.json --integration-type mysql --out /data/102/0/normalize
2023-01-19 11:39:04 normalization > Namespace(config='destination_config.json', integration_type=<DestinationType.MYSQL: 'mysql'>, out='/data/102/0/normalize')
2023-01-19 11:39:04 normalization > transform_mysql
2023-01-19 11:39:04 normalization > Running: transform-catalog --integration-type mysql --profile-config-dir /data/102/0/normalize --catalog destination_catalog.json --out /data/102/0/normalize/models/generated/ --json-column _airbyte_data
2023-01-19 11:39:05 normalization > Processing destination_catalog.json...
2023-01-19 11:39:05 normalization > Truncating _airbyte_raw_GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL (#65) to _airbyte_raw_GET_FLAT_Y_LAST_UPDATE_GENERAL (#44)
2023-01-19 11:39:05 normalization > Truncating GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL (#52) to GET_FLAT_FILE_ALL_ORD_Y_LAST_UPDATE_GENERAL (#44)
2023-01-19 11:39:05 normalization > Truncating _airbyte_raw_GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL (#65) to _airbyte_raw_GET_FLAT_Y_LAST_UPDATE_GENERAL (#44)
2023-01-19 11:39:05 normalization > Truncating GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL (#52) to GET_FLAT_FILE_ALL_ORD_Y_LAST_UPDATE_GENERAL (#44)
2023-01-19 11:39:05 normalization > Truncating get_flat_file_all_ord__y_last_update_general_ab1 (#48) to get_flat_file_all_ord_st_update_general_ab1 (#44)
2023-01-19 11:39:05 normalization > Truncating get_flat_file_all_ord__y_last_update_general_ab1 (#48) to get_flat_file_all_ord_st_update_general_ab1 (#44)
2023-01-19 11:39:05 normalization >   Generating airbyte_ctes/msz_prod/get_flat_file_all_ord_1st_update_general_ab1.sql from GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL
2023-01-19 11:39:05 normalization > Truncating GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL (#52) to GET_FLAT_FILE_ALL_ORD_Y_LAST_UPDATE_GENERAL (#44)
2023-01-19 11:39:05 normalization > Truncating get_flat_file_all_ord__y_last_update_general_ab2 (#48) to get_flat_file_all_ord_st_update_general_ab2 (#44)
2023-01-19 11:39:05 normalization > Truncating get_flat_file_all_ord__y_last_update_general_ab2 (#48) to get_flat_file_all_ord_st_update_general_ab2 (#44)
2023-01-19 11:39:05 normalization >   Generating airbyte_ctes/msz_prod/get_flat_file_all_ord_1st_update_general_ab2.sql from GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL
2023-01-19 11:39:05 normalization > Truncating GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL (#52) to GET_FLAT_FILE_ALL_ORD_Y_LAST_UPDATE_GENERAL (#44)
2023-01-19 11:39:05 normalization > Truncating _airbyte_get_flat_file_all_ord__y_last_update_general_hashid (#60) to _airbyte_get_flat_fil_update_general_hashid (#44)
2023-01-19 11:39:05 normalization > Truncating GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL (#52) to GET_FLAT_FILE_ALL_ORD_Y_LAST_UPDATE_GENERAL (#44)
2023-01-19 11:39:05 normalization > Truncating get_flat_file_all_ord__y_last_update_general_ab3 (#48) to get_flat_file_all_ord_st_update_general_ab3 (#44)
2023-01-19 11:39:05 normalization > Truncating get_flat_file_all_ord__y_last_update_general_ab3 (#48) to get_flat_file_all_ord_st_update_general_ab3 (#44)
2023-01-19 11:39:05 normalization >   Generating airbyte_ctes/msz_prod/get_flat_file_all_ord_1st_update_general_ab3.sql from GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL
2023-01-19 11:39:05 normalization > Truncating GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL (#52) to GET_FLAT_FILE_ALL_ORD_Y_LAST_UPDATE_GENERAL (#44)
2023-01-19 11:39:05 normalization > Truncating _airbyte_get_flat_file_all_ord__y_last_update_general_hashid (#60) to _airbyte_get_flat_fil_update_general_hashid (#44)
2023-01-19 11:39:05 normalization > Truncating GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL (#52) to GET_FLAT_FILE_ALL_ORD_Y_LAST_UPDATE_GENERAL (#44)
2023-01-19 11:39:05 normalization > Truncating get_flat_file_all_ord__y_last_update_general_scd (#48) to get_flat_file_all_ord_st_update_general_scd (#44)
2023-01-19 11:39:05 normalization >   Adding drop table hook for get_flat_file_all_ord_1st_update_general_scd to get_flat_file_all_ord__y_last_update_general
2023-01-19 11:39:05 normalization >   Generating airbyte_tables/msz_prod/get_flat_file_all_ord__y_last_update_general.sql from GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL
2023-01-19 11:39:05 normalization > detected no config file for ssh, assuming ssh is off.
2023-01-19 11:39:08 normalization >            [--event-buffer-size EVENT_BUFFER_SIZE]
2023-01-19 11:39:08 normalization >   --event-buffer-size EVENT_BUFFER_SIZE
2023-01-19 11:39:08 INFO i.a.w.n.NormalizationAirbyteStreamFactory(filterOutAndHandleNonAirbyteMessageLines):104 - 
2023-01-19 11:39:08 normalization > DBT >=1.0.0 detected; using 10K event buffer size
2023-01-19 11:39:08 INFO i.a.w.n.NormalizationAirbyteStreamFactory(filterOutAndHandleNonAirbyteMessageLines):104 - 
2023-01-19 11:39:11 normalization > Running with dbt=1.0.0
2023-01-19 11:39:11 normalization > Partial parse save file not found. Starting full parse.
2023-01-19 11:39:12 normalization > [WARNING]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources.
There are 2 unused configuration paths:
- models.airbyte_utils.generated.airbyte_incremental
- models.airbyte_utils.generated.airbyte_views

2023-01-19 11:39:12 normalization > Found 4 models, 0 tests, 0 snapshots, 0 analyses, 584 macros, 0 operations, 0 seed files, 1 source, 0 exposures, 0 metrics
2023-01-19 11:39:12 normalization > Concurrency: 1 threads (target='prod')
2023-01-19 11:39:13 normalization > 1 of 1 START table model msz_prod.get_flat_file_all_ord__y_last_update_general.......................................... [RUN]
2023-01-19 11:39:30 normalization > 1 of 1 OK created table model msz_prod.get_flat_file_all_ord__y_last_update_general..................................... [SUCCESS 427475 in 17.89s]
2023-01-19 11:39:30 normalization > Finished running 1 table model in 18.22s.
2023-01-19 11:39:30 normalization > Completed successfully
2023-01-19 11:39:30 normalization > Done. PASS=1 WARN=0 ERROR=0 SKIP=0 TOTAL=1
2023-01-19 11:39:31 INFO i.a.w.n.DefaultNormalizationRunner(close):186 - Terminating normalization process...
2023-01-19 11:39:31 INFO i.a.w.n.DefaultNormalizationRunner(close):199 - Normalization process successfully terminated.
2023-01-19 11:39:31 INFO i.a.w.g.DefaultNormalizationWorker(run):94 - Normalization executed in 30 seconds for job 102.
2023-01-19 11:39:31 INFO i.a.w.g.DefaultNormalizationWorker(run):106 - Normalization summary: io.airbyte.config.NormalizationSummary@188dbd62[startTime=1674128340371,endTime=1674128371127,failures=[]]
2023-01-19 11:39:31 INFO i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2023-01-19 11:39:31 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-01-19 11:39:31 INFO i.a.c.t.TemporalUtils(withBackgroundHeartbeat):283 - Stopping temporal heartbeating...
2023-01-19 11:39:31 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- END DEFAULT NORMALIZATION -----
2023-01-19 11:39:31 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-01-19 11:39:41 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):64 - Using default value for environment variable AUTO_DETECT_SCHEMA: 'false'
2023-01-19 11:39:31 INFO i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/102/1/logs.log
2023-01-19 11:39:31 INFO i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.26
2023-01-19 11:39:31 INFO i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2023-01-19 11:39:31 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):64 - Using default value for environment variable AUTO_DETECT_SCHEMA: 'false'
2023-01-19 11:39:31 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-01-19 11:39:31 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK -----
2023-01-19 11:39:31 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-01-19 11:39:31 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/source-amazon-seller-partner:0.2.30 exists...
2023-01-19 11:39:31 INFO i.a.c.i.LineGobbler(voidCall):114 - airbyte/source-amazon-seller-partner:0.2.30 was found locally.
2023-01-19 11:39:31 INFO i.a.w.p.DockerProcessFactory(create):120 - Creating docker container = source-amazon-seller-partner-check-102-1-hrxee with resources io.airbyte.config.ResourceRequirements@12b2bdc9[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2023-01-19 11:39:31 INFO i.a.w.p.DockerProcessFactory(create):164 - Preparing command: docker run --rm --init -i -w /data/102/1 --log-driver none --name source-amazon-seller-partner-check-102-1-hrxee --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_CONNECTOR_IMAGE=airbyte/source-amazon-seller-partner:0.2.30 -e WORKER_JOB_ATTEMPT=1 -e AUTO_DETECT_SCHEMA=false -e AIRBYTE_VERSION=0.40.26 -e WORKER_JOB_ID=102 airbyte/source-amazon-seller-partner:0.2.30 check --config source_config.json
2023-01-19 11:39:31 INFO i.a.w.i.VersionedAirbyteStreamFactory(create):97 - Reading messages from protocol version 0.2.0
2023-01-19 11:39:36 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Check succeeded
2023-01-19 11:39:36 INFO i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2023-01-19 11:39:36 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-01-19 11:39:36 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK -----
2023-01-19 11:39:36 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-01-19 11:39:36 INFO i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/102/1/logs.log
2023-01-19 11:39:36 INFO i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.26
2023-01-19 11:39:36 INFO i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2023-01-19 11:39:36 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-01-19 11:39:36 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):64 - Using default value for environment variable AUTO_DETECT_SCHEMA: 'false'
2023-01-19 11:39:36 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK -----
2023-01-19 11:39:36 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-01-19 11:39:36 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/destination-mysql:0.1.20 exists...
2023-01-19 11:39:36 INFO i.a.c.i.LineGobbler(voidCall):114 - airbyte/destination-mysql:0.1.20 was found locally.
2023-01-19 11:39:36 INFO i.a.w.p.DockerProcessFactory(create):120 - Creating docker container = destination-mysql-check-102-1-xdoji with resources io.airbyte.config.ResourceRequirements@12b2bdc9[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2023-01-19 11:39:36 INFO i.a.w.p.DockerProcessFactory(create):164 - Preparing command: docker run --rm --init -i -w /data/102/1 --log-driver none --name destination-mysql-check-102-1-xdoji --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_CONNECTOR_IMAGE=airbyte/destination-mysql:0.1.20 -e WORKER_JOB_ATTEMPT=1 -e AUTO_DETECT_SCHEMA=false -e AIRBYTE_VERSION=0.40.26 -e WORKER_JOB_ID=102 airbyte/destination-mysql:0.1.20 check --config source_config.json
2023-01-19 11:39:36 INFO i.a.w.i.VersionedAirbyteStreamFactory(create):97 - Reading messages from protocol version 0.2.0
2023-01-19 11:39:38 ERROR i.a.c.i.LineGobbler(voidCall):114 - SLF4J: Class path contains multiple SLF4J bindings.
2023-01-19 11:39:38 ERROR i.a.c.i.LineGobbler(voidCall):114 - SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2023-01-19 11:39:38 ERROR i.a.c.i.LineGobbler(voidCall):114 - SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2023-01-19 11:39:38 ERROR i.a.c.i.LineGobbler(voidCall):114 - SLF4J: Found binding in [jar:file:/airbyte/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2023-01-19 11:39:38 ERROR i.a.c.i.LineGobbler(voidCall):114 - SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2023-01-19 11:39:38 ERROR i.a.c.i.LineGobbler(voidCall):114 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2023-01-19 11:39:39 INFO i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2023-01-19 11:39:39 INFO i.a.i.d.m.MySQLDestination(main):136 - starting destination: class io.airbyte.integrations.destination.mysql.MySQLDestination
2023-01-19 11:39:39 INFO i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2023-01-19 11:39:39 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json}
2023-01-19 11:39:39 INFO i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2023-01-19 11:39:39 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2023-01-19 11:39:39 INFO i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2023-01-19 11:39:39 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: CHECK
2023-01-19 11:39:39 INFO i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2023-01-19 11:39:39 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'}
2023-01-19 11:39:39 INFO i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2023-01-19 11:39:39 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
2023-01-19 11:39:39 INFO i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2023-01-19 11:39:39 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
2023-01-19 11:39:39 INFO i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2023-01-19 11:39:39 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
2023-01-19 11:39:39 INFO i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2023-01-19 11:39:39 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
2023-01-19 11:39:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2023-01-19 11:39:40 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL
2023-01-19 11:39:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2023-01-19 11:39:40 INFO c.z.h.HikariDataSource(<init>):80 - HikariPool-1 - Starting...
2023-01-19 11:39:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2023-01-19 11:39:40 INFO c.z.h.HikariDataSource(<init>):82 - HikariPool-1 - Start completed.
2023-01-19 11:39:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2023-01-19 11:39:40 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated...
2023-01-19 11:39:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2023-01-19 11:39:40 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed.
2023-01-19 11:39:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2023-01-19 11:39:40 INFO i.a.i.b.IntegrationRunner(runInternal):171 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2023-01-19 11:39:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2023-01-19 11:39:40 INFO i.a.i.d.m.MySQLDestination(main):138 - completed destination: class io.airbyte.integrations.destination.mysql.MySQLDestination
2023-01-19 11:39:41 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-01-19 11:39:41 INFO i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2023-01-19 11:39:41 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK -----
2023-01-19 11:39:41 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-01-19 11:39:41 INFO i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/102/1/logs.log
2023-01-19 11:39:41 INFO i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.26
2023-01-19 11:39:41 INFO i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2023-01-19 11:39:41 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):64 - Using default value for environment variable LOG_CONNECTOR_MESSAGES: 'false'
2023-01-19 11:39:41 INFO i.a.c.EnvConfigs(getEnvOrDefault):1161 - Using default value for environment variable METRIC_CLIENT: ''
2023-01-19 11:39:41 WARN i.a.m.l.MetricClientFactory(initialize):60 - Metric client is already initialized to 
2023-01-19 11:39:41 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):64 - Using default value for environment variable LOG_CONNECTOR_MESSAGES: 'false'
2023-01-19 11:39:41 INFO i.a.w.g.DefaultReplicationWorker(run):142 - start sync worker. job id: 102 attempt id: 1
2023-01-19 11:39:41 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-01-19 11:39:41 INFO i.a.w.g.DefaultReplicationWorker(run):157 - configured sync modes: {null.GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL=full_refresh - overwrite}
2023-01-19 11:39:41 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- START REPLICATION -----
2023-01-19 11:39:41 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-01-19 11:39:41 INFO i.a.w.i.DefaultAirbyteDestination(start):72 - Running destination...
2023-01-19 11:39:41 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):64 - Using default value for environment variable AUTO_DETECT_SCHEMA: 'false'
2023-01-19 11:39:41 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/destination-mysql:0.1.20 exists...
2023-01-19 11:39:41 INFO i.a.c.i.LineGobbler(voidCall):114 - airbyte/destination-mysql:0.1.20 was found locally.
2023-01-19 11:39:41 INFO i.a.w.p.DockerProcessFactory(create):120 - Creating docker container = destination-mysql-write-102-1-fomam with resources io.airbyte.config.ResourceRequirements@33b03536[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2023-01-19 11:39:41 INFO i.a.w.p.DockerProcessFactory(create):164 - Preparing command: docker run --rm --init -i -w /data/102/1 --log-driver none --name destination-mysql-write-102-1-fomam --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_CONNECTOR_IMAGE=airbyte/destination-mysql:0.1.20 -e WORKER_JOB_ATTEMPT=1 -e AUTO_DETECT_SCHEMA=false -e AIRBYTE_VERSION=0.40.26 -e WORKER_JOB_ID=102 airbyte/destination-mysql:0.1.20 write --config destination_config.json --catalog destination_catalog.json
2023-01-19 11:39:41 INFO i.a.w.i.VersionedAirbyteMessageBufferedWriterFactory(createWriter):33 - Writing messages to protocol version 0.2.0
2023-01-19 11:39:41 INFO i.a.w.i.VersionedAirbyteStreamFactory(create):97 - Reading messages from protocol version 0.2.0
2023-01-19 11:39:41 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):64 - Using default value for environment variable AUTO_DETECT_SCHEMA: 'false'
2023-01-19 11:39:41 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/source-amazon-seller-partner:0.2.30 exists...
2023-01-19 11:39:41 INFO i.a.c.i.LineGobbler(voidCall):114 - airbyte/source-amazon-seller-partner:0.2.30 was found locally.
2023-01-19 11:39:41 INFO i.a.w.p.DockerProcessFactory(create):120 - Creating docker container = source-amazon-seller-partner-read-102-1-rbqbu with resources io.airbyte.config.ResourceRequirements@67d95f15[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2023-01-19 11:39:41 INFO i.a.w.p.DockerProcessFactory(create):164 - Preparing command: docker run --rm --init -i -w /data/102/1 --log-driver none --name source-amazon-seller-partner-read-102-1-rbqbu --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_CONNECTOR_IMAGE=airbyte/source-amazon-seller-partner:0.2.30 -e WORKER_JOB_ATTEMPT=1 -e AUTO_DETECT_SCHEMA=false -e AIRBYTE_VERSION=0.40.26 -e WORKER_JOB_ID=102 airbyte/source-amazon-seller-partner:0.2.30 read --config source_config.json --catalog source_catalog.json --state input_state.json
2023-01-19 11:39:41 INFO i.a.w.i.VersionedAirbyteStreamFactory(create):97 - Reading messages from protocol version 0.2.0
2023-01-19 11:39:41 INFO i.a.w.g.DefaultReplicationWorker(replicate):234 - Waiting for source and destination threads to complete.
2023-01-19 11:39:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):260 - Destination output thread started.
2023-01-19 11:39:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):310 - Replication thread started.
2023-01-19 11:39:41 destination > SLF4J: Class path contains multiple SLF4J bindings.
2023-01-19 11:39:41 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2023-01-19 11:39:41 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2023-01-19 11:39:41 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2023-01-19 11:39:41 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2023-01-19 11:39:41 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2023-01-19 11:39:42 source > Starting syncing SourceAmazonSellerPartner
2023-01-19 11:39:42 destination > 2023-01-19 11:39:42 INFO i.a.i.d.m.MySQLDestination(main):136 - starting destination: class io.airbyte.integrations.destination.mysql.MySQLDestination
2023-01-19 11:39:42 source > Syncing stream: GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL 
2023-01-19 11:39:42 destination > 2023-01-19 11:39:42 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2023-01-19 11:39:42 destination > 2023-01-19 11:39:42 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2023-01-19 11:39:42 destination > 2023-01-19 11:39:42 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: WRITE
2023-01-19 11:39:42 destination > 2023-01-19 11:39:42 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2023-01-19 11:39:42 destination > 2023-01-19 11:39:42 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
2023-01-19 11:39:42 destination > 2023-01-19 11:39:42 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
2023-01-19 11:39:42 destination > 2023-01-19 11:39:42 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
2023-01-19 11:39:42 destination > 2023-01-19 11:39:42 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
2023-01-19 11:39:42 destination > 2023-01-19 11:39:42 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL
2023-01-19 11:39:42 destination > 2023-01-19 11:39:42 INFO c.z.h.HikariDataSource(<init>):80 - HikariPool-1 - Starting...
2023-01-19 11:39:42 destination > 2023-01-19 11:39:42 INFO c.z.h.HikariDataSource(<init>):82 - HikariPool-1 - Start completed.
2023-01-19 11:39:43 destination > 2023-01-19 11:39:43 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):98 - Write config: WriteConfig{streamName=GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL, namespace=null, outputSchemaName=msz_prod, tmpTableName=_airbyte_tmp_ram_get___y_last_update_general, outputTableName=_airbyte_raw_get_flat__y_last_update_general, syncMode=overwrite}
2023-01-19 11:39:43 destination > 2023-01-19 11:39:43 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2023-01-19 11:39:43 destination > 2023-01-19 11:39:43 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):123 - Preparing tmp tables in destination started for 1 streams
2023-01-19 11:39:43 destination > 2023-01-19 11:39:43 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):127 - Preparing tmp table in destination started for stream GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL. schema: msz_prod, tmp table name: _airbyte_tmp_ram_get___y_last_update_general
2023-01-19 11:39:43 destination > 2023-01-19 11:39:43 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):133 - Preparing tables in destination completed.
2023-01-19 11:41:01 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$6):231 - Running sync worker cancellation...
2023-01-19 11:41:01 INFO i.a.w.g.DefaultReplicationWorker(cancel):623 - Cancelling replication worker...
2023-01-19 11:41:11 INFO i.a.w.g.DefaultReplicationWorker(cancel):632 - Cancelling destination...
2023-01-19 11:41:11 INFO i.a.w.i.DefaultAirbyteDestination(cancel):131 - Attempting to cancel destination process...
2023-01-19 11:41:11 INFO i.a.w.i.DefaultAirbyteDestination(cancel):136 - Destination process exists, cancelling...
2023-01-19 11:41:11 INFO i.a.w.g.DefaultReplicationWorker(replicate):239 - One of source or destination thread complete. Waiting on the other.
2023-01-19 11:41:11 WARN i.a.c.i.LineGobbler(voidCall):119 - airbyte-destination gobbler IOException: Stream closed. Typically happens when cancelling a job.
2023-01-19 11:41:11 INFO i.a.w.i.DefaultAirbyteDestination(cancel):138 - Cancelled destination process!
2023-01-19 11:41:11 INFO i.a.w.g.DefaultReplicationWorker(cancel):640 - Cancelling source...
2023-01-19 11:41:11 INFO i.a.w.i.DefaultAirbyteSource(cancel):151 - Attempting to cancel source process...
2023-01-19 11:41:11 INFO i.a.w.i.DefaultAirbyteSource(cancel):156 - Source process exists, cancelling...
2023-01-19 11:41:11 INFO i.a.w.g.DefaultReplicationWorker(replicate):241 - Source and destination threads complete.
2023-01-19 11:41:11 INFO i.a.w.i.DefaultAirbyteSource(cancel):158 - Cancelled source process!
2023-01-19 11:41:11 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$6):235 - Interrupting worker thread...
2023-01-19 11:41:11 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$6):238 - Cancelling completable future...
2023-01-19 11:41:11 WARN i.a.c.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled.
2023-01-19 11:41:11 WARN i.a.c.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled.
2023-01-19 11:41:11 INFO i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2023-01-19 11:41:11 ERROR i.a.w.g.DefaultReplicationWorker(replicate):246 - 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:144) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.replicate(DefaultReplicationWorker.java:243) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:164) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:84) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$5(TemporalAttemptExecution.java:195) ~[io.airbyte-airbyte-workers-0.40.26.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:124) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
		at io.airbyte.workers.general.DefaultReplicationWorker.replicate(DefaultReplicationWorker.java:185) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
		at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:164) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
		at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:84) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$5(TemporalAttemptExecution.java:195) ~[io.airbyte-airbyte-workers-0.40.26.jar:?]
		at java.lang.Thread.run(Thread.java:1589) ~[?:?]
2023-01-19 11:41:11 INFO i.a.c.t.TemporalUtils(withBackgroundHeartbeat):283 - Stopping temporal heartbeating...
2023-01-19 11:41:11 INFO i.a.w.g.DefaultReplicationWorker(prepStateForLaterSaving):503 - Source did not output any state messages
2023-01-19 11:41:11 WARN i.a.w.g.DefaultReplicationWorker(prepStateForLaterSaving):511 - State capture: No new state, falling back on input state: io.airbyte.config.State@767a29d4[state={}]
2023-01-19 11:41:11 WARN i.t.i.a.ActivityTaskExecutors$BaseActivityTaskExecutor(execute):114 - Activity failure. ActivityId=3ccf7460-0329-3da7-8ffd-38f7d5c2a4c7, activityType=Replicate, attempt=1
java.lang.RuntimeException: java.util.concurrent.CancellationException
	at io.airbyte.commons.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:281) ~[io.airbyte-airbyte-commons-temporal-0.40.26.jar:?]
	at io.airbyte.workers.temporal.sync.ReplicationActivityImpl.replicate(ReplicationActivityImpl.java:156) ~[io.airbyte-airbyte-workers-0.40.26.jar:?]
	at jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:104) ~[?:?]
	at java.lang.reflect.Method.invoke(Method.java:578) ~[?:?]
	at io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:64) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:43) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:95) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:92) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:241) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:206) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:179) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:93) ~[temporal-sdk-1.17.0.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$6(TemporalAttemptExecution.java:241) ~[io.airbyte-airbyte-workers-0.40.26.jar:?]
	at io.airbyte.commons.temporal.CancellationHandler$TemporalCancellationHandler.checkAndHandleCancellation(CancellationHandler.java:52) ~[io.airbyte-airbyte-commons-temporal-0.40.26.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$7(TemporalAttemptExecution.java:244) ~[io.airbyte-airbyte-workers-0.40.26.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
2023-01-19 11:41:11 INFO i.a.w.g.DefaultReplicationWorker(getReplicationOutput):434 - sync summary: {
  "status" : "cancelled",
  "recordsSynced" : 0,
  "bytesSynced" : 0,
  "startTime" : 1674128381236,
  "endTime" : 1674128471387,
  "totalStats" : {
    "recordsEmitted" : 0,
    "bytesEmitted" : 0,
    "sourceStateMessagesEmitted" : 0,
    "destinationStateMessagesEmitted" : 0,
    "recordsCommitted" : 0,
    "meanSecondsBeforeSourceStateMessageEmitted" : 0,
    "maxSecondsBeforeSourceStateMessageEmitted" : 0,
    "maxSecondsBetweenStateMessageEmittedandCommitted" : 0,
    "meanSecondsBetweenStateMessageEmittedandCommitted" : 0,
    "replicationStartTime" : 1674128381236,
    "replicationEndTime" : 1674128471387,
    "sourceReadStartTime" : 1674128381267,
    "sourceReadEndTime" : 0,
    "destinationWriteStartTime" : 1674128381350,
    "destinationWriteEndTime" : 0
  },
  "streamStats" : [ ]
}
2023-01-19 11:41:11 INFO i.a.w.g.DefaultReplicationWorker(getReplicationOutput):435 - failures: [ ]
2023-01-19 11:41:11 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-01-19 11:41:11 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- END REPLICATION -----
2023-01-19 11:41:11 INFO i.a.c.i.LineGobbler(voidCall):114 -