🐛 Destination MongoDb: Sudden kill of the current job

AM-I-Human commented 2 years ago

Environment

Airbyte version: 0.33.9-alpha and 0.35.35
OS Version / Instance: On docker swarm, and on local docker
Deployment: Docker
Source Connector and version: Snowflake 1.4 and 1.9
Destination Connector and version: Mongo 0.1.3 and 1.4
Severity: High
Step where error happened: Sync job

Current Behavior

After a sync from a Snowflake Database to a MongoDB database. After the copy was completed the process was killed and there are different attempts.

Expected Behavior

The process will continue and complete the copy between temporary collections to permanents one

Logs

LOG

``` source - 2022-01-16 19:06:23 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 19:06:17 INFO i.a.i.b.IntegrationRunner(run):133 - Completed integration: io.airbyte.integrations.source.snowflake.SnowflakeSource source - 2022-01-16 19:06:23 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 19:06:17 INFO i.a.i.s.s.SnowflakeSource(main):31 - completed source: class io.airbyte.integrations.source.snowflake.SnowflakeSource 2022-01-16 19:06:23 INFO () DefaultReplicationWorker(run):138 - Source thread complete. 2022-01-16 19:06:23 INFO () DefaultReplicationWorker(run):139 - Waiting for destination thread to join. destination - 2022-01-16 19:06:25 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 19:06:25 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):60 - Airbyte message consumer: succeeded. destination - 2022-01-16 19:06:25 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 19:06:25 INFO i.a.i.d.m.MongodbRecordConsumer(close):88 - Migration finished with no explicit errors. Copying data from tmp tables to permanent destination - 2022-01-16 19:09:23 ERROR () LineGobbler(voidCall):82 - /airbyte/javabase.sh: line 26: 8 Killed /airbyte/bin/"$APPLICATION" "$@" 2022-01-16 19:09:24 INFO () DefaultReplicationWorker(run):141 - Destination thread complete. 2022-01-16 19:09:24 ERROR () DefaultReplicationWorker(run):145 - Sync worker failed. io.airbyte.workers.WorkerException: Destination process exit with code 137. This warning is normal if the job was cancelled. at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.close(DefaultAirbyteDestination.java:114) ~[io.airbyte-airbyte-workers-0.33.9-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:143) ~[io.airbyte-airbyte-workers-0.33.9-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:49) ~[io.airbyte-airbyte-workers-0.33.9-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:167) ~[io.airbyte-airbyte-workers-0.33.9-alpha.jar:?] at java.lang.Thread.run(Thread.java:832) [?:?] 2022-01-16 19:09:24 INFO () DefaultReplicationWorker(run):169 - sync summary: io.airbyte.config.ReplicationAttemptSummary@5ad5811c[status=failed,recordsSynced=6413690,bytesSynced=2414834373,startTime=1642351465642,endTime=1642360164103] 2022-01-16 19:09:24 INFO () DefaultReplicationWorker(run):178 - Source did not output any state messages 2022-01-16 19:09:24 WARN () DefaultReplicationWorker(run):186 - State capture: No new state, falling back on input state: io.airbyte.config.State@258511ff[state={}] 2022-01-16 19:09:24 INFO () TemporalAttemptExecution(get):137 - Stopping cancellation check scheduling... ```

Steps to Reproduce

Make the sync with 20 tables (maybe), It happens every time I try to sync some specific group of tables

Are you willing to submit a PR?

Yes, but I don't know if my employer let me (in this case I don't know where is the problem)

alafanechere commented 2 years ago

Hi @AM-I-Human could you please share the entire sync attempts log as an attached file? Even if there's a failure do you consider the replication as complete?

AM-I-Human commented 2 years ago

I can't retrieve it because airbyte hangs while showing the logs. I can see them using potrainer, but I cannot download them.

Last 500 lines

``` root@e880c8b92caa:/tmp/workspace# tail --lines=500 74/0/logs.log 2022-01-16 18:54:46 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 5980000 2022-01-16 18:54:48 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 5981000 2022-01-16 18:54:49 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 5982000 2022-01-16 18:54:51 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 5983000 2022-01-16 18:54:53 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 5984000 source - 2022-01-16 18:54:54 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 18:54:44 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INCLUSIONI. Records read: 90000 2022-01-16 18:54:54 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 5985000 2022-01-16 18:54:56 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 5986000 2022-01-16 18:54:57 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 5987000 2022-01-16 18:54:59 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 5988000 2022-01-16 18:55:00 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 5989000 2022-01-16 18:55:02 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 5990000 2022-01-16 18:55:04 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 5991000 2022-01-16 18:55:05 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 5992000 2022-01-16 18:55:07 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 5993000 2022-01-16 18:55:09 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 5994000 source - 2022-01-16 18:55:10 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 18:55:02 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INCLUSIONI. Records read: 100000 2022-01-16 18:55:11 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 5995000 2022-01-16 18:55:12 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 5996000 2022-01-16 18:55:14 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 5997000 2022-01-16 18:55:15 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 5998000 2022-01-16 18:55:17 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 5999000 2022-01-16 18:55:18 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6000000 2022-01-16 18:55:20 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6001000 2022-01-16 18:55:21 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6002000 2022-01-16 18:55:23 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6003000 2022-01-16 18:55:25 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6004000 source - 2022-01-16 18:55:26 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 18:55:17 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INCLUSIONI. Records read: 110000 2022-01-16 18:55:26 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6005000 2022-01-16 18:55:28 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6006000 2022-01-16 18:55:30 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6007000 2022-01-16 18:55:31 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6008000 2022-01-16 18:55:33 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6009000 2022-01-16 18:55:34 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6010000 2022-01-16 18:55:36 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6011000 2022-01-16 18:55:37 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6012000 2022-01-16 18:55:40 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6013000 2022-01-16 18:55:41 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6014000 source - 2022-01-16 18:55:42 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 18:55:35 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INCLUSIONI. Records read: 120000 2022-01-16 18:55:43 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6015000 2022-01-16 18:55:44 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6016000 2022-01-16 18:55:46 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6017000 2022-01-16 18:55:47 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6018000 2022-01-16 18:55:49 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6019000 2022-01-16 18:55:50 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6020000 2022-01-16 18:55:52 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6021000 2022-01-16 18:55:54 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6022000 2022-01-16 18:55:56 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6023000 2022-01-16 18:55:57 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6024000 source - 2022-01-16 18:55:58 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 18:55:49 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INCLUSIONI. Records read: 130000 2022-01-16 18:55:59 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6025000 2022-01-16 18:56:00 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6026000 2022-01-16 18:56:02 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6027000 2022-01-16 18:56:03 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6028000 2022-01-16 18:56:05 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6029000 2022-01-16 18:56:06 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6030000 2022-01-16 18:56:09 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6031000 2022-01-16 18:56:10 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6032000 2022-01-16 18:56:12 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6033000 2022-01-16 18:56:13 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6034000 source - 2022-01-16 18:56:14 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 18:56:07 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INCLUSIONI. Records read: 140000 2022-01-16 18:56:15 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6035000 2022-01-16 18:56:16 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6036000 2022-01-16 18:56:18 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6037000 2022-01-16 18:56:19 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6038000 2022-01-16 18:56:21 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6039000 2022-01-16 18:56:22 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6040000 2022-01-16 18:56:25 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6041000 2022-01-16 18:56:26 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6042000 2022-01-16 18:56:28 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6043000 2022-01-16 18:56:29 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6044000 source - 2022-01-16 18:56:30 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 18:56:21 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INCLUSIONI. Records read: 150000 2022-01-16 18:56:31 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6045000 2022-01-16 18:56:32 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6046000 2022-01-16 18:56:34 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6047000 2022-01-16 18:56:35 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6048000 2022-01-16 18:56:37 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6049000 2022-01-16 18:56:39 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6050000 2022-01-16 18:56:41 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6051000 2022-01-16 18:56:42 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6052000 2022-01-16 18:56:43 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6053000 2022-01-16 18:56:45 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6054000 source - 2022-01-16 18:56:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 18:56:39 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INCLUSIONI. Records read: 160000 2022-01-16 18:56:47 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6055000 2022-01-16 18:56:48 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6056000 2022-01-16 18:56:50 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6057000 2022-01-16 18:56:51 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6058000 2022-01-16 18:56:53 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6059000 2022-01-16 18:56:55 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6060000 2022-01-16 18:56:56 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6061000 2022-01-16 18:56:58 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6062000 2022-01-16 18:56:59 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6063000 2022-01-16 18:57:01 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6064000 source - 2022-01-16 18:57:02 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 18:56:53 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INCLUSIONI. Records read: 170000 2022-01-16 18:57:02 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6065000 2022-01-16 18:57:04 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6066000 2022-01-16 18:57:05 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6067000 2022-01-16 18:57:07 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6068000 2022-01-16 18:57:09 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6069000 2022-01-16 18:57:10 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6070000 2022-01-16 18:57:12 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6071000 2022-01-16 18:57:13 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6072000 2022-01-16 18:57:15 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6073000 2022-01-16 18:57:16 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6074000 source - 2022-01-16 18:57:17 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 18:57:10 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INCLUSIONI. Records read: 180000 2022-01-16 18:57:18 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6075000 2022-01-16 18:57:19 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6076000 2022-01-16 18:57:21 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6077000 2022-01-16 18:57:22 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6078000 2022-01-16 18:57:25 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6079000 2022-01-16 18:57:26 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6080000 2022-01-16 18:57:28 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6081000 2022-01-16 18:57:29 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6082000 2022-01-16 18:57:31 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6083000 2022-01-16 18:57:32 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6084000 source - 2022-01-16 18:57:33 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 18:57:24 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INCLUSIONI. Records read: 190000 2022-01-16 18:57:34 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6085000 2022-01-16 18:57:36 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6086000 2022-01-16 18:57:37 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6087000 2022-01-16 18:57:39 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6088000 2022-01-16 18:57:40 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6089000 2022-01-16 18:57:43 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6090000 2022-01-16 18:57:44 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6091000 2022-01-16 18:57:46 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6092000 2022-01-16 18:57:47 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6093000 2022-01-16 18:57:49 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6094000 source - 2022-01-16 18:57:50 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 18:57:43 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INCLUSIONI. Records read: 200000 2022-01-16 18:57:50 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6095000 2022-01-16 18:57:52 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6096000 2022-01-16 18:57:54 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6097000 2022-01-16 18:57:55 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6098000 2022-01-16 18:57:57 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6099000 2022-01-16 18:57:59 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6100000 2022-01-16 18:58:00 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6101000 2022-01-16 18:58:02 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6102000 2022-01-16 18:58:03 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6103000 2022-01-16 18:58:05 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6104000 source - 2022-01-16 18:58:05 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 18:57:57 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INCLUSIONI. Records read: 210000 2022-01-16 18:58:06 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6105000 2022-01-16 18:58:08 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6106000 2022-01-16 18:58:09 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6107000 2022-01-16 18:58:11 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6108000 2022-01-16 18:58:13 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6109000 2022-01-16 18:58:15 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6110000 2022-01-16 18:58:16 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6111000 2022-01-16 18:58:18 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6112000 2022-01-16 18:58:19 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6113000 2022-01-16 18:58:21 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6114000 source - 2022-01-16 18:58:22 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 18:58:15 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INCLUSIONI. Records read: 220000 2022-01-16 18:58:22 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6115000 2022-01-16 18:58:24 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6116000 2022-01-16 18:58:25 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6117000 2022-01-16 18:58:28 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6118000 2022-01-16 18:58:29 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6119000 2022-01-16 18:58:31 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6120000 2022-01-16 18:58:32 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6121000 2022-01-16 18:58:34 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6122000 2022-01-16 18:58:35 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6123000 2022-01-16 18:58:37 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6124000 source - 2022-01-16 18:58:38 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 18:58:28 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INCLUSIONI. Records read: 230000 2022-01-16 18:58:38 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6125000 2022-01-16 18:58:40 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6126000 2022-01-16 18:58:41 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6127000 2022-01-16 18:58:44 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6128000 2022-01-16 18:58:45 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6129000 2022-01-16 18:58:47 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6130000 2022-01-16 18:58:48 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6131000 2022-01-16 18:58:50 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6132000 2022-01-16 18:58:51 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6133000 2022-01-16 18:58:53 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6134000 source - 2022-01-16 18:58:54 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 18:58:47 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INCLUSIONI. Records read: 240000 2022-01-16 18:58:54 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6135000 2022-01-16 18:58:55 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6136000 2022-01-16 18:58:58 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6137000 2022-01-16 18:58:59 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6138000 2022-01-16 18:59:01 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6139000 2022-01-16 18:59:02 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6140000 2022-01-16 18:59:04 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6141000 2022-01-16 18:59:05 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6142000 2022-01-16 18:59:07 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6143000 2022-01-16 18:59:08 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6144000 source - 2022-01-16 18:59:10 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 18:59:00 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INCLUSIONI. Records read: 250000 2022-01-16 18:59:10 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6145000 2022-01-16 18:59:11 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6146000 2022-01-16 18:59:13 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6147000 2022-01-16 18:59:15 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6148000 2022-01-16 18:59:16 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6149000 2022-01-16 18:59:18 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6150000 2022-01-16 18:59:19 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6151000 2022-01-16 18:59:21 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6152000 2022-01-16 18:59:22 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6153000 2022-01-16 18:59:23 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6154000 source - 2022-01-16 18:59:25 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 18:59:18 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INCLUSIONI. Records read: 260000 2022-01-16 18:59:25 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6155000 2022-01-16 18:59:27 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6156000 2022-01-16 18:59:29 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6157000 2022-01-16 18:59:30 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6158000 2022-01-16 18:59:32 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6159000 2022-01-16 18:59:33 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6160000 2022-01-16 18:59:35 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6161000 2022-01-16 18:59:36 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6162000 2022-01-16 18:59:38 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6163000 2022-01-16 18:59:39 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6164000 source - 2022-01-16 18:59:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 18:59:32 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INCLUSIONI. Records read: 270000 2022-01-16 18:59:41 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6165000 2022-01-16 18:59:43 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6166000 2022-01-16 18:59:45 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6167000 2022-01-16 18:59:46 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6168000 2022-01-16 18:59:48 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6169000 2022-01-16 18:59:49 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6170000 2022-01-16 18:59:51 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6171000 2022-01-16 18:59:52 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6172000 2022-01-16 18:59:54 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6173000 2022-01-16 18:59:55 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6174000 source - 2022-01-16 18:59:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 18:59:50 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INCLUSIONI. Records read: 280000 2022-01-16 18:59:57 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6175000 2022-01-16 18:59:59 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6176000 2022-01-16 19:00:00 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6177000 2022-01-16 19:00:02 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6178000 2022-01-16 19:00:04 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6179000 2022-01-16 19:00:06 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6180000 2022-01-16 19:00:07 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6181000 2022-01-16 19:00:09 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6182000 2022-01-16 19:00:10 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6183000 2022-01-16 19:00:11 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6184000 source - 2022-01-16 19:00:13 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 19:00:03 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INCLUSIONI. Records read: 290000 2022-01-16 19:00:14 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6185000 2022-01-16 19:00:15 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6186000 2022-01-16 19:00:17 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6187000 2022-01-16 19:00:18 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6188000 2022-01-16 19:00:20 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6189000 2022-01-16 19:00:21 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6190000 2022-01-16 19:00:23 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6191000 2022-01-16 19:00:24 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6192000 2022-01-16 19:00:26 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6193000 2022-01-16 19:00:28 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6194000 source - 2022-01-16 19:00:29 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 19:00:21 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INCLUSIONI. Records read: 300000 2022-01-16 19:00:29 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6195000 2022-01-16 19:00:31 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6196000 2022-01-16 19:00:33 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6197000 2022-01-16 19:00:34 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6198000 2022-01-16 19:00:36 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6199000 2022-01-16 19:00:37 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6200000 2022-01-16 19:00:39 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6201000 2022-01-16 19:00:40 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6202000 2022-01-16 19:00:42 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6203000 2022-01-16 19:00:43 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6204000 source - 2022-01-16 19:00:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 19:00:36 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INCLUSIONI. Records read: 310000 2022-01-16 19:00:45 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6205000 2022-01-16 19:00:47 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6206000 2022-01-16 19:00:48 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6207000 2022-01-16 19:00:50 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6208000 2022-01-16 19:00:51 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6209000 2022-01-16 19:00:53 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6210000 2022-01-16 19:00:54 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6211000 2022-01-16 19:00:56 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6212000 2022-01-16 19:00:57 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6213000 2022-01-16 19:00:59 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6214000 source - 2022-01-16 19:01:00 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 19:00:53 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INCLUSIONI. Records read: 320000 2022-01-16 19:01:01 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6215000 2022-01-16 19:01:02 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6216000 2022-01-16 19:01:04 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6217000 2022-01-16 19:01:05 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6218000 2022-01-16 19:01:07 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6219000 2022-01-16 19:01:08 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6220000 2022-01-16 19:01:10 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6221000 2022-01-16 19:01:12 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6222000 2022-01-16 19:01:14 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6223000 2022-01-16 19:01:16 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6224000 2022-01-16 19:01:17 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6225000 2022-01-16 19:01:19 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6226000 2022-01-16 19:01:20 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6227000 2022-01-16 19:01:22 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6228000 2022-01-16 19:01:23 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6229000 2022-01-16 19:01:25 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6230000 2022-01-16 19:01:27 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6231000 source - 2022-01-16 19:01:28 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 19:01:22 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INFORMAZIONI_AGGIUNTIVE. Records read: 10000 2022-01-16 19:01:28 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6232000 2022-01-16 19:01:30 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6233000 2022-01-16 19:01:32 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6234000 2022-01-16 19:01:33 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6235000 2022-01-16 19:01:35 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6236000 2022-01-16 19:01:37 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6237000 2022-01-16 19:01:38 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6238000 2022-01-16 19:01:40 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6239000 2022-01-16 19:01:42 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6240000 2022-01-16 19:01:43 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6241000 source - 2022-01-16 19:01:44 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 19:01:38 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INFORMAZIONI_AGGIUNTIVE. Records read: 20000 2022-01-16 19:01:45 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6242000 2022-01-16 19:01:47 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6243000 2022-01-16 19:01:48 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6244000 2022-01-16 19:01:50 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6245000 2022-01-16 19:01:51 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6246000 2022-01-16 19:01:53 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6247000 2022-01-16 19:01:54 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6248000 2022-01-16 19:01:56 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6249000 2022-01-16 19:01:58 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6250000 2022-01-16 19:02:00 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6251000 source - 2022-01-16 19:02:00 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 19:01:55 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INFORMAZIONI_AGGIUNTIVE. Records read: 30000 2022-01-16 19:02:01 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6252000 2022-01-16 19:02:03 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6253000 2022-01-16 19:02:05 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6254000 2022-01-16 19:02:06 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6255000 2022-01-16 19:02:08 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6256000 2022-01-16 19:02:10 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6257000 2022-01-16 19:02:11 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6258000 2022-01-16 19:02:13 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6259000 2022-01-16 19:02:15 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6260000 2022-01-16 19:02:16 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6261000 source - 2022-01-16 19:02:17 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 19:02:12 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INFORMAZIONI_AGGIUNTIVE. Records read: 40000 2022-01-16 19:02:18 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6262000 2022-01-16 19:02:19 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6263000 2022-01-16 19:02:21 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6264000 2022-01-16 19:02:23 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6265000 2022-01-16 19:02:24 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6266000 2022-01-16 19:02:26 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6267000 2022-01-16 19:02:28 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6268000 2022-01-16 19:02:30 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6269000 2022-01-16 19:02:31 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6270000 2022-01-16 19:02:33 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6271000 source - 2022-01-16 19:02:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 19:02:26 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INFORMAZIONI_AGGIUNTIVE. Records read: 50000 2022-01-16 19:02:35 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6272000 2022-01-16 19:02:36 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6273000 2022-01-16 19:02:38 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6274000 2022-01-16 19:02:40 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6275000 2022-01-16 19:02:41 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6276000 2022-01-16 19:02:43 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6277000 2022-01-16 19:02:44 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6278000 2022-01-16 19:02:46 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6279000 2022-01-16 19:02:47 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6280000 2022-01-16 19:02:49 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6281000 source - 2022-01-16 19:02:50 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 19:02:43 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INFORMAZIONI_AGGIUNTIVE. Records read: 60000 2022-01-16 19:02:51 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6282000 2022-01-16 19:02:53 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6283000 2022-01-16 19:02:54 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6284000 2022-01-16 19:02:56 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6285000 2022-01-16 19:02:58 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6286000 2022-01-16 19:02:59 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6287000 2022-01-16 19:03:01 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6288000 2022-01-16 19:03:02 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6289000 2022-01-16 19:03:04 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6290000 2022-01-16 19:03:05 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6291000 source - 2022-01-16 19:03:06 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 19:02:59 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INFORMAZIONI_AGGIUNTIVE. Records read: 70000 2022-01-16 19:03:06 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6292000 2022-01-16 19:03:08 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6293000 2022-01-16 19:03:10 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6294000 2022-01-16 19:03:12 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6295000 2022-01-16 19:03:13 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6296000 2022-01-16 19:03:15 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6297000 2022-01-16 19:03:16 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6298000 2022-01-16 19:03:18 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6299000 2022-01-16 19:03:20 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6300000 2022-01-16 19:03:21 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6301000 source - 2022-01-16 19:03:22 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 19:03:16 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INFORMAZIONI_AGGIUNTIVE. Records read: 80000 2022-01-16 19:03:23 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6302000 2022-01-16 19:03:24 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6303000 2022-01-16 19:03:26 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6304000 2022-01-16 19:03:27 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6305000 2022-01-16 19:03:29 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6306000 2022-01-16 19:03:30 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6307000 2022-01-16 19:03:32 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6308000 2022-01-16 19:03:33 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6309000 2022-01-16 19:03:35 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6310000 2022-01-16 19:03:37 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6311000 source - 2022-01-16 19:03:37 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 19:03:31 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INFORMAZIONI_AGGIUNTIVE. Records read: 90000 2022-01-16 19:03:38 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6312000 2022-01-16 19:03:39 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6313000 2022-01-16 19:03:41 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6314000 2022-01-16 19:03:43 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6315000 2022-01-16 19:03:44 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6316000 2022-01-16 19:03:46 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6317000 2022-01-16 19:03:48 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6318000 2022-01-16 19:03:49 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6319000 2022-01-16 19:03:51 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6320000 2022-01-16 19:03:53 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6321000 source - 2022-01-16 19:03:53 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 19:03:47 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INFORMAZIONI_AGGIUNTIVE. Records read: 100000 2022-01-16 19:03:54 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6322000 2022-01-16 19:03:56 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6323000 2022-01-16 19:03:58 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6324000 2022-01-16 19:03:59 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6325000 2022-01-16 19:04:01 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6326000 2022-01-16 19:04:03 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6327000 2022-01-16 19:04:04 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6328000 2022-01-16 19:04:06 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6329000 2022-01-16 19:04:08 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6330000 2022-01-16 19:04:09 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6331000 source - 2022-01-16 19:04:10 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 19:04:04 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INFORMAZIONI_AGGIUNTIVE. Records read: 110000 2022-01-16 19:04:11 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6332000 2022-01-16 19:04:12 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6333000 2022-01-16 19:04:14 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6334000 2022-01-16 19:04:15 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6335000 2022-01-16 19:04:17 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6336000 2022-01-16 19:04:19 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6337000 2022-01-16 19:04:20 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6338000 2022-01-16 19:04:22 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6339000 2022-01-16 19:04:23 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6340000 2022-01-16 19:04:25 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6341000 source - 2022-01-16 19:04:26 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 19:04:21 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INFORMAZIONI_AGGIUNTIVE. Records read: 120000 2022-01-16 19:04:27 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6342000 2022-01-16 19:04:28 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6343000 2022-01-16 19:04:30 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6344000 2022-01-16 19:04:32 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6345000 2022-01-16 19:04:33 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6346000 2022-01-16 19:04:35 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6347000 2022-01-16 19:04:37 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6348000 2022-01-16 19:04:38 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6349000 2022-01-16 19:04:40 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6350000 2022-01-16 19:04:41 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6351000 source - 2022-01-16 19:04:42 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 19:04:34 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INFORMAZIONI_AGGIUNTIVE. Records read: 130000 2022-01-16 19:04:43 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6352000 2022-01-16 19:04:45 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6353000 2022-01-16 19:04:46 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6354000 2022-01-16 19:04:48 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6355000 2022-01-16 19:04:50 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6356000 2022-01-16 19:04:51 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6357000 2022-01-16 19:04:53 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6358000 2022-01-16 19:04:55 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6359000 2022-01-16 19:04:57 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6360000 2022-01-16 19:04:58 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6361000 source - 2022-01-16 19:04:59 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 19:04:51 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INFORMAZIONI_AGGIUNTIVE. Records read: 140000 2022-01-16 19:05:00 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6362000 2022-01-16 19:05:02 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6363000 2022-01-16 19:05:03 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6364000 2022-01-16 19:05:05 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6365000 2022-01-16 19:05:06 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6366000 2022-01-16 19:05:08 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6367000 2022-01-16 19:05:10 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6368000 2022-01-16 19:05:12 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6369000 2022-01-16 19:05:13 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6370000 2022-01-16 19:05:15 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6371000 source - 2022-01-16 19:05:16 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 19:05:09 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INFORMAZIONI_AGGIUNTIVE. Records read: 150000 2022-01-16 19:05:17 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6372000 2022-01-16 19:05:18 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6373000 2022-01-16 19:05:20 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6374000 2022-01-16 19:05:22 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6375000 2022-01-16 19:05:23 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6376000 2022-01-16 19:05:25 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6377000 2022-01-16 19:05:27 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6378000 2022-01-16 19:05:28 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6379000 2022-01-16 19:05:30 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6380000 2022-01-16 19:05:32 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6381000 source - 2022-01-16 19:05:32 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 19:05:26 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INFORMAZIONI_AGGIUNTIVE. Records read: 160000 2022-01-16 19:05:33 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6382000 2022-01-16 19:05:35 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6383000 2022-01-16 19:05:36 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6384000 2022-01-16 19:05:38 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6385000 2022-01-16 19:05:39 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6386000 2022-01-16 19:05:40 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6387000 2022-01-16 19:05:42 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6388000 2022-01-16 19:05:44 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6389000 2022-01-16 19:05:45 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6390000 2022-01-16 19:05:47 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6391000 2022-01-16 19:05:49 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6392000 2022-01-16 19:05:50 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6393000 source - 2022-01-16 19:05:51 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 19:05:43 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INFORMAZIONI_AGGIUNTIVE_USATO. Records read: 10000 2022-01-16 19:05:51 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6394000 2022-01-16 19:05:54 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6395000 2022-01-16 19:05:55 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6396000 2022-01-16 19:05:56 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6397000 2022-01-16 19:05:59 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6398000 2022-01-16 19:06:00 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6399000 2022-01-16 19:06:01 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6400000 2022-01-16 19:06:03 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6401000 2022-01-16 19:06:05 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6402000 2022-01-16 19:06:06 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6403000 source - 2022-01-16 19:06:08 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 19:06:01 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):249 - Reading stream INFOCAR_INFORMAZIONI_AGGIUNTIVE_USATO. Records read: 20000 2022-01-16 19:06:08 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6404000 2022-01-16 19:06:10 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6405000 2022-01-16 19:06:11 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6406000 2022-01-16 19:06:12 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6407000 2022-01-16 19:06:14 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6408000 2022-01-16 19:06:16 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6409000 2022-01-16 19:06:17 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6410000 2022-01-16 19:06:19 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6411000 2022-01-16 19:06:21 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6412000 2022-01-16 19:06:22 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):220 - Records read: 6413000 source - 2022-01-16 19:06:23 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 19:06:17 INFO i.a.i.s.r.AbstractDbSource(lambda$read$2):123 - Closing database connection pool. source - 2022-01-16 19:06:23 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 19:06:17 INFO i.a.i.s.r.AbstractDbSource(lambda$read$2):125 - Closed database connection pool. source - 2022-01-16 19:06:23 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 19:06:17 INFO i.a.i.b.IntegrationRunner(run):133 - Completed integration: io.airbyte.integrations.source.snowflake.SnowflakeSource source - 2022-01-16 19:06:23 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 19:06:17 INFO i.a.i.s.s.SnowflakeSource(main):31 - completed source: class io.airbyte.integrations.source.snowflake.SnowflakeSource 2022-01-16 19:06:23 INFO () DefaultReplicationWorker(run):138 - Source thread complete. 2022-01-16 19:06:23 INFO () DefaultReplicationWorker(run):139 - Waiting for destination thread to join. destination - 2022-01-16 19:06:25 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 19:06:25 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):60 - Airbyte message consumer: succeeded. destination - 2022-01-16 19:06:25 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-16 19:06:25 INFO i.a.i.d.m.MongodbRecordConsumer(close):88 - Migration finished with no explicit errors. Copying data from tmp tables to permanent destination - 2022-01-16 19:09:23 ERROR () LineGobbler(voidCall):82 - /airbyte/javabase.sh: line 26: 8 Killed /airbyte/bin/"$APPLICATION" "$@" 2022-01-16 19:09:24 INFO () DefaultReplicationWorker(run):141 - Destination thread complete. 2022-01-16 19:09:24 ERROR () DefaultReplicationWorker(run):145 - Sync worker failed. io.airbyte.workers.WorkerException: Destination process exit with code 137. This warning is normal if the job was cancelled. at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.close(DefaultAirbyteDestination.java:114) ~[io.airbyte-airbyte-workers-0.33.9-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:143) ~[io.airbyte-airbyte-workers-0.33.9-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:49) ~[io.airbyte-airbyte-workers-0.33.9-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:167) ~[io.airbyte-airbyte-workers-0.33.9-alpha.jar:?] at java.lang.Thread.run(Thread.java:832) [?:?] 2022-01-16 19:09:24 INFO () DefaultReplicationWorker(run):169 - sync summary: io.airbyte.config.ReplicationAttemptSummary@5ad5811c[status=failed,recordsSynced=6413690,bytesSynced=2414834373,startTime=1642351465642,endTime=1642360164103] 2022-01-16 19:09:24 INFO () DefaultReplicationWorker(run):178 - Source did not output any state messages 2022-01-16 19:09:24 WARN () DefaultReplicationWorker(run):186 - State capture: No new state, falling back on input state: io.airbyte.config.State@258511ff[state={}] 2022-01-16 19:09:24 INFO () TemporalAttemptExecution(get):137 - Stopping cancellation check scheduling... 2022-01-16 19:09:24 INFO () ReplicationActivityImpl(replicate):121 - sync summary: io.airbyte.config.StandardSyncOutput@471dcebe[standardSyncSummary=io.airbyte.config.StandardSyncSummary@4149dc71[status=failed,recordsSynced=6413690,bytesSynced=2414834373,startTime=1642351465642,endTime=1642360164103],state=io.airbyte.config.State@258511ff[state={}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@2de56fd4[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@6a122ed8[stream=io.airbyte.protocol.models.AirbyteStream@4353751a[name=INFOCAR_ANAGRAFICA_ALLESTIMENTI,jsonSchema={"type":"object","properties":{"CODICE_MARCA":{"type":"string"},"CODICE_MODELLO":{"type":"string"},"TAPPO_NUMERICO":{"type":"string"},"CODICE_ALLESTIMENTO":{"type":"string"},"DESCRIZIONE_ALLESTIMENTO":{"type":"string"},"DESCR_ALLESTIMENTO_MERCATO":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Domus,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@4c768355[stream=io.airbyte.protocol.models.AirbyteStream@4a6bcec0[name=INFOCAR_ANAGRAFICA_MARCHE,jsonSchema={"type":"object","properties":{"CODICE_MARCA":{"type":"string"},"TAPPO_NUMERICO":{"type":"string"},"DESCRIZIONE_MARCA":{"type":"string"},"INDIRIZZO_INTERNET_MARCA":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Domus,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@31f44dbb[stream=io.airbyte.protocol.models.AirbyteStream@69d7053a[name=INFOCAR_ANAGRAFICA_MODELLI,jsonSchema={"type":"object","properties":{"FILLER":{"type":"string"},"CODICE_MARCA":{"type":"string"},"CODICE_MODELLO":{"type":"string"},"TAPPO_NUMERICO":{"type":"string"},"DESCRIZIONE_MODELLO":{"type":"string"},"FLAG_DESMOD_SEMPLICE":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Domus,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@11c34f7e[stream=io.airbyte.protocol.models.AirbyteStream@5ca9e48[name=INFOCAR_ANAGRAFICA_MOTIVAZIONI_PERIODI_QUOTAZIONI_USATO,jsonSchema={"type":"object","properties":{"TAPPO_NUMERICO":{"type":"string"},"DESCR_MOTIVAZIONE_PERIODI_QUOTAZ_USATO":{"type":"string"},"CODICE_MOTIVAZIONE_PERIODI_QUOTAZ_USATO":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Domus,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@164092df[stream=io.airbyte.protocol.models.AirbyteStream@476fbbf8[name=INFOCAR_ANAGRAFICA_NORMALIZZATI,jsonSchema={"type":"object","properties":{"TAPPO_NUMERICO":{"type":"string"},"DATA_FINE_ATTUALITA":{"type":"string"},"CODICE_GLOSSARIO_NORMALIZZATO":{"type":"string"},"FLAG_SE_EQUIPAGGIAMENTO_ATTUALE":{"type":"string"},"CODICE_EQUIPAGGIAMENTO_NORMALIZZATO":{"type":"string"},"DESCRIZIONE_EQUIPAGGIAMENTO_NORMALIZZATO_A":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Domus,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@4cdca4d4[stream=io.airbyte.protocol.models.AirbyteStream@1db55bd9[name=INFOCAR_ANAGRAFICA_RAGGRUPPAMENTO_MODELLI,jsonSchema={"type":"object","properties":{"CODICE_MARCA":{"type":"string"},"TAPPO_NUMERICO":{"type":"string"},"CODICE_RAGGRUPPAMENTO_MODELLI":{"type":"string"},"DESCRIZIONE_RAGGRUPPAMENTO_MODELLI":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Domus,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@f71f4da[stream=io.airbyte.protocol.models.AirbyteStream@357b2eb7[name=INFOCAR_ANAGRAFICA_SEGMENTI,jsonSchema={"type":"object","properties":{"TAPPO_NUMERICO":{"type":"string"},"CODICE_SEGMENTO":{"type":"string"},"DESCRIZIONE_SEGMENTO":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Domus,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@1ca8d6c8[stream=io.airbyte.protocol.models.AirbyteStream@2bf42d17[name=INFOCAR_ANAGRAFICA_STATUS,jsonSchema={"type":"object","properties":{"SEGNO_VUOTO":{"type":"string"},"TAPPO_NUMERICO":{"type":"string"},"DESCRIZIONE_STATUS":{"type":"string"},"STATUS_EQUIPAGGIAMENTO":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Domus,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@2b23db97[stream=io.airbyte.protocol.models.AirbyteStream@47c146d2[name=INFOCAR_ANAGRAFICA_UFFICIALI,jsonSchema={"type":"object","properties":{"CODICE_QR":{"type":"string"},"CODICE_MARCA":{"type":"string"},"TAPPO_NUMERICO":{"type":"string"},"FLAG_SE_PACCHETTO_S_N":{"type":"string"},"CODICE_INCOMPATIBILITA":{"type":"string"},"CODICE_CASA_EQUIPAGGIAMENTO":{"type":"string"},"DESCRIZIONE_EQUIPAGGIAMENTO":{"type":"string"},"CODICE_GLOSSARIO_NORMALIZZATO":{"type":"string"},"CODICE_QR_PER_INCOMPATIBILITA":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Domus,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@1d85d674[stream=io.airbyte.protocol.models.AirbyteStream@1793cc46[name=INFOCAR_BASE,jsonSchema={"type":"object","properties":{"TAPPO_NUMERICO":{"type":"string"},"ANNO_REGISTRAZIONE":{"type":"string"},"MESE_REGISTRAZIONE":{"type":"string"},"CODICE_ALLESTIMENTO":{"type":"string"},"ANNO_REGISTRAZIONE_PREC":{"type":"string"},"MESE_REGISTRAZIONE_PREC":{"type":"string"},"CODICE_ALLEST_PRECEDENTE":{"type":"string"},"CODICE_CATEGORIA_VEICOLO":{"type":"string"},"CODICE_MODELLO_PRECEDENTE":{"type":"string"},"FINE_VENDITA_ITALIA_AAAAMM":{"type":"string"},"ANNO_PRESENTAZIONE_UFFICIALE":{"type":"string"},"FINE_IMMATRICOLAZIONI_AAAAMM":{"type":"string"},"INIZIO_VENDITA_ITALIA_AAAAMM":{"type":"string"},"MESE_PRESENTAZIONE_UFFICIALE":{"type":"string"},"INIZIO_IMMATRICOLAZIONI_AAAAMM":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Domus,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@22595240[stream=io.airbyte.protocol.models.AirbyteStream@6f63770f[name=INFOCAR_CAMBI_E_PRESTAZIONI,jsonSchema={"type":"object","properties":{"COPPIA_NM":{"type":"string"},"COPPIA_KGM":{"type":"string"},"POTENZA_CV":{"type":"string"},"POTENZA_KW":{"type":"string"},"PROGRESSIVO":{"type":"string"},"TAPPO_NUMERICO":{"type":"string"},"COPPIA_GIRI_MIN":{"type":"string"},"POTENZA_GIRI_MIN":{"type":"string"},"VELOCITA_MASSIMA":{"type":"string"},"ANNO_REGISTRAZIONE":{"type":"string"},"CONSUMO_1_L_100_KM":{"type":"string"},"CONSUMO_2_L_100_KM":{"type":"string"},"CONSUMO_3_L_100_KM":{"type":"string"},"MESE_REGISTRAZIONE":{"type":"string"},"AUTONOMIA_URBANA_KM":{"type":"string"},"CODICE_ALLESTIMENTO":{"type":"string"},"CODICE_TIPO_CONSUMO":{"type":"string"},"CONSUMO_1_KG_100_KG":{"type":"string"},"CONSUMO_2_KG_100_KG":{"type":"string"},"CONSUMO_3_KG_100_KG":{"type":"string"},"CAPACITA_SERBATOIO_L":{"type":"string"},"CODICE_NUCLEO_MOTORE":{"type":"string"},"CAPACITA_SERBATOIO_KG":{"type":"string"},"CODICE_SERIE_OPZIONALI":{"type":"string"},"FLAG_STIMA_EMISSIONI_1":{"type":"string"},"FLAG_STIMA_EMISSIONI_2":{"type":"string"},"FLAG_STIMA_EMISSIONI_3":{"type":"string"},"FLAG_STIMA_SERBATOIO_L":{"type":"string"},"FLAG_STIMA_VELOCIT_MAX":{"type":"string"},"VELOCITA_COSTANTE_KM_H":{"type":"string"},"FLAG_STIMA_SERBATOIO_KG":{"type":"string"},"ACCELERAZIONE_0_100_KM_H":{"type":"string"},"FLAG_STIMA_ACCELERAZIONE":{"type":"string"},"CODICE_NUCLEO_TRASMISSIONE":{"type":"string"},"EMISSIONI_CO2_PER_CONSUMO_1":{"type":"string"},"EMISSIONI_CO2_PER_CONSUMO_2":{"type":"string"},"EMISSIONI_CO2_PER_CONSUMO_3":{"type":"string"},"FLAG_STIMA_AUTONOMIA_URBANA":{"type":"string"},"AUTONOMIA_A_VELOC_COSTANTE_KM":{"type":"string"},"FLAG_STIMA_CONSUMO_1_L_100_KM":{"type":"string"},"FLAG_STIMA_CONSUMO_2_L_100_KM":{"type":"string"},"FLAG_STIMA_CONSUMO_3_L_100_KM":{"type":"string"},"ELETTRICHE_POTENZA_DI_PICCO_CV":{"type":"string"},"ELETTRICHE_POTENZA_DI_PICCO_KW":{"type":"string"},"FLAG_STIMA_CONSUMO_1_KG_100_KM":{"type":"string"},"FLAG_STIMA_CONSUMO_2_KG_100_KM":{"type":"string"},"FLAG_STIMA_CONSUMO_3_KG_100_KM":{"type":"string"},"FLAG_STIMA_AUTONOMIA_VEL_COSTANTE":{"type":"string"},"CODICE_TIPO_COMBUSTIBILE_SPECIFICO":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Domus,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@5ce62ae1[stream=io.airbyte.protocol.models.AirbyteStream@559e2cc7[name=INFOCAR_CATEGORIA_VEICOLO,jsonSchema={"type":"object","properties":{"TAPPO_NUMERICO":{"type":"string"},"FLAG_TIPO_VEICOLO":{"type":"string"},"CODICE_TIPO_VEICOLO":{"type":"string"},"TIPO_OMOLOGAZIONE_VCL":{"type":"string"},"DESCRIZIONE_TIPO_VEICOLO":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Domus,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@3dbdaf66[stream=io.airbyte.protocol.models.AirbyteStream@49927cd1[name=INFOCAR_CAUSE_ANNO_MESE,jsonSchema={"type":"object","properties":{"TAPPO_NUMERICO":{"type":"string"},"CODICE_VARIAZIONE":{"type":"string"},"ANNO_REGISTRAZIONE":{"type":"string"},"MESE_REGISTRAZIONE":{"type":"string"},"CODICE_ALLESTIMENTO":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Domus,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@244ef620[stream=io.airbyte.protocol.models.AirbyteStream@920e7a[name=INFOCAR_CHILOMETRAGGIO_STANDARD_COMPLESSIVO,jsonSchema={"type":"object","properties":{"TAPPO_NUMERICO":{"type":"string"},"INDICE_PERCORRENZA_CHILOMETRICA":{"type":"string"},"CHILOMETRAGGIO_COMPLESSIVO_PERIODO_1":{"type":"string"},"CHILOMETRAGGIO_COMPLESSIVO_PERIODO_2":{"type":"string"},"CHILOMETRAGGIO_COMPLESSIVO_PERIODO_3":{"type":"string"},"CHILOMETRAGGIO_COMPLESSIVO_PERIODO_4":{"type":"string"},"CHILOMETRAGGIO_COMPLESSIVO_PERIODO_5":{"type":"string"},"CHILOMETRAGGIO_COMPLESSIVO_PERIODO_6":{"type":"string"},"CHILOMETRAGGIO_COMPLESSIVO_PERIODO_7":{"type":"string"},"CHILOMETRAGGIO_COMPLESSIVO_PERIODO_8":{"type":"string"},"CHILOMETRAGGIO_COMPLESSIVO_PERIODO_9":{"type":"string"},"CHILOMETRAGGIO_COMPLESSIVO_PERIODO_10":{"type":"string"},"CHILOMETRAGGIO_COMPLESSIVO_PERIODO_11":{"type":"string"},"CHILOMETRAGGIO_COMPLESSIVO_PERIODO_12":{"type":"string"},"CHILOMETRAGGIO_COMPLESSIVO_PERIODO_13":{"type":"string"},"CHILOMETRAGGIO_COMPLESSIVO_PERIODO_14":{"type":"string"},"CHILOMETRAGGIO_COMPLESSIVO_PERIODO_15":{"type":"string"},"CHILOMETRAGGIO_COMPLESSIVO_PERIODO_16":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Domus,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@50844791[stream=io.airbyte.protocol.models.AirbyteStream@aaacda4[name=INFOCAR_CODICI_CASA_ANAGRAFE,jsonSchema={"type":"object","properties":{"TAPPO_NUMERICO":{"type":"string"},"CODICE_CASA_DEL_VEICOLO":{"type":"string"},"DESCRIZIONE_CASA_DEL_VEICOLO":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Domus,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@5986c527[stream=io.airbyte.protocol.models.AirbyteStream@4977e1b3[name=INFOCAR_CODICI_CASA_IDENTIFICAZIONE,jsonSchema={"type":"object","properties":{"NOTE":{"type":"string"},"PROGRESSIVO":{"type":"string"},"DATA_AAAAMMGG":{"type":"string"},"TAPPO_NUMERICO":{"type":"string"},"ANNO_REGISTRAZIONE":{"type":"string"},"MESE_REGISTRAZIONE":{"type":"string"},"CODICE_ALLESTIMENTO":{"type":"string"},"CODICE_CASA_DEL_VEICOLO":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Domus,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@3bbd8fc3[stream=io.airbyte.protocol.models.AirbyteStream@6726b2fd[name=INFOCAR_COMPOSIZIONE_PACCHETTI,jsonSchema={"type":"object","properties":{"TAPPO_NUMERICO":{"type":"string"},"CODICE_QR_DEL_PACCHETTO":{"type":"string"},"CODICE_EQUIPAGGIAMENTO_NEL_PACCHETTO":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Domus,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@866fcc3[stream=io.airbyte.protocol.models.AirbyteStream@7e6afe05[name=INFOCAR_CROSS_RAGGRUPPAMENTO_MODELLI,jsonSchema={"type":"object","properties":{"CODICE_MARCA":{"type":"string"},"CODICE_MODELLO":{"type":"string"},"TAPPO_NUMERICO":{"type":"string"},"CODICE_RAGGRUPPAMENTO_MODELLI":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Domus,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@29fea59c[stream=io.airbyte.protocol.models.AirbyteStream@7b9d4b04[name=INFOCAR_CROSS_RCL,jsonSchema={"type":"object","properties":{"CODICE_RCL":{"type":"string"},"TAPPO_NUMERICO":{"type":"string"},"ANNO_REGISTRAZIONE":{"type":"string"},"MESE_REGISTRAZIONE":{"type":"string"},"CODICE_ALLESTIMENTO":{"type":"string"},"PROGRESSIVO_CODICE_RCL":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Domus,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@44223050[stream=io.airbyte.protocol.models.AirbyteStream@6d916407[name=INFOCAR_DATI_TECNICI_BASE,jsonSchema={"type":"object","properties":{"PASSO_M":{"type":"string"},"MASSA_KG":{"type":"string"},"ALTEZZA_M":{"type":"string"},"TIPO_GUIDA":{"type":"string"},"LARGHEZZA_M":{"type":"string"},"LUNGHEZZA_M":{"type":"string"},"NUMERO_PORTE":{"type":"string"},"NUMERO_POSTI":{"type":"string"},"PORTATA_A_KG":{"type":"string"},"PORTATA_DA_KG":{"type":"string"},"TAPPO_NUMERICO":{"type":"string"},"POTENZA_FISCALE":{"type":"string"},"FLAG_STIMA_MASSA":{"type":"string"},"CODICE_TIPO_TETTO":{"type":"string"},"ANNO_REGISTRAZIONE":{"type":"string"},"FLAG_STIMA_ALTEZZA":{"type":"string"},"FLAG_STIMA_N_POSTI":{"type":"string"},"MESE_REGISTRAZIONE":{"type":"string"},"CODICE_ALLESTIMENTO":{"type":"string"},"MASSA_RIMORCHIABILE":{"type":"string"},"FLAG_STIMA_LARGHEZZA":{"type":"string"},"FLAG_STIMA_LUNGHEZZA":{"type":"string"},"FLAG_STIMA_PORTATA_A":{"type":"string"},"FLAG_STIMA_PORTATA_DA":{"type":"string"},"CODICE_TIPO_CARROZZERIA":{"type":"string"},"FLAG_STIMA_BAGAGLIAIO_1":{"type":"string"},"FLAG_STIMA_BAGAGLIAIO_2":{"type":"string"},"FLAG_STIMA_BAGAGLIAIO_3":{"type":"string"},"FLAG_VEICOLO_IBRIDO_S_N":{"type":"string"},"MASSA_PIENO_CARICO_A_KG":{"type":"string"},"FLAG_STIMA_RIMORCHIABILE":{"type":"string"},"CAPACITA_BAGAGLIAIO_1_DM3":{"type":"string"},"CAPACITA_BAGAGLIAIO_2_DM3":{"type":"string"},"CAPACITA_BAGAGLIAIO_3_DM3":{"type":"string"},"NORMATIVA_ANTINQUINAMENTO":{"type":"string"},"MASSA_A_PIENO_CARICO_DA_KG":{"type":"string"},"FLAG_STIMA_MASSA_PIENO_CARICO_A":{"type":"string"},"FLAG_STIMA_MASSA_PIENO_CARICO_DA":{"type":"string"},"NUMERO_POSTI_AGGIUNTIVI_NEGATIVO":{"type":"string"},"NUMERO_POSTI_AGGIUNTIVI_POSITIVO":{"type":"string"},"FLAG_STIMA_N_POSTI_AGGIUNTIVI_NEGATIVO":{"type":"string"},"FLAG_STIMA_N_POSTI_AGGIUNTIVI_POSITIVI":{"type":"string"},"CODICE_TIPO_IMPIANTO_SOLO_SE_BIFUEL_TRIFUEL":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Domus,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@319fee6c[stream=io.airbyte.protocol.models.AirbyteStream@204b4630[name=INFOCAR_DATI_TECNICI_SPECIFICI_PER_IBRIDI,jsonSchema={"type":"object","properties":{"COPPIA_NM":{"type":"string"},"COPPIA_KGM":{"type":"string"},"POTENZA_CV":{"type":"string"},"POTENZA_KW":{"type":"string"},"PLUG_IN_S_N":{"type":"string"},"TAPPO_NUMERICO":{"type":"string"},"COPPIA_GIRI_MIN":{"type":"string"},"POTENZA_GIRI_MIN":{"type":"string"},"ANNO_REGISTRAZIONE":{"type":"string"},"MESE_REGISTRAZIONE":{"type":"string"},"CODICE_ALLESTIMENTO":{"type":"string"},"CODICE_TIPOLOGIA_IBRIDIZZAZIONE":{"type":"string"},"FUNZIONAMENTO_IN_ELETTRICO_PURO_S_N":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Domus,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@753e52d9[stream=io.airbyte.protocol.models.AirbyteStream@13e9a125[name=INFOCAR_DETTAGLI_NUCLEO_MOTORE,jsonSchema={"type":"object","properties":{"CILINDRATA":{"type":"string"},"TAPPO_NUMERICO":{"type":"string"},"NUMERO_CILINDRI":{"type":"string"},"CODICE_NUCLEO_MOTORE":{"type":"string"},"CODICE_CATALIZZAZIONE":{"type":"string"},"CODICE_SOVRALIMENTAZIONE":{"type":"string"},"NUMERO_VALVOLE_PER_CILINDRO":{"type":"string"},"CODICE_DISPOSIZIONE_CILINDRI":{"type":"string"},"ELETT_POTENZA_RICARICA_RAPIDA":{"type":"string"},"ELETT_TEMPO_DI_RICARICA_IN_ORE":{"type":"string"},"CODICE_TIPO_COMBUSTIBILE_COMPLETO":{"type":"string"},"ELETT_TEMPO_DI_RICARICA_IN_MINUTI":{"type":"string"},"ELETT_TENSIONE_DI_RICARICA_IN_VOLT":{"type":"string"},"ELETT_CORRENTE_DI_RICARICA_IN_AMPERE":{"type":"string"},"ELETT_CORRENTE_RICARICA_RAPIDA_IN_AMPERE":{"type":"string"},"ELETT_TENSIONE_DI_RICARICA_RAPIDA_IN_VOLT":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Domus,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@5dcbd1ba[stream=io.airbyte.protocol.models.AirbyteStream@27cb66f5[name=INFOCAR_DETTAGLI_NUCLEO_TRASMISSIONE,jsonSchema={"type":"object","properties":{"MARCE":{"type":"string"},"TAPPO_NUMERICO":{"type":"string"},"CODICE_TIPO_CAMBIO":{"type":"string"},"CODICE_TIPO_TRAZIONE":{"type":"string"},"CODICE_NUCLEO_TRASMISSIONE":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Domus,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@2064504f[stream=io.airbyte.protocol.models.AirbyteStream@7e5a3def[name=INFOCAR_DETTAGLIO_SEGMENTI,jsonSchema={"type":"object","properties":{"TAPPO_NUMERICO":{"type":"string"},"CODICE_SEGMENTO":{"type":"string"},"CODICE_ALLESTIMENTO":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Domus,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@7d1f659f[stream=io.airbyte.protocol.models.AirbyteStream@19f4807[name=INFOCAR_DISPOSITIVI_ANTI_INQUINAMENTO,jsonSchema={"type":"object","properties":{"TAPPO_NUMERICO":{"type":"string"},"FLAG_CATALIZZAZIONE":{"type":"string"},"CODICE_TIPO_DISPOSITIVO":{"type":"string"},"DESCRIZIONE_DISPOSITIVO":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Domus,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@37b9653[stream=io.airbyte.protocol.models.AirbyteStream@2ce17696[name=INFOCAR_DISPOSIZIONE_CILINDRI,jsonSchema={"type":"object","properties":{"TAPPO_NUMERICO":{"type":"string"},"FLAG_DISPOSIZIONE_CILINDRI":{"type":"string"},"CODICE_DISPOSIZIONE_CILINDRI":{"type":"string"},"DESCRIZIONE_DISPOSIZIONE_CILINDRI":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Domus,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@2ad4cd08[stream=io.airbyte.protocol.models.AirbyteStream@51707725[name=INFOCAR_EDIZIONE,jsonSchema={"type":"object","properties":{"TAPPO_NUMERICO":{"type":"string"},"ANNO_EDIZIONE_DEL_FILE":{"type":"string"},"MESE_EDIZIONE_DEL_FILE":{"type":"string"},"DATA_AGGIORNAMENTO_DEL_FILE_AAAAMMGG":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Domus,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@ee6aa56[stream=io.airbyte.protocol.models.AirbyteStream@291428da[name=INFOCAR_EDIZIONE_QUOTAZIONI,jsonSchema={"type":"object","properties":{"TAPPO_NUMERICO":{"type":"string"},"ANNO_EDIZIONE_QRT":{"type":"string"},"MESE_EDIZIONE_QRT":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Domus,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@25a41c7d[stream=io.airbyte.protocol.models.AirbyteStream@773f8eb3[name=INFOCAR_ESCLUSIONI,jsonSchema={"type":"object","properties":{"CODICE_QR_1":{"type":"string"},"CODICE_QR_2":{"type":"string"},"TAPPO_NUMERICO":{"type":"string"},"ANNO_REGISTRAZIONE":{"type":"string"},"MESE_REGISTRAZIONE":{"type":"string"},"CODICE_ALLESTIMENTO":{"type":"string"},"DATA_COMPARSA_ESCLUSIONE":{"type":"string"},"DATA_VARIAZIONE_ESCLUSIONE":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Domus,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@4c302e18[stream=io.airbyte.protocol.models.AirbyteStream@44ea9dbc[name=INFOCAR_FOTO,jsonSchema={"type":"object","properties":{"VISTA_FOTO":{"type":"string"},"CODICE_FOTO":{"type":"string"},"TAPPO_NUMERICO":{"type":"string"},"DIMENSIONI_FOTO":{"type":"string"},"ANNO_REGISTRAZIONE":{"type":"string"},"MESE_REGISTRAZIONE":{"type":"string"},"CODICE_ALLESTIMENTO":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Domus,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@41a826a8[stream=io.airbyte.protocol.models.AirbyteStream@4a697238[name=INFOCAR_INCLUSIONI,jsonSchema={"type":"object","properties":{"CODICE_QR_1":{"type":"string"},"CODICE_QR_2":{"type":"string"},"TAPPO_NUMERICO":{"type":"string"},"ANNO_REGISTRAZIONE":{"type":"string"},"MESE_REGISTRAZIONE":{"type":"string"},"CODICE_ALLESTIMENTO":{"type":"string"},"DATA_COMPARSA_INCLUSIONE":{"type":"string"},"DATA_VARIAZIONE_INCLUSIONE":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Domus,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@764c583[stream=io.airbyte.protocol.models.AirbyteStream@1773afae[name=INFOCAR_INFORMAZIONI_AGGIUNTIVE,jsonSchema={"type":"object","properties":{"FILLER":{"type":"string"},"TAPPO_NUMERICO":{"type":"string"},"ANNO_REGISTRAZIONE":{"type":"string"},"MESE_REGISTRAZIONE":{"type":"string"},"CODICE_ALLESTIMENTO":{"type":"string"},"FLAG_ESAURIMENTO_SCORTE":{"type":"string"},"VEICOLO_MERCATO_PRIVATI_S_N":{"type":"string"},"VEICOLO_MERCATO_NOLEGGIO_S_N":{"type":"string"},"VEICOLO_MERCATO_PARTITE_IVA_S_N":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Domus,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@17ee468e[stream=io.airbyte.protocol.models.AirbyteStream@16971ef9[name=INFOCAR_INFORMAZIONI_AGGIUNTIVE_USATO,jsonSchema={"type":"object","properties":{"TAPPO_NUMERICO":{"type":"string"},"ANNO_REGISTRAZIONE":{"type":"string"},"MESE_REGISTRAZIONE":{"type":"string"},"CODICE_ALLESTIMENTO":{"type":"string"},"PERIODO_FINE_QUOTAZIONE_AAAAMM":{"type":"string"},"PERIODO_INIZIO_QUOTAZIONE_AAAAMM":{"type":"string"},"CODICE_MOTIVAZIONE_PERIODI_QUOTAZ_USATO":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Domus,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@377e8975[stream=io.airbyte.protocol.models.AirbyteStream@3d7a4eeb[name=INFOCAR_INTESTAZIONE,jsonSchema={"type":"object","properties":{"TAPPO_NUMERICO":{"type":"string"},"INTESTAZIONE_PERIODO_1":{"type":"string"},"INTESTAZIONE_PERIODO_2":{"type":"string"},"INTESTAZIONE_PERIODO_3":{"type":"string"},"INTESTAZIONE_PERIODO_4":{"type":"string"},"INTESTAZIONE_PERIODO_5":{"type":"string"},"INTESTAZIONE_PERIODO_6":{"type":"string"},"INTESTAZIONE_PERIODO_7":{"type":"string"},"INTESTAZIONE_PERIODO_8":{"type":"string"},"INTESTAZIONE_PERIODO_9":{"type":"string"},"INTESTAZIONE_PERIODO_10":{"type":"string"},"INTESTAZIONE_PERIODO_11":{"type":"string"},"INTESTAZIONE_PERIODO_12":{"type":"string"},"INTESTAZIONE_PERIODO_13":{"type":"string"},"INTESTAZIONE_PERIODO_14":{"type":"string"},"INTESTAZIONE_PERIODO_15":{"type":"string"},"INTESTAZIONE_PERIODO_16":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=Domus,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}]],additionalProperties={}]] 2022-01-16 19:09:24 INFO () ConfigRepository(updateConnectionState):515 - Updating connection b5fdadad-94f4-4da9-8cb1-30a3aa4b1c53 state: io.airbyte.config.State@35fd025e[state={}] 2022-01-16 19:09:24 INFO () DatabaseConfigPersistence(updateConfigRecord):273 - Updating STANDARD_SYNC_STATE record b5fdadad-94f4-4da9-8cb1-30a3aa4b1c53 ```

AM-I-Human commented 2 years ago

I downloaded the log, it is 300 mb, I can't upload it.

AM-I-Human commented 2 years ago

The job seems complete. I found that the data on snowflake (the source), contained the double of the records (the load loaded the same file twice). So in my views that needed to be transferred, there was 2 identical row for each row. I don't think that this caused the issue but the problem happen only with this data that had this issue.

AM-I-Human commented 2 years ago

logs-82-0.txt One log of a single table upload that is killed after competition. This table have not the problem that I sad before. So that is not the issue, as expected.

AM-I-Human commented 2 years ago

logs-24.txt

2022-02-24 10:12:06  [43mdestination [0m > 2022-02-24 10:12:06  [32mINFO [m i.a.i.d.m.MongodbRecordConsumer(close):88 - Migration finished with no explicit errors. Copying data from tmp tables to permanent

2022-02-24 10:12:16 destination > /airbyte/javabase.sh: line 26:    10 Killed                  /airbyte/bin/"$APPLICATION" "$@"

The problem happens even in local with

Environment

Airbyte version: 0.35.35-alpha
OS Version / Instance: On Local
Deployment: Docker
Source Connector and version:: Snowflake (0.1.9)
Destination Connector and version: MongoDB (0.1.4)
Severity: High
Step where error happened: Sync job

IzioDev commented 2 years ago

We have a similar behavior.

Source: Salesforce Destination: MongoDB (DocDB AWS cluster) Logs: logs-71.txt

First, line 2246:

2022-08-04 01:41:05 [43mdestination[0m > 2022-08-04 01:41:05 [32mINFO[m i.a.i.d.m.MongodbRecordConsumer(close):89 - Migration finished with no explicit errors. Copying data from tmp tables to permanent
2022-08-04 01:46:51 [43mdestination[0m > /airbyte/javabase.sh: line 26:     9 Killed                  /airbyte/bin/"$APPLICATION" "$@"
2022-08-04 01:46:51 [1;31mERROR[m i.a.w.g.DefaultReplicationWorker(run):181 - Sync worker failed.

2nd l. 3427:

2022-08-04 05:01:58 [32mINFO[m i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 875000 (9 GB)
2022-08-04 05:01:59 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):191 - Running sync worker cancellation...
2022-08-04 05:01:59 [32mINFO[m i.a.w.g.DefaultReplicationWorker(cancel):444 - Cancelling replication worker...
2022-08-04 05:02:06 [32mINFO[m i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):325 - Records read: 876000 (9 GB)
2022-08-04 05:02:09 [32mINFO[m i.a.w.g.DefaultReplicationWorker(cancel):452 - Cancelling destination...
2022-08-04 05:02:09 [32mINFO[m i.a.w.i.DefaultAirbyteDestination(cancel):125 - Attempting to cancel destination process...
2022-08-04 05:02:09 [32mINFO[m i.a.w.i.DefaultAirbyteDestination(cancel):130 - Destination process exists, cancelling...
2022-08-04 05:02:09 [32mINFO[m i.a.w.g.DefaultReplicationWorker(run):175 - One of source or destination thread complete. Waiting on the other.
2022-08-04 05:02:09 [32mINFO[m i.a.w.g.DefaultReplicationWorker(run):177 - Source and destination threads complete.
2022-08-04 05:02:09 [32mINFO[m i.a.w.i.DefaultAirbyteDestination(cancel):132 - Cancelled destination process!
2022-08-04 05:02:09 [32mINFO[m i.a.w.g.DefaultReplicationWorker(cancel):459 - Cancelling source...
2022-08-04 05:02:09 [32mINFO[m i.a.w.i.DefaultAirbyteSource(cancel):142 - Attempting to cancel source process...
2022-08-04 05:02:09 [32mINFO[m i.a.w.i.DefaultAirbyteSource(cancel):147 - Source process exists, cancelling...
2022-08-04 05:02:09 [33mWARN[m i.a.c.i.LineGobbler(voidCall):86 - airbyte-source gobbler IOException: Stream closed. Typically happens when cancelling a job.
2022-08-04 05:02:09 [1;31mERROR[m i.a.w.g.DefaultReplicationWorker(run):181 - Sync worker failed.

Is cancellation due to the 1st. error log?

EDIT: We identified that this interrupt is encountered when memory limit is reached. We tried to add swap, nothing changes. What is causing this sync to hit 8Gb RAM ? (we're currently investigating with ctop to see what container is consuming the RAM)

Answer: The destination writer (mongodb) is taking all the RAM, could we do the same 'batch payload' you did with other destinations?

AM-I-Human commented 1 year ago

I discover that machine was used by another service. I think it was out of memory issue, and docker killed the container. Now the problem seems to be resolved on the last version I tried > 0.50.12. I close the issue because seems obsolete to me.

airbytehq / airbyte