2022-07-05 09:37:49 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/192/0/logs.log
2022-07-05 09:37:49 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.32-alpha
2022-07-05 09:37:49 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false'
2022-07-05 09:37:49 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-fusion-cloud-extract:dev exists...
2022-07-05 09:37:49 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-fusion-cloud-extract:dev was found locally.
2022-07-05 09:37:49 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 192
2022-07-05 09:37:49 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/192/0 --log-driver none --name source-fusion-cloud-extract-check-192-0-tmyco --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/source-fusion-cloud-extract:dev -e AIRBYTE_VERSION=0.39.32-alpha -e WORKER_JOB_ID=192 airbyte/source-fusion-cloud-extract:dev check --config source_config.json
2022-07-05 09:37:54 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):97 - Begins check !!!
2022-07-05 09:37:59 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):97 - bisecurityservice->isValidLogin: validating login credentails
2022-07-05 09:37:59 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):97 - fusion connnection status: True
2022-07-05 09:37:59 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):97 - Check succeeded
2022-07-05 09:38:00 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-07-05 09:38:00 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/192/0/logs.log
2022-07-05 09:38:00 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.32-alpha
2022-07-05 09:38:00 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false'
2022-07-05 09:38:00 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-mysql:0.1.20 exists...
2022-07-05 09:38:00 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-mysql:0.1.20 was found locally.
2022-07-05 09:38:00 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 192
2022-07-05 09:38:00 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/192/0 --log-driver none --name destination-mysql-check-192-0-dgjpm --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-mysql:0.1.20 -e AIRBYTE_VERSION=0.39.32-alpha -e WORKER_JOB_ID=192 airbyte/destination-mysql:0.1.20 check --config source_config.json
2022-07-05 09:38:02 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings.
2022-07-05 09:38:02 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-07-05 09:38:02 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-07-05 09:38:02 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-07-05 09:38:02 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-07-05 09:38:02 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-07-05 09:38:03 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-05 09:38:03 INFO i.a.i.d.m.MySQLDestination(main):136 - starting destination: class io.airbyte.integrations.destination.mysql.MySQLDestination
2022-07-05 09:38:04 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-05 09:38:04 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json}
2022-07-05 09:38:04 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-05 09:38:04 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2022-07-05 09:38:04 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-05 09:38:04 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: CHECK
2022-07-05 09:38:04 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-05 09:38:04 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'}
2022-07-05 09:38:04 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-05 09:38:04 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-07-05 09:38:04 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-05 09:38:04 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-07-05 09:38:04 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-05 09:38:04 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-07-05 09:38:04 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-05 09:38:04 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword multiline - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-07-05 09:38:04 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-05 09:38:04 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL
2022-07-05 09:38:05 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-05 09:38:05 INFO c.z.h.HikariDataSource(<init>):80 - HikariPool-1 - Starting...
2022-07-05 09:38:05 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-05 09:38:05 INFO c.z.h.HikariDataSource(<init>):82 - HikariPool-1 - Start completed.
2022-07-05 09:38:06 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-05 09:38:06 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated...
2022-07-05 09:38:06 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-05 09:38:06 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed.
2022-07-05 09:38:06 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-07-05 09:38:06 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/192/0/logs.log
2022-07-05 09:38:06 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.32-alpha
2022-07-05 09:38:06 INFO i.a.w.g.DefaultReplicationWorker(run):115 - start sync worker. job id: 192 attempt id: 0
2022-07-05 09:38:06 INFO i.a.w.g.DefaultReplicationWorker(run):127 - configured sync modes: {null.FiscalDayPVO=full_refresh - overwrite}
2022-07-05 09:38:06 INFO i.a.w.i.DefaultAirbyteDestination(start):69 - Running destination...
2022-07-05 09:38:06 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false'
2022-07-05 09:38:06 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-mysql:0.1.20 exists...
2022-07-05 09:38:07 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-mysql:0.1.20 was found locally.
2022-07-05 09:38:07 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 192
2022-07-05 09:38:07 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/192/0 --log-driver none --name destination-mysql-write-192-0-uhqcr --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-mysql:0.1.20 -e AIRBYTE_VERSION=0.39.32-alpha -e WORKER_JOB_ID=192 airbyte/destination-mysql:0.1.20 write --config destination_config.json --catalog destination_catalog.json
2022-07-05 09:38:07 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false'
2022-07-05 09:38:07 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-fusion-cloud-extract:dev exists...
2022-07-05 09:38:07 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-fusion-cloud-extract:dev was found locally.
2022-07-05 09:38:07 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 192
2022-07-05 09:38:07 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/192/0 --log-driver none --name source-fusion-cloud-extract-read-192-0-jlhse --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/source-fusion-cloud-extract:dev -e AIRBYTE_VERSION=0.39.32-alpha -e WORKER_JOB_ID=192 airbyte/source-fusion-cloud-extract:dev read --config source_config.json --catalog source_catalog.json --state input_state.json
2022-07-05 09:38:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):405 - Destination output thread started.
2022-07-05 09:38:07 INFO i.a.w.g.DefaultReplicationWorker(run):169 - Waiting for source and destination threads to complete.
2022-07-05 09:38:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):298 - Replication thread started.
2022-07-05 09:38:08 destination > SLF4J: Class path contains multiple SLF4J bindings.
2022-07-05 09:38:08 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-07-05 09:38:08 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-07-05 09:38:08 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-07-05 09:38:08 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-07-05 09:38:08 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-07-05 09:38:10 destination > 2022-07-05 09:38:10 INFO i.a.i.d.m.MySQLDestination(main):136 - starting destination: class io.airbyte.integrations.destination.mysql.MySQLDestination
2022-07-05 09:38:10 destination > 2022-07-05 09:38:10 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-07-05 09:38:10 destination > 2022-07-05 09:38:10 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2022-07-05 09:38:10 destination > 2022-07-05 09:38:10 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: WRITE
2022-07-05 09:38:10 destination > 2022-07-05 09:38:10 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2022-07-05 09:38:10 source > Begins reading streams for the fusion cloud extract type : Application Data Extract !!!
2022-07-05 09:38:10 source > No of datastores to be streamed : 1
2022-07-05 09:38:11 destination > 2022-07-05 09:38:11 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-07-05 09:38:11 destination > 2022-07-05 09:38:11 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-07-05 09:38:11 destination > 2022-07-05 09:38:11 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-07-05 09:38:11 destination > 2022-07-05 09:38:11 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword multiline - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-07-05 09:38:11 destination > 2022-07-05 09:38:11 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL
2022-07-05 09:38:11 destination > 2022-07-05 09:38:11 INFO c.z.h.HikariDataSource(<init>):80 - HikariPool-1 - Starting...
2022-07-05 09:38:11 destination > 2022-07-05 09:38:11 INFO c.z.h.HikariDataSource(<init>):82 - HikariPool-1 - Start completed.
2022-07-05 09:38:11 destination > 2022-07-05 09:38:11 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):98 - Write config: WriteConfig{streamName=JUL5_FiscalDayPVO, namespace=null, outputSchemaName=discometa, tmpTableName=_airbyte_tmp_itr_jul5_fiscaldaypvo, outputTableName=_airbyte_raw_jul5_fiscaldaypvo, syncMode=overwrite}
2022-07-05 09:38:12 destination > 2022-07-05 09:38:12 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-07-05 09:38:12 destination > 2022-07-05 09:38:12 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):123 - Preparing tmp tables in destination started for 1 streams
2022-07-05 09:38:12 destination > 2022-07-05 09:38:12 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):127 - Preparing tmp table in destination started for stream JUL5_FiscalDayPVO. schema: discometa, tmp table name: _airbyte_tmp_itr_jul5_fiscaldaypvo
2022-07-05 09:38:13 destination > 2022-07-05 09:38:13 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):133 - Preparing tables in destination completed.
2022-07-05 09:38:16 source > Begins scheduled request for extract type Application Data Extract !!!
2022-07-05 09:38:16 source > request_id : 642236
2022-07-05 09:38:16 source > Request id : 642236
2022-07-05 09:39:19 source > Fetching the request status for 642236
2022-07-05 09:39:19 source > Fetching the request status for 642236
2022-07-05 09:39:19 source > submitted request status :SUCCEEDED and time taken : 63.02589011192322 seconds
2022-07-05 09:39:20 source > Wait for a minute for the files to be uploaded to the UCM !!!
2022-07-05 09:40:21 source > Begins searching manifest files in UCM !!
2022-07-05 09:40:21 source > manifest files count: 1
2022-07-05 09:40:21 source > Begins parsing manifest file contents for 663629
2022-07-05 09:40:21 source > zip files count : 1
2022-07-05 09:40:21 source > zip filename : file_fscmtopmodelam_finglcalaccam_fiscaldaypvo-batch376228553-20220705_093832.zip
2022-07-05 09:40:21 source > Begins downloading document : {'fileName': 'file_fscmtopmodelam_finglcalaccam_fiscaldaypvo-batch376228553-20220705_093832.zip', 'documentId': '663628'}
2022-07-05 09:40:21 source > fileName : file_fscmtopmodelam_finglcalaccam_fiscaldaypvo-batch376228553-20220705_093832.zip
2022-07-05 09:40:21 source > filePath : /tmp/file_fscmtopmodelam_finglcalaccam_fiscaldaypvo-batch376228553-20220705_093832.zip
2022-07-05 09:40:21 source > Ends downloading document with status:SUCCESS  !!!
2022-07-05 09:40:21 source > Begins reading file contents /tmp/file_fscmtopmodelam_finglcalaccam_fiscaldaypvo-batch376228553-20220705_093832.zip
2022-07-05 09:40:21 source > filePath : /tmp/file_fscmtopmodelam_finglcalaccam_fiscaldaypvo-batch376228553-20220705_093832.zip
2022-07-05 09:40:21 source > Unzipped the file : /tmp/file_fscmtopmodelam_finglcalaccam_fiscaldaypvo-batch376228553-20220705_093832.zip
2022-07-05 09:40:21 source > csv file path : /tmp/file_fscmtopmodelam_finglcalaccam_fiscaldaypvo-batch376228553-20220705_093832.csv
2022-07-05 09:40:22 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 1000 (121 KB)
2022-07-05 09:40:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 2000 (244 KB)
2022-07-05 09:40:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 3000 (367 KB)
2022-07-05 09:40:24 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 4000 (490 KB)
2022-07-05 09:40:24 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 5000 (613 KB)
2022-07-05 09:40:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 6000 (736 KB)
2022-07-05 09:40:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 7000 (859 KB)
2022-07-05 09:40:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 8000 (982 KB)
2022-07-05 09:40:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 9000 (1 MB)
2022-07-05 09:40:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 10000 (1 MB)
2022-07-05 09:40:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 11000 (1 MB)
2022-07-05 09:40:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 12000 (1 MB)
2022-07-05 09:40:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 13000 (1 MB)
2022-07-05 09:40:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 14000 (1 MB)
2022-07-05 09:40:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 15000 (1 MB)
2022-07-05 09:40:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 16000 (1 MB)
2022-07-05 09:40:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 17000 (2 MB)
2022-07-05 09:40:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 18000 (2 MB)
2022-07-05 09:40:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 19000 (2 MB)
2022-07-05 09:40:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 20000 (2 MB)
2022-07-05 09:40:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 21000 (2 MB)
2022-07-05 09:40:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 22000 (2 MB)
2022-07-05 09:40:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 23000 (2 MB)
2022-07-05 09:40:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 24000 (2 MB)
2022-07-05 09:40:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 25000 (3 MB)
2022-07-05 09:40:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 26000 (3 MB)
2022-07-05 09:40:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 27000 (3 MB)
2022-07-05 09:40:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 28000 (3 MB)
2022-07-05 09:40:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 29000 (3 MB)
2022-07-05 09:40:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 30000 (3 MB)
2022-07-05 09:40:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 31000 (3 MB)
2022-07-05 09:40:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 32000 (3 MB)
2022-07-05 09:40:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 33000 (3 MB)
2022-07-05 09:40:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 34000 (4 MB)
2022-07-05 09:40:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 35000 (4 MB)
2022-07-05 09:40:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 36000 (4 MB)
2022-07-05 09:40:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 37000 (4 MB)
2022-07-05 09:40:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 38000 (4 MB)
2022-07-05 09:40:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 39000 (4 MB)
2022-07-05 09:40:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 40000 (4 MB)
2022-07-05 09:40:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 41000 (4 MB)
2022-07-05 09:40:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 42000 (5 MB)
2022-07-05 09:40:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 43000 (5 MB)
2022-07-05 09:40:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 44000 (5 MB)
2022-07-05 09:40:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 45000 (5 MB)
2022-07-05 09:40:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 46000 (5 MB)
2022-07-05 09:40:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 47000 (5 MB)
2022-07-05 09:40:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 48000 (5 MB)
2022-07-05 09:40:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 49000 (5 MB)
2022-07-05 09:40:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 50000 (6 MB)
2022-07-05 09:40:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 51000 (6 MB)
2022-07-05 09:40:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 52000 (6 MB)
2022-07-05 09:40:42 destination > 2022-07-05 09:40:42 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing JUL5_FiscalDayPVO: 52134 records (24 MB)
2022-07-05 09:40:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 53000 (6 MB)
2022-07-05 09:40:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 54000 (6 MB)
2022-07-05 09:40:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 55000 (6 MB)
2022-07-05 09:40:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 56000 (6 MB)
2022-07-05 09:40:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 57000 (6 MB)
2022-07-05 09:40:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 58000 (6 MB)
2022-07-05 09:40:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 59000 (7 MB)
2022-07-05 09:40:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 60000 (7 MB)
2022-07-05 09:40:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 61000 (7 MB)
2022-07-05 09:40:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 62000 (7 MB)
2022-07-05 09:40:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 63000 (7 MB)
2022-07-05 09:40:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 64000 (7 MB)
2022-07-05 09:40:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 65000 (7 MB)
2022-07-05 09:41:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 66000 (7 MB)
2022-07-05 09:41:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 67000 (8 MB)
2022-07-05 09:41:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 68000 (8 MB)
2022-07-05 09:41:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 69000 (8 MB)
2022-07-05 09:41:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 70000 (8 MB)
2022-07-05 09:41:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 71000 (8 MB)
2022-07-05 09:41:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 72000 (8 MB)
2022-07-05 09:41:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 73000 (8 MB)
2022-07-05 09:41:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 74000 (8 MB)
2022-07-05 09:41:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 75000 (9 MB)
2022-07-05 09:41:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 76000 (9 MB)
2022-07-05 09:41:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 77000 (9 MB)
2022-07-05 09:41:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 78000 (9 MB)
2022-07-05 09:41:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 79000 (9 MB)
2022-07-05 09:41:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 80000 (9 MB)
2022-07-05 09:41:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 81000 (9 MB)
2022-07-05 09:41:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 82000 (9 MB)
2022-07-05 09:41:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 83000 (9 MB)
2022-07-05 09:41:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 84000 (10 MB)
2022-07-05 09:41:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 85000 (10 MB)
2022-07-05 09:41:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 86000 (10 MB)
2022-07-05 09:41:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 87000 (10 MB)
2022-07-05 09:41:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 88000 (10 MB)
2022-07-05 09:41:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 89000 (10 MB)
2022-07-05 09:41:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 90000 (10 MB)
2022-07-05 09:41:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 91000 (10 MB)
2022-07-05 09:41:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 92000 (11 MB)
2022-07-05 09:41:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 93000 (11 MB)
2022-07-05 09:41:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 94000 (11 MB)
2022-07-05 09:41:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 95000 (11 MB)
2022-07-05 09:41:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 96000 (11 MB)
2022-07-05 09:41:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 97000 (11 MB)
2022-07-05 09:41:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 98000 (11 MB)
2022-07-05 09:41:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 99000 (11 MB)
2022-07-05 09:41:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 100000 (12 MB)
2022-07-05 09:41:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 101000 (12 MB)
2022-07-05 09:41:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 102000 (12 MB)
2022-07-05 09:41:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 103000 (12 MB)
2022-07-05 09:41:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 104000 (12 MB)
2022-07-05 09:41:11 destination > 2022-07-05 09:41:11 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing JUL5_FiscalDayPVO: 52117 records (24 MB)
2022-07-05 09:41:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 105000 (12 MB)
2022-07-05 09:41:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 106000 (12 MB)
2022-07-05 09:41:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 107000 (12 MB)
2022-07-05 09:41:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 108000 (12 MB)
2022-07-05 09:41:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 109000 (13 MB)
2022-07-05 09:41:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 110000 (13 MB)
2022-07-05 09:41:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 111000 (13 MB)
2022-07-05 09:41:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 112000 (13 MB)
2022-07-05 09:41:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 113000 (13 MB)
2022-07-05 09:41:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 114000 (13 MB)
2022-07-05 09:41:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 115000 (13 MB)
2022-07-05 09:41:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 116000 (13 MB)
2022-07-05 09:41:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 117000 (14 MB)
2022-07-05 09:41:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 118000 (14 MB)
2022-07-05 09:41:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 119000 (14 MB)
2022-07-05 09:41:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 120000 (14 MB)
2022-07-05 09:41:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 121000 (14 MB)
2022-07-05 09:41:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 122000 (14 MB)
2022-07-05 09:41:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 123000 (14 MB)
2022-07-05 09:41:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 124000 (14 MB)
2022-07-05 09:41:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 125000 (15 MB)
2022-07-05 09:41:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 126000 (15 MB)
2022-07-05 09:41:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 127000 (15 MB)
2022-07-05 09:41:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 128000 (15 MB)
2022-07-05 09:41:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 129000 (15 MB)
2022-07-05 09:41:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 130000 (15 MB)
2022-07-05 09:41:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 131000 (15 MB)
2022-07-05 09:41:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 132000 (15 MB)
2022-07-05 09:41:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 133000 (15 MB)
2022-07-05 09:41:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 134000 (16 MB)
2022-07-05 09:41:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 135000 (16 MB)
2022-07-05 09:41:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 136000 (16 MB)
2022-07-05 09:41:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 137000 (16 MB)
2022-07-05 09:41:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 138000 (16 MB)
2022-07-05 09:41:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 139000 (16 MB)
2022-07-05 09:41:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 140000 (16 MB)
2022-07-05 09:41:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 141000 (16 MB)
2022-07-05 09:41:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 142000 (17 MB)
2022-07-05 09:41:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 143000 (17 MB)
2022-07-05 09:41:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 144000 (17 MB)
2022-07-05 09:41:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 145000 (17 MB)
2022-07-05 09:41:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 146000 (17 MB)
2022-07-05 09:41:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 147000 (17 MB)
2022-07-05 09:41:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 148000 (17 MB)
2022-07-05 09:41:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 149000 (17 MB)
2022-07-05 09:41:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 150000 (18 MB)
2022-07-05 09:41:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 151000 (18 MB)
2022-07-05 09:41:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 152000 (18 MB)
2022-07-05 09:41:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 153000 (18 MB)
2022-07-05 09:41:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 154000 (18 MB)
2022-07-05 09:41:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 155000 (18 MB)
2022-07-05 09:41:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 156000 (18 MB)
2022-07-05 09:41:59 destination > 2022-07-05 09:41:59 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing JUL5_FiscalDayPVO: 52117 records (24 MB)
2022-07-05 09:41:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 157000 (18 MB)
2022-07-05 09:42:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 158000 (18 MB)
2022-07-05 09:42:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 159000 (19 MB)
2022-07-05 09:42:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 160000 (19 MB)
2022-07-05 09:42:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 161000 (19 MB)
2022-07-05 09:42:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 162000 (19 MB)
2022-07-05 09:42:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 163000 (19 MB)
2022-07-05 09:42:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 164000 (19 MB)
2022-07-05 09:42:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 165000 (19 MB)
2022-07-05 09:42:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 166000 (19 MB)
2022-07-05 09:42:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 167000 (20 MB)
2022-07-05 09:42:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 168000 (20 MB)
2022-07-05 09:42:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 169000 (20 MB)
2022-07-05 09:42:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 170000 (20 MB)
2022-07-05 09:42:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 171000 (20 MB)
2022-07-05 09:42:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 172000 (20 MB)
2022-07-05 09:42:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 173000 (20 MB)
2022-07-05 09:42:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 174000 (20 MB)
2022-07-05 09:42:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 175000 (21 MB)
2022-07-05 09:42:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 176000 (21 MB)
2022-07-05 09:42:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 177000 (21 MB)
2022-07-05 09:42:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 178000 (21 MB)
2022-07-05 09:42:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 179000 (21 MB)
2022-07-05 09:42:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 180000 (21 MB)
2022-07-05 09:42:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 181000 (21 MB)
2022-07-05 09:42:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 182000 (21 MB)
2022-07-05 09:42:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 183000 (21 MB)
2022-07-05 09:42:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 184000 (22 MB)
2022-07-05 09:42:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 185000 (22 MB)
2022-07-05 09:42:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 186000 (22 MB)
2022-07-05 09:42:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 187000 (22 MB)
2022-07-05 09:42:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 188000 (22 MB)
2022-07-05 09:42:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 189000 (22 MB)
2022-07-05 09:42:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 190000 (22 MB)
2022-07-05 09:42:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 191000 (22 MB)
2022-07-05 09:42:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 192000 (23 MB)
2022-07-05 09:42:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 193000 (23 MB)
2022-07-05 09:42:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 194000 (23 MB)
2022-07-05 09:42:52 source > Changing file title for the document id : 663629
2022-07-05 09:42:52 source > Changed file title to 642236_2022-07-05 09:42:49.909001_MANIFEST.MF
2022-07-05 09:42:52 source > Renamed manifest file having document id : 663629 and document name : UCMFA00675472
2022-07-05 09:42:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):327 - Source has no more messages, closing connection.
2022-07-05 09:42:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):335 - Total records read: 194686 (23 MB)
2022-07-05 09:42:52 WARN i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$5):338 - Schema validation errors found for stream FiscalDayPVO. Error messages: [$.FISCALYEARNUMBER is of an incorrect type. Expected it to be number, $.FISCALPERIODNUMBER is of an incorrect type. Expected it to be number]
2022-07-05 09:42:52 INFO i.a.w.g.DefaultReplicationWorker(run):174 - One of source or destination thread complete. Waiting on the other.
2022-07-05 09:42:52 destination > 2022-07-05 09:42:52 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded.
2022-07-05 09:42:52 destination > 2022-07-05 09:42:52 INFO i.a.i.d.b.BufferedStreamConsumer(close):171 - executing on success close procedure.
2022-07-05 09:42:52 destination > 2022-07-05 09:42:52 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):86 - Flushing JUL5_FiscalDayPVO: 38318 records (18 MB)
2022-07-05 09:43:20 destination > 2022-07-05 09:43:20 INFO i.a.i.d.j.SqlOperations(onDestinationCloseOperations):138 - No onDestinationCloseOperations required for this destination.
2022-07-05 09:43:20 destination > 2022-07-05 09:43:20 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):163 - Finalizing tables in destination started for 1 streams
2022-07-05 09:43:20 destination > 2022-07-05 09:43:20 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):168 - Finalizing stream JUL5_FiscalDayPVO. schema discometa, tmp table _airbyte_tmp_itr_jul5_fiscaldaypvo, final table _airbyte_raw_jul5_fiscaldaypvo
2022-07-05 09:43:20 destination > 2022-07-05 09:43:20 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):181 - Executing finalization of tables.
2022-07-05 09:43:29 destination > 2022-07-05 09:43:29 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):183 - Finalizing tables in destination completed.
2022-07-05 09:43:29 destination > 2022-07-05 09:43:29 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):186 - Cleaning tmp tables in destination started for 1 streams
2022-07-05 09:43:29 destination > 2022-07-05 09:43:29 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):190 - Cleaning tmp table in destination started for stream JUL5_FiscalDayPVO. schema discometa, tmp table name: _airbyte_tmp_itr_jul5_fiscaldaypvo
2022-07-05 09:43:29 destination > 2022-07-05 09:43:29 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):195 - Cleaning tmp tables in destination completed.
2022-07-05 09:43:29 destination > 2022-07-05 09:43:29 INFO i.a.i.b.IntegrationRunner(runInternal):171 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2022-07-05 09:43:29 destination > 2022-07-05 09:43:29 INFO i.a.i.d.m.MySQLDestination(main):138 - completed destination: class io.airbyte.integrations.destination.mysql.MySQLDestination
2022-07-05 09:43:29 INFO i.a.w.g.DefaultReplicationWorker(run):176 - Source and destination threads complete.
2022-07-05 09:43:29 INFO i.a.w.g.DefaultReplicationWorker(run):239 - sync summary: io.airbyte.config.ReplicationAttemptSummary@5e0969b3[status=completed,recordsSynced=194686,bytesSynced=24527053,startTime=1657013886906,endTime=1657014209433,totalStats=io.airbyte.config.SyncStats@5a35f2a6[recordsEmitted=194686,bytesEmitted=24527053,stateMessagesEmitted=0,recordsCommitted=194686],streamStats=[io.airbyte.config.StreamSyncStats@1f18ccc6[streamName=JUL5_FiscalDayPVO,stats=io.airbyte.config.SyncStats@373b5a34[recordsEmitted=194686,bytesEmitted=24527053,stateMessagesEmitted=<null>,recordsCommitted=194686]]]]
2022-07-05 09:43:29 INFO i.a.w.g.DefaultReplicationWorker(run):268 - Source did not output any state messages
2022-07-05 09:43:29 WARN i.a.w.g.DefaultReplicationWorker(run):276 - State capture: No new state, falling back on input state: io.airbyte.config.State@226ae991[state={}]
2022-07-05 09:43:29 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-07-05 09:43:29 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):161 - sync summary: io.airbyte.config.StandardSyncOutput@1b07b571[standardSyncSummary=io.airbyte.config.StandardSyncSummary@5e053875[status=completed,recordsSynced=194686,bytesSynced=24527053,startTime=1657013886906,endTime=1657014209433,totalStats=io.airbyte.config.SyncStats@5a35f2a6[recordsEmitted=194686,bytesEmitted=24527053,stateMessagesEmitted=0,recordsCommitted=194686],streamStats=[io.airbyte.config.StreamSyncStats@1f18ccc6[streamName=JUL5_FiscalDayPVO,stats=io.airbyte.config.SyncStats@373b5a34[recordsEmitted=194686,bytesEmitted=24527053,stateMessagesEmitted=<null>,recordsCommitted=194686]]]],normalizationSummary=<null>,state=io.airbyte.config.State@226ae991[state={}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@3165ea62[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@6f110442[stream=io.airbyte.protocol.models.AirbyteStream@499b88ec[name=JUL5_FiscalDayPVO,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"FISCALPERIODTYPE":{"type":"string"},"FISCALYEARNUMBER":{"type":"number"},"FISCALPERIODNUMBER":{"type":"number"},"FISCALPERIODSETNAME":{"type":"string"}},"extractType":"Application Data Extract","datastoreName":"FscmTopModelAM.FinGlCalAccAM.FiscalDayPVO","additionalProperties":true},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=<null>,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}]],additionalProperties={}],failures=[]]
2022-07-05 09:43:29 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):291 - Stopping temporal heartbeating...
2022-07-05 09:43:29 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false'