2022-06-04 13:12:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101123000 (21 GB)
2022-06-04 13:12:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101124000 (21 GB)
2022-06-04 13:12:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101125000 (21 GB)
2022-06-04 13:12:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101126000 (21 GB)
2022-06-04 13:12:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101127000 (21 GB)
2022-06-04 13:12:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101128000 (21 GB)
2022-06-04 13:12:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101129000 (21 GB)
2022-06-04 13:12:48 source > 2022-06-04 13:12:47 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101130000
2022-06-04 13:12:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101130000 (21 GB)
2022-06-04 13:12:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101131000 (21 GB)
2022-06-04 13:12:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101132000 (21 GB)
2022-06-04 13:12:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101133000 (21 GB)
2022-06-04 13:12:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101134000 (21 GB)
2022-06-04 13:12:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101135000 (21 GB)
2022-06-04 13:12:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101136000 (21 GB)
2022-06-04 13:12:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101137000 (21 GB)
2022-06-04 13:12:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101138000 (21 GB)
2022-06-04 13:12:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101139000 (21 GB)
2022-06-04 13:12:50 source > 2022-06-04 13:12:49 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101140000
2022-06-04 13:12:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101140000 (21 GB)
2022-06-04 13:12:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101141000 (21 GB)
2022-06-04 13:12:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101142000 (21 GB)
2022-06-04 13:12:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101143000 (21 GB)
2022-06-04 13:12:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101144000 (21 GB)
2022-06-04 13:12:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101145000 (21 GB)
2022-06-04 13:12:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101146000 (21 GB)
2022-06-04 13:12:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101147000 (21 GB)
2022-06-04 13:12:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101148000 (21 GB)
2022-06-04 13:12:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101149000 (21 GB)
2022-06-04 13:12:52 source > 2022-06-04 13:12:51 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101150000
2022-06-04 13:12:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101150000 (21 GB)
2022-06-04 13:12:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101151000 (21 GB)
2022-06-04 13:12:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101152000 (21 GB)
2022-06-04 13:12:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101153000 (21 GB)
2022-06-04 13:12:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101154000 (21 GB)
2022-06-04 13:12:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101155000 (21 GB)
2022-06-04 13:12:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101156000 (21 GB)
2022-06-04 13:12:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101157000 (21 GB)
2022-06-04 13:12:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101158000 (21 GB)
2022-06-04 13:12:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101159000 (21 GB)
2022-06-04 13:12:54 source > 2022-06-04 13:12:53 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101160000
2022-06-04 13:12:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101160000 (21 GB)
2022-06-04 13:12:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101161000 (21 GB)
2022-06-04 13:12:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101162000 (21 GB)
2022-06-04 13:12:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101163000 (21 GB)
2022-06-04 13:12:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101164000 (21 GB)
2022-06-04 13:12:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101165000 (21 GB)
2022-06-04 13:12:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101166000 (21 GB)
2022-06-04 13:12:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101167000 (21 GB)
2022-06-04 13:12:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101168000 (21 GB)
2022-06-04 13:12:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101169000 (21 GB)
2022-06-04 13:12:56 source > 2022-06-04 13:12:54 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101170000
2022-06-04 13:12:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101170000 (21 GB)
2022-06-04 13:12:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101171000 (21 GB)
2022-06-04 13:12:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101172000 (21 GB)
2022-06-04 13:12:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101173000 (21 GB)
2022-06-04 13:12:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101174000 (21 GB)
2022-06-04 13:12:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101175000 (21 GB)
2022-06-04 13:12:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101176000 (21 GB)
2022-06-04 13:12:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101177000 (21 GB)
2022-06-04 13:12:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101178000 (21 GB)
2022-06-04 13:12:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101179000 (21 GB)
2022-06-04 13:12:58 source > 2022-06-04 13:12:57 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101180000
2022-06-04 13:12:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101180000 (21 GB)
2022-06-04 13:12:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101181000 (21 GB)
2022-06-04 13:12:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101182000 (21 GB)
2022-06-04 13:12:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101183000 (21 GB)
2022-06-04 13:12:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101184000 (21 GB)
2022-06-04 13:12:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101185000 (21 GB)
2022-06-04 13:12:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101186000 (21 GB)
2022-06-04 13:13:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101187000 (21 GB)
2022-06-04 13:13:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101188000 (21 GB)
2022-06-04 13:13:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101189000 (21 GB)
2022-06-04 13:13:00 source > 2022-06-04 13:12:59 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101190000
2022-06-04 13:13:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101190000 (21 GB)
2022-06-04 13:13:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101191000 (21 GB)
2022-06-04 13:13:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101192000 (21 GB)
2022-06-04 13:13:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101193000 (21 GB)
2022-06-04 13:13:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101194000 (21 GB)
2022-06-04 13:13:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101195000 (21 GB)
2022-06-04 13:13:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101196000 (21 GB)
2022-06-04 13:13:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101197000 (21 GB)
2022-06-04 13:13:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101198000 (21 GB)
2022-06-04 13:13:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101199000 (21 GB)
2022-06-04 13:13:03 source > 2022-06-04 13:13:01 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101200000
2022-06-04 13:13:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101200000 (21 GB)
2022-06-04 13:13:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101201000 (21 GB)
2022-06-04 13:13:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101202000 (21 GB)
2022-06-04 13:13:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101203000 (21 GB)
2022-06-04 13:13:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101204000 (21 GB)
2022-06-04 13:13:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101205000 (21 GB)
2022-06-04 13:13:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101206000 (21 GB)
2022-06-04 13:13:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101207000 (21 GB)
2022-06-04 13:13:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101208000 (21 GB)
2022-06-04 13:13:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101209000 (21 GB)
2022-06-04 13:13:04 source > 2022-06-04 13:13:03 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101210000
2022-06-04 13:13:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101210000 (21 GB)
2022-06-04 13:13:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101211000 (21 GB)
2022-06-04 13:13:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101212000 (21 GB)
2022-06-04 13:13:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101213000 (21 GB)
2022-06-04 13:13:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101214000 (21 GB)
2022-06-04 13:13:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101215000 (21 GB)
2022-06-04 13:13:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101216000 (21 GB)
2022-06-04 13:13:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101217000 (21 GB)
2022-06-04 13:13:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101218000 (21 GB)
2022-06-04 13:13:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101219000 (21 GB)
2022-06-04 13:13:06 source > 2022-06-04 13:13:05 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101220000
2022-06-04 13:13:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101220000 (21 GB)
2022-06-04 13:13:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101221000 (21 GB)
2022-06-04 13:13:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101222000 (21 GB)
2022-06-04 13:13:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101223000 (21 GB)
2022-06-04 13:13:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101224000 (21 GB)
2022-06-04 13:13:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101225000 (21 GB)
2022-06-04 13:13:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101226000 (21 GB)
2022-06-04 13:13:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101227000 (21 GB)
2022-06-04 13:13:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101228000 (21 GB)
2022-06-04 13:13:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101229000 (21 GB)
2022-06-04 13:13:08 source > 2022-06-04 13:13:07 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101230000
2022-06-04 13:13:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101230000 (21 GB)
2022-06-04 13:13:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101231000 (21 GB)
2022-06-04 13:13:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101232000 (21 GB)
2022-06-04 13:13:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101233000 (21 GB)
2022-06-04 13:13:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101234000 (21 GB)
2022-06-04 13:13:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101235000 (21 GB)
2022-06-04 13:13:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101236000 (21 GB)
2022-06-04 13:13:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101237000 (21 GB)
2022-06-04 13:13:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101238000 (21 GB)
2022-06-04 13:13:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101239000 (21 GB)
2022-06-04 13:13:10 source > 2022-06-04 13:13:09 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101240000
2022-06-04 13:13:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101240000 (21 GB)
2022-06-04 13:13:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101241000 (21 GB)
2022-06-04 13:13:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101242000 (21 GB)
2022-06-04 13:13:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101243000 (21 GB)
2022-06-04 13:13:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101244000 (21 GB)
2022-06-04 13:13:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101245000 (21 GB)
2022-06-04 13:13:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101246000 (21 GB)
2022-06-04 13:13:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101247000 (21 GB)
2022-06-04 13:13:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101248000 (21 GB)
2022-06-04 13:13:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101249000 (21 GB)
2022-06-04 13:13:12 source > 2022-06-04 13:13:11 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101250000
2022-06-04 13:13:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101250000 (21 GB)
2022-06-04 13:13:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101251000 (21 GB)
2022-06-04 13:13:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101252000 (21 GB)
2022-06-04 13:13:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101253000 (21 GB)
2022-06-04 13:13:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101254000 (21 GB)
2022-06-04 13:13:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101255000 (21 GB)
2022-06-04 13:13:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101256000 (21 GB)
2022-06-04 13:13:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101257000 (21 GB)
2022-06-04 13:13:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101258000 (21 GB)
2022-06-04 13:13:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101259000 (21 GB)
2022-06-04 13:13:14 source > 2022-06-04 13:13:13 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101260000
2022-06-04 13:13:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101260000 (21 GB)
2022-06-04 13:13:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101261000 (21 GB)
2022-06-04 13:13:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101262000 (21 GB)
2022-06-04 13:13:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101263000 (21 GB)
2022-06-04 13:13:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101264000 (21 GB)
2022-06-04 13:13:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101265000 (21 GB)
2022-06-04 13:13:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101266000 (21 GB)
2022-06-04 13:13:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101267000 (21 GB)
2022-06-04 13:13:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101268000 (21 GB)
2022-06-04 13:13:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101269000 (21 GB)
2022-06-04 13:13:16 source > 2022-06-04 13:13:15 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101270000
2022-06-04 13:13:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101270000 (21 GB)
2022-06-04 13:13:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101271000 (21 GB)
2022-06-04 13:13:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101272000 (21 GB)
2022-06-04 13:13:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101273000 (21 GB)
2022-06-04 13:13:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101274000 (21 GB)
2022-06-04 13:13:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101275000 (21 GB)
2022-06-04 13:13:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101276000 (21 GB)
2022-06-04 13:13:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101277000 (21 GB)
2022-06-04 13:13:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101278000 (21 GB)
2022-06-04 13:13:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101279000 (21 GB)
2022-06-04 13:13:18 source > 2022-06-04 13:13:17 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101280000
2022-06-04 13:13:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101280000 (21 GB)
2022-06-04 13:13:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101281000 (21 GB)
2022-06-04 13:13:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101282000 (21 GB)
2022-06-04 13:13:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101283000 (21 GB)
2022-06-04 13:13:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101284000 (21 GB)
2022-06-04 13:13:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101285000 (21 GB)
2022-06-04 13:13:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101286000 (21 GB)
2022-06-04 13:13:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101287000 (21 GB)
2022-06-04 13:13:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101288000 (21 GB)
2022-06-04 13:13:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101289000 (21 GB)
2022-06-04 13:13:19 source > 2022-06-04 13:13:19 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101290000
2022-06-04 13:13:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101290000 (21 GB)
2022-06-04 13:13:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101291000 (21 GB)
2022-06-04 13:13:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101292000 (21 GB)
2022-06-04 13:13:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101293000 (21 GB)
2022-06-04 13:13:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101294000 (21 GB)
2022-06-04 13:13:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101295000 (21 GB)
2022-06-04 13:13:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101296000 (21 GB)
2022-06-04 13:13:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101297000 (21 GB)
2022-06-04 13:13:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101298000 (21 GB)
2022-06-04 13:13:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101299000 (21 GB)
2022-06-04 13:13:21 source > 2022-06-04 13:13:20 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101300000
2022-06-04 13:13:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101300000 (21 GB)
2022-06-04 13:13:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101301000 (21 GB)
2022-06-04 13:13:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101302000 (21 GB)
2022-06-04 13:13:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101303000 (21 GB)
2022-06-04 13:13:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101304000 (21 GB)
2022-06-04 13:13:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101305000 (21 GB)
2022-06-04 13:13:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101306000 (21 GB)
2022-06-04 13:13:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101307000 (21 GB)
2022-06-04 13:13:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101308000 (21 GB)
2022-06-04 13:13:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101309000 (21 GB)
2022-06-04 13:13:23 source > 2022-06-04 13:13:22 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101310000
2022-06-04 13:13:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101310000 (21 GB)
2022-06-04 13:13:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101311000 (21 GB)
2022-06-04 13:13:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101312000 (21 GB)
2022-06-04 13:13:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101313000 (21 GB)
2022-06-04 13:13:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101314000 (21 GB)
2022-06-04 13:13:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101315000 (21 GB)
2022-06-04 13:13:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101316000 (21 GB)
2022-06-04 13:13:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101317000 (21 GB)
2022-06-04 13:13:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101318000 (21 GB)
2022-06-04 13:13:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101319000 (21 GB)
2022-06-04 13:13:25 source > 2022-06-04 13:13:24 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101320000
2022-06-04 13:13:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101320000 (21 GB)
2022-06-04 13:13:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101321000 (21 GB)
2022-06-04 13:13:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101322000 (21 GB)
2022-06-04 13:13:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101323000 (21 GB)
2022-06-04 13:13:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101324000 (21 GB)
2022-06-04 13:13:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101325000 (21 GB)
2022-06-04 13:13:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101326000 (21 GB)
2022-06-04 13:13:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101327000 (21 GB)
2022-06-04 13:13:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101328000 (21 GB)
2022-06-04 13:13:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101329000 (21 GB)
2022-06-04 13:13:27 source > 2022-06-04 13:13:26 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101330000
2022-06-04 13:13:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101330000 (21 GB)
2022-06-04 13:13:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101331000 (21 GB)
2022-06-04 13:13:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101332000 (21 GB)
2022-06-04 13:13:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101333000 (21 GB)
2022-06-04 13:13:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101334000 (21 GB)
2022-06-04 13:13:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101335000 (21 GB)
2022-06-04 13:13:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101336000 (21 GB)
2022-06-04 13:13:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101337000 (21 GB)
2022-06-04 13:13:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101338000 (21 GB)
2022-06-04 13:13:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101339000 (21 GB)
2022-06-04 13:13:29 source > 2022-06-04 13:13:28 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101340000
2022-06-04 13:13:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101340000 (21 GB)
2022-06-04 13:13:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101341000 (21 GB)
2022-06-04 13:13:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101342000 (21 GB)
2022-06-04 13:13:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101343000 (21 GB)
2022-06-04 13:13:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101344000 (21 GB)
2022-06-04 13:13:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101345000 (21 GB)
2022-06-04 13:13:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101346000 (21 GB)
2022-06-04 13:13:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101347000 (21 GB)
2022-06-04 13:13:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101348000 (21 GB)
2022-06-04 13:13:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101349000 (21 GB)
2022-06-04 13:13:31 source > 2022-06-04 13:13:30 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101350000
2022-06-04 13:13:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101350000 (21 GB)
2022-06-04 13:13:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101351000 (21 GB)
2022-06-04 13:13:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101352000 (21 GB)
2022-06-04 13:13:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101353000 (21 GB)
2022-06-04 13:13:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101354000 (21 GB)
2022-06-04 13:13:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101355000 (21 GB)
2022-06-04 13:13:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101356000 (21 GB)
2022-06-04 13:13:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101357000 (21 GB)
2022-06-04 13:13:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101358000 (21 GB)
2022-06-04 13:13:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101359000 (21 GB)
2022-06-04 13:13:33 source > 2022-06-04 13:13:32 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101360000
2022-06-04 13:13:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101360000 (21 GB)
2022-06-04 13:13:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101361000 (21 GB)
2022-06-04 13:13:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101362000 (21 GB)
2022-06-04 13:13:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101363000 (21 GB)
2022-06-04 13:13:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101364000 (21 GB)
2022-06-04 13:13:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101365000 (21 GB)
2022-06-04 13:13:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101366000 (21 GB)
2022-06-04 13:13:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101367000 (21 GB)
2022-06-04 13:13:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101368000 (21 GB)
2022-06-04 13:13:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101369000 (21 GB)
2022-06-04 13:13:34 source > 2022-06-04 13:13:33 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101370000
2022-06-04 13:13:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101370000 (21 GB)
2022-06-04 13:13:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101371000 (21 GB)
2022-06-04 13:13:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101372000 (21 GB)
2022-06-04 13:13:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101373000 (21 GB)
2022-06-04 13:13:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101374000 (21 GB)
2022-06-04 13:13:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101375000 (21 GB)
2022-06-04 13:13:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101376000 (21 GB)
2022-06-04 13:13:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101377000 (21 GB)
2022-06-04 13:13:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101378000 (21 GB)
2022-06-04 13:13:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101379000 (21 GB)
2022-06-04 13:13:36 source > 2022-06-04 13:13:35 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101380000
2022-06-04 13:13:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101380000 (21 GB)
2022-06-04 13:13:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101381000 (21 GB)
2022-06-04 13:13:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101382000 (21 GB)
2022-06-04 13:13:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101383000 (21 GB)
2022-06-04 13:13:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101384000 (21 GB)
2022-06-04 13:13:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101385000 (21 GB)
2022-06-04 13:13:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101386000 (21 GB)
2022-06-04 13:13:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101387000 (21 GB)
2022-06-04 13:13:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101388000 (21 GB)
2022-06-04 13:13:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101389000 (21 GB)
2022-06-04 13:13:38 source > 2022-06-04 13:13:37 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101390000
2022-06-04 13:13:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101390000 (21 GB)
2022-06-04 13:13:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101391000 (21 GB)
2022-06-04 13:13:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101392000 (21 GB)
2022-06-04 13:13:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101393000 (21 GB)
2022-06-04 13:13:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101394000 (21 GB)
2022-06-04 13:13:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101395000 (21 GB)
2022-06-04 13:13:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101396000 (21 GB)
2022-06-04 13:13:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101397000 (21 GB)
2022-06-04 13:13:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101398000 (21 GB)
2022-06-04 13:13:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101399000 (21 GB)
2022-06-04 13:13:40 source > 2022-06-04 13:13:39 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101400000
2022-06-04 13:13:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101400000 (21 GB)
2022-06-04 13:13:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101401000 (21 GB)
2022-06-04 13:13:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101402000 (21 GB)
2022-06-04 13:13:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101403000 (21 GB)
2022-06-04 13:13:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101404000 (21 GB)
2022-06-04 13:13:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101405000 (21 GB)
2022-06-04 13:13:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101406000 (21 GB)
2022-06-04 13:13:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101407000 (21 GB)
2022-06-04 13:13:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101408000 (21 GB)
2022-06-04 13:13:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101409000 (21 GB)
2022-06-04 13:13:43 source > 2022-06-04 13:13:41 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101410000
2022-06-04 13:13:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101410000 (21 GB)
2022-06-04 13:13:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101411000 (21 GB)
2022-06-04 13:13:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101412000 (21 GB)
2022-06-04 13:13:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101413000 (21 GB)
2022-06-04 13:13:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101414000 (21 GB)
2022-06-04 13:13:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101415000 (21 GB)
2022-06-04 13:13:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101416000 (21 GB)
2022-06-04 13:13:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101417000 (21 GB)
2022-06-04 13:13:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101418000 (21 GB)
2022-06-04 13:13:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101419000 (21 GB)
2022-06-04 13:13:46 source > 2022-06-04 13:13:44 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101420000
2022-06-04 13:13:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101420000 (21 GB)
2022-06-04 13:13:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101421000 (21 GB)
2022-06-04 13:13:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101422000 (21 GB)
2022-06-04 13:13:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101423000 (21 GB)
2022-06-04 13:13:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101424000 (21 GB)
2022-06-04 13:13:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101425000 (21 GB)
2022-06-04 13:13:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101426000 (21 GB)
2022-06-04 13:13:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101427000 (21 GB)
2022-06-04 13:13:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101428000 (21 GB)
2022-06-04 13:13:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101429000 (21 GB)
2022-06-04 13:13:49 source > 2022-06-04 13:13:48 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101430000
2022-06-04 13:13:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101430000 (21 GB)
2022-06-04 13:13:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101431000 (21 GB)
2022-06-04 13:13:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101432000 (21 GB)
2022-06-04 13:13:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101433000 (21 GB)
2022-06-04 13:13:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101434000 (21 GB)
2022-06-04 13:13:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101435000 (21 GB)
2022-06-04 13:13:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101436000 (21 GB)
2022-06-04 13:13:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101437000 (21 GB)
2022-06-04 13:13:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101438000 (21 GB)
2022-06-04 13:13:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101439000 (21 GB)
2022-06-04 13:13:52 source > 2022-06-04 13:13:50 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101440000
2022-06-04 13:13:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101440000 (21 GB)
2022-06-04 13:13:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101441000 (21 GB)
2022-06-04 13:13:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101442000 (21 GB)
2022-06-04 13:13:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101443000 (21 GB)
2022-06-04 13:13:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101444000 (21 GB)
2022-06-04 13:13:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101445000 (21 GB)
2022-06-04 13:13:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101446000 (21 GB)
2022-06-04 13:13:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101447000 (21 GB)
2022-06-04 13:13:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101448000 (21 GB)
2022-06-04 13:13:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101449000 (21 GB)
2022-06-04 13:13:54 source > 2022-06-04 13:13:53 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101450000
2022-06-04 13:13:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101450000 (21 GB)
2022-06-04 13:13:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101451000 (21 GB)
2022-06-04 13:13:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101452000 (21 GB)
2022-06-04 13:13:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101453000 (21 GB)
2022-06-04 13:13:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101454000 (21 GB)
2022-06-04 13:13:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101455000 (21 GB)
2022-06-04 13:13:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101456000 (21 GB)
2022-06-04 13:13:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101457000 (21 GB)
2022-06-04 13:13:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101458000 (21 GB)
2022-06-04 13:13:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101459000 (21 GB)
2022-06-04 13:13:56 source > 2022-06-04 13:13:55 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101460000
2022-06-04 13:13:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101460000 (21 GB)
2022-06-04 13:13:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101461000 (21 GB)
2022-06-04 13:13:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101462000 (21 GB)
2022-06-04 13:13:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101463000 (21 GB)
2022-06-04 13:13:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101464000 (21 GB)
2022-06-04 13:13:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101465000 (21 GB)
2022-06-04 13:13:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101466000 (21 GB)
2022-06-04 13:13:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101467000 (21 GB)
2022-06-04 13:13:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101468000 (21 GB)
2022-06-04 13:13:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101469000 (21 GB)
2022-06-04 13:13:58 source > 2022-06-04 13:13:57 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101470000
2022-06-04 13:13:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101470000 (21 GB)
2022-06-04 13:13:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101471000 (21 GB)
2022-06-04 13:13:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101472000 (21 GB)
2022-06-04 13:13:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101473000 (21 GB)
2022-06-04 13:13:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101474000 (21 GB)
2022-06-04 13:13:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101475000 (21 GB)
2022-06-04 13:14:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101476000 (21 GB)
2022-06-04 13:14:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101477000 (21 GB)
2022-06-04 13:14:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101478000 (21 GB)
2022-06-04 13:14:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101479000 (21 GB)
2022-06-04 13:14:00 source > 2022-06-04 13:13:59 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101480000
2022-06-04 13:14:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101480000 (21 GB)
2022-06-04 13:14:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101481000 (21 GB)
2022-06-04 13:14:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101482000 (21 GB)
2022-06-04 13:14:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101483000 (21 GB)
2022-06-04 13:14:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101484000 (21 GB)
2022-06-04 13:14:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101485000 (21 GB)
2022-06-04 13:14:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101486000 (21 GB)
2022-06-04 13:14:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101487000 (21 GB)
2022-06-04 13:14:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101488000 (21 GB)
2022-06-04 13:14:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101489000 (21 GB)
2022-06-04 13:14:02 source > 2022-06-04 13:14:01 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101490000
2022-06-04 13:14:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101490000 (21 GB)
2022-06-04 13:14:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101491000 (21 GB)
2022-06-04 13:14:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101492000 (21 GB)
2022-06-04 13:14:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101493000 (21 GB)
2022-06-04 13:14:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101494000 (21 GB)
2022-06-04 13:14:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101495000 (21 GB)
2022-06-04 13:14:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101496000 (21 GB)
2022-06-04 13:14:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101497000 (21 GB)
2022-06-04 13:14:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101498000 (21 GB)
2022-06-04 13:14:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101499000 (21 GB)
2022-06-04 13:14:04 source > 2022-06-04 13:14:03 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101500000
2022-06-04 13:14:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101500000 (21 GB)
2022-06-04 13:14:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101501000 (21 GB)
2022-06-04 13:14:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101502000 (21 GB)
2022-06-04 13:14:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101503000 (21 GB)
2022-06-04 13:14:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101504000 (21 GB)
2022-06-04 13:14:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101505000 (21 GB)
2022-06-04 13:14:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101506000 (21 GB)
2022-06-04 13:14:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101507000 (21 GB)
2022-06-04 13:14:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101508000 (21 GB)
2022-06-04 13:14:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101509000 (21 GB)
2022-06-04 13:14:06 source > 2022-06-04 13:14:05 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101510000
2022-06-04 13:14:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101510000 (21 GB)
2022-06-04 13:14:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101511000 (21 GB)
2022-06-04 13:14:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101512000 (21 GB)
2022-06-04 13:14:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101513000 (21 GB)
2022-06-04 13:14:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101514000 (21 GB)
2022-06-04 13:14:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101515000 (21 GB)
2022-06-04 13:14:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101516000 (21 GB)
2022-06-04 13:14:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101517000 (21 GB)
2022-06-04 13:14:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101518000 (21 GB)
2022-06-04 13:14:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101519000 (21 GB)
2022-06-04 13:14:08 source > 2022-06-04 13:14:07 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101520000
2022-06-04 13:14:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101520000 (21 GB)
2022-06-04 13:14:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101521000 (21 GB)
2022-06-04 13:14:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101522000 (21 GB)
2022-06-04 13:14:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101523000 (21 GB)
2022-06-04 13:14:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101524000 (21 GB)
2022-06-04 13:14:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101525000 (21 GB)
2022-06-04 13:14:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101526000 (21 GB)
2022-06-04 13:14:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101527000 (21 GB)
2022-06-04 13:14:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101528000 (21 GB)
2022-06-04 13:14:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101529000 (21 GB)
2022-06-04 13:14:10 source > 2022-06-04 13:14:09 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101530000
2022-06-04 13:14:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101530000 (21 GB)
2022-06-04 13:14:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101531000 (21 GB)
2022-06-04 13:14:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101532000 (21 GB)
2022-06-04 13:14:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101533000 (21 GB)
2022-06-04 13:14:10 destination > 2022-06-04 13:14:10 INFO i.a.i.d.r.SerializedBufferingStrategy(flushWriter):82 - Flushing buffer of stream training_sessions (200 MB)
2022-06-04 13:14:10 destination > 2022-06-04 13:14:10 INFO i.a.i.d.b.BigQueryStagingConsumerFactory(lambda$flushBufferFunction$4):115 - Flushing buffer for stream training_sessions (200 MB) to staging
2022-06-04 13:14:10 destination > 2022-06-04 13:14:10 INFO i.a.i.d.r.BaseSerializedBuffer(flush):138 - Finished writing data to 93e9c8e5-48e9-4d3a-a33a-23f1d90e94cd16085512368528710243.avro (200 MB)
2022-06-04 13:14:10 destination > 2022-06-04 13:14:10 INFO i.a.i.d.b.BigQueryGcsOperations(uploadRecordsToStage):108 - Uploading records to staging for stream training_sessions (dataset training_sessions): prod/training_sessions_training_sessions/2022/06/04/07/16480f42-7450-42f5-abcb-94a1da8db855/
2022-06-04 13:14:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101534000 (21 GB)
2022-06-04 13:14:10 destination > 2022-06-04 13:14:10 INFO i.a.i.d.s.u.StreamTransferManagerHelper(getDefault):60 - PartSize arg is set to 256 MB
2022-06-04 13:14:10 destination > 2022-06-04 13:14:10 INFO a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - Initiated multipart upload to airbyte-prod/prod/training_sessions_training_sessions/2022/06/04/07/16480f42-7450-42f5-abcb-94a1da8db855/134.avro with full ID ABPnzm7-HOy8gvuP7kOHdgNIEDhxfPigI0BoRo9u6jtSeRN7zDSUIBy0Jnxp4uOje1KwxQA
2022-06-04 13:14:11 destination > 2022-06-04 13:14:11 INFO a.m.s.MultiPartOutputStream(close):158 - Called close() on [MultipartOutputStream for parts 1 - 10000]
2022-06-04 13:14:13 destination > 2022-06-04 13:14:13 INFO a.m.s.StreamTransferManager(uploadStreamPart):558 - [Manager uploading to airbyte-prod/prod/training_sessions_training_sessions/2022/06/04/07/16480f42-7450-42f5-abcb-94a1da8db855/134.avro with id ABPnzm7-H...Oje1KwxQA]: Finished uploading [Part number 1 containing 200.04 MB]
2022-06-04 13:14:14 destination > 2022-06-04 13:14:14 INFO a.m.s.StreamTransferManager(complete):395 - [Manager uploading to airbyte-prod/prod/training_sessions_training_sessions/2022/06/04/07/16480f42-7450-42f5-abcb-94a1da8db855/134.avro with id ABPnzm7-H...Oje1KwxQA]: Completed
2022-06-04 13:14:14 destination > 2022-06-04 13:14:14 INFO i.a.i.d.s.S3StorageOperations(loadDataIntoBucket):176 - Uploaded buffer file to storage: 93e9c8e5-48e9-4d3a-a33a-23f1d90e94cd16085512368528710243.avro -> prod/training_sessions_training_sessions/2022/06/04/07/16480f42-7450-42f5-abcb-94a1da8db855/134.avro (filename: 134.avro)
2022-06-04 13:14:14 destination > 2022-06-04 13:14:14 INFO i.a.i.d.b.BigQueryWriteConfig(addStagedFile):53 - Added staged file: 134.avro
2022-06-04 13:14:14 destination > 2022-06-04 13:14:14 INFO i.a.i.d.r.FileBuffer(deleteFile):81 - Deleting tempFile data 93e9c8e5-48e9-4d3a-a33a-23f1d90e94cd16085512368528710243.avro
2022-06-04 13:14:14 destination > 2022-06-04 13:14:14 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):55 - Starting a new buffer for stream training_sessions (current state: -45426 bytes in 0 buffers)
2022-06-04 13:14:14 destination > 2022-06-04 13:14:14 INFO i.a.i.d.g.u.GcsUtils(getDefaultAvroSchema):25 - Default schema.
2022-06-04 13:14:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101535000 (21 GB)
2022-06-04 13:14:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101536000 (21 GB)
2022-06-04 13:14:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101537000 (21 GB)
2022-06-04 13:14:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101538000 (21 GB)
2022-06-04 13:14:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101539000 (21 GB)
2022-06-04 13:14:15 source > 2022-06-04 13:14:10 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101540000
2022-06-04 13:14:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101540000 (21 GB)
2022-06-04 13:14:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101541000 (21 GB)
2022-06-04 13:14:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101542000 (21 GB)
2022-06-04 13:14:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101543000 (21 GB)
2022-06-04 13:14:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101544000 (21 GB)
2022-06-04 13:14:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101545000 (21 GB)
2022-06-04 13:14:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101546000 (21 GB)
2022-06-04 13:14:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101547000 (21 GB)
2022-06-04 13:14:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101548000 (21 GB)
2022-06-04 13:14:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101549000 (21 GB)
2022-06-04 13:14:17 source > 2022-06-04 13:14:16 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101550000
2022-06-04 13:14:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101550000 (21 GB)
2022-06-04 13:14:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101551000 (21 GB)
2022-06-04 13:14:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101552000 (21 GB)
2022-06-04 13:14:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101553000 (21 GB)
2022-06-04 13:14:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101554000 (21 GB)
2022-06-04 13:14:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101555000 (21 GB)
2022-06-04 13:14:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101556000 (21 GB)
2022-06-04 13:14:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101557000 (21 GB)
2022-06-04 13:14:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101558000 (21 GB)
2022-06-04 13:14:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101559000 (21 GB)
2022-06-04 13:14:19 source > 2022-06-04 13:14:18 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101560000
2022-06-04 13:14:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101560000 (21 GB)
2022-06-04 13:14:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101561000 (21 GB)
2022-06-04 13:14:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101562000 (21 GB)
2022-06-04 13:14:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101563000 (21 GB)
2022-06-04 13:14:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101564000 (21 GB)
2022-06-04 13:14:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101565000 (21 GB)
2022-06-04 13:14:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101566000 (21 GB)
2022-06-04 13:14:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101567000 (21 GB)
2022-06-04 13:14:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101568000 (21 GB)
2022-06-04 13:14:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101569000 (21 GB)
2022-06-04 13:14:22 source > 2022-06-04 13:14:20 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101570000
2022-06-04 13:14:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101570000 (21 GB)
2022-06-04 13:14:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101571000 (21 GB)
2022-06-04 13:14:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101572000 (21 GB)
2022-06-04 13:14:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101573000 (21 GB)
2022-06-04 13:14:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101574000 (21 GB)
2022-06-04 13:14:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101575000 (21 GB)
2022-06-04 13:14:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101576000 (21 GB)
2022-06-04 13:14:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101577000 (21 GB)
2022-06-04 13:14:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101578000 (21 GB)
2022-06-04 13:14:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101579000 (21 GB)
2022-06-04 13:14:24 source > 2022-06-04 13:14:23 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101580000
2022-06-04 13:14:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101580000 (21 GB)
2022-06-04 13:14:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101581000 (21 GB)
2022-06-04 13:14:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101582000 (21 GB)
2022-06-04 13:14:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101583000 (21 GB)
2022-06-04 13:14:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101584000 (21 GB)
2022-06-04 13:14:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101585000 (21 GB)
2022-06-04 13:14:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101586000 (21 GB)
2022-06-04 13:14:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101587000 (21 GB)
2022-06-04 13:14:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101588000 (21 GB)
2022-06-04 13:14:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101589000 (21 GB)
2022-06-04 13:14:27 source > 2022-06-04 13:14:25 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101590000
2022-06-04 13:14:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101590000 (21 GB)
2022-06-04 13:14:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101591000 (21 GB)
2022-06-04 13:14:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101592000 (21 GB)
2022-06-04 13:14:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101593000 (21 GB)
2022-06-04 13:14:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101594000 (21 GB)
2022-06-04 13:14:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101595000 (21 GB)
2022-06-04 13:14:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101596000 (21 GB)
2022-06-04 13:14:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101597000 (21 GB)
2022-06-04 13:14:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101598000 (21 GB)
2022-06-04 13:14:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101599000 (21 GB)
2022-06-04 13:14:29 source > 2022-06-04 13:14:28 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101600000
2022-06-04 13:14:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101600000 (21 GB)
2022-06-04 13:14:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101601000 (21 GB)
2022-06-04 13:14:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101602000 (21 GB)
2022-06-04 13:14:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101603000 (21 GB)
2022-06-04 13:14:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101604000 (21 GB)
2022-06-04 13:14:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101605000 (21 GB)
2022-06-04 13:14:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101606000 (21 GB)
2022-06-04 13:14:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101607000 (21 GB)
2022-06-04 13:14:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101608000 (21 GB)
2022-06-04 13:14:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101609000 (21 GB)
2022-06-04 13:14:31 source > 2022-06-04 13:14:30 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101610000
2022-06-04 13:14:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101610000 (21 GB)
2022-06-04 13:14:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101611000 (21 GB)
2022-06-04 13:14:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101612000 (21 GB)
2022-06-04 13:14:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101613000 (21 GB)
2022-06-04 13:14:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101614000 (21 GB)
2022-06-04 13:14:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101615000 (21 GB)
2022-06-04 13:14:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101616000 (21 GB)
2022-06-04 13:14:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101617000 (21 GB)
2022-06-04 13:14:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101618000 (21 GB)
2022-06-04 13:14:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101619000 (21 GB)
2022-06-04 13:14:34 source > 2022-06-04 13:14:33 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101620000
2022-06-04 13:14:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101620000 (21 GB)
2022-06-04 13:14:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101621000 (21 GB)
2022-06-04 13:14:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101622000 (21 GB)
2022-06-04 13:14:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101623000 (21 GB)
2022-06-04 13:14:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101624000 (21 GB)
2022-06-04 13:14:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101625000 (21 GB)
2022-06-04 13:14:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101626000 (21 GB)
2022-06-04 13:14:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101627000 (21 GB)
2022-06-04 13:14:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101628000 (21 GB)
2022-06-04 13:14:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101629000 (21 GB)
2022-06-04 13:14:36 source > 2022-06-04 13:14:35 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101630000
2022-06-04 13:14:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101630000 (21 GB)
2022-06-04 13:14:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101631000 (21 GB)
2022-06-04 13:14:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101632000 (21 GB)
2022-06-04 13:14:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101633000 (21 GB)
2022-06-04 13:14:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101634000 (21 GB)
2022-06-04 13:14:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101635000 (21 GB)
2022-06-04 13:14:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101636000 (21 GB)
2022-06-04 13:14:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101637000 (21 GB)
2022-06-04 13:14:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101638000 (21 GB)
2022-06-04 13:14:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101639000 (21 GB)
2022-06-04 13:14:38 source > 2022-06-04 13:14:37 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101640000
2022-06-04 13:14:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101640000 (21 GB)
2022-06-04 13:14:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101641000 (21 GB)
2022-06-04 13:14:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101642000 (21 GB)
2022-06-04 13:14:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101643000 (21 GB)
2022-06-04 13:14:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101644000 (21 GB)
2022-06-04 13:14:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101645000 (21 GB)
2022-06-04 13:14:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101646000 (21 GB)
2022-06-04 13:14:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101647000 (21 GB)
2022-06-04 13:14:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101648000 (21 GB)
2022-06-04 13:14:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101649000 (21 GB)
2022-06-04 13:14:40 source > 2022-06-04 13:14:39 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101650000
2022-06-04 13:14:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101650000 (21 GB)
2022-06-04 13:14:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101651000 (21 GB)
2022-06-04 13:14:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101652000 (21 GB)
2022-06-04 13:14:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101653000 (21 GB)
2022-06-04 13:14:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101654000 (21 GB)
2022-06-04 13:14:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101655000 (21 GB)
2022-06-04 13:14:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101656000 (21 GB)
2022-06-04 13:14:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101657000 (21 GB)
2022-06-04 13:14:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101658000 (21 GB)
2022-06-04 13:14:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101659000 (21 GB)
2022-06-04 13:14:42 source > 2022-06-04 13:14:40 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101660000
2022-06-04 13:14:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101660000 (21 GB)
2022-06-04 13:14:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101661000 (21 GB)
2022-06-04 13:14:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101662000 (21 GB)
2022-06-04 13:14:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101663000 (21 GB)
2022-06-04 13:14:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101664000 (21 GB)
2022-06-04 13:14:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101665000 (21 GB)
2022-06-04 13:14:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101666000 (21 GB)
2022-06-04 13:14:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101667000 (21 GB)
2022-06-04 13:14:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101668000 (21 GB)
2022-06-04 13:14:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101669000 (21 GB)
2022-06-04 13:14:44 source > 2022-06-04 13:14:43 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101670000
2022-06-04 13:14:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101670000 (21 GB)
2022-06-04 13:14:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101671000 (21 GB)
2022-06-04 13:14:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101672000 (21 GB)
2022-06-04 13:14:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101673000 (21 GB)
2022-06-04 13:14:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101674000 (21 GB)
2022-06-04 13:14:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101675000 (21 GB)
2022-06-04 13:14:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101676000 (21 GB)
2022-06-04 13:14:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101677000 (21 GB)
2022-06-04 13:14:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101678000 (21 GB)
2022-06-04 13:14:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101679000 (21 GB)
2022-06-04 13:14:46 source > 2022-06-04 13:14:45 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101680000
2022-06-04 13:14:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101680000 (21 GB)
2022-06-04 13:14:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101681000 (21 GB)
2022-06-04 13:14:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101682000 (21 GB)
2022-06-04 13:14:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101683000 (21 GB)
2022-06-04 13:14:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101684000 (21 GB)
2022-06-04 13:14:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101685000 (21 GB)
2022-06-04 13:14:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101686000 (21 GB)
2022-06-04 13:14:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101687000 (21 GB)
2022-06-04 13:14:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101688000 (21 GB)
2022-06-04 13:14:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101689000 (21 GB)
2022-06-04 13:14:47 source > 2022-06-04 13:14:47 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101690000
2022-06-04 13:14:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101690000 (21 GB)
2022-06-04 13:14:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101691000 (21 GB)
2022-06-04 13:14:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101692000 (21 GB)
2022-06-04 13:14:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101693000 (21 GB)
2022-06-04 13:14:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101694000 (21 GB)
2022-06-04 13:14:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101695000 (21 GB)
2022-06-04 13:14:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101696000 (21 GB)
2022-06-04 13:14:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101697000 (21 GB)
2022-06-04 13:14:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101698000 (21 GB)
2022-06-04 13:14:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101699000 (21 GB)
2022-06-04 13:14:49 source > 2022-06-04 13:14:48 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101700000
2022-06-04 13:14:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101700000 (21 GB)
2022-06-04 13:14:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101701000 (21 GB)
2022-06-04 13:14:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101702000 (21 GB)
2022-06-04 13:14:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101703000 (21 GB)
2022-06-04 13:14:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101704000 (21 GB)
2022-06-04 13:14:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101705000 (21 GB)
2022-06-04 13:14:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101706000 (21 GB)
2022-06-04 13:14:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101707000 (21 GB)
2022-06-04 13:14:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101708000 (21 GB)
2022-06-04 13:14:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101709000 (21 GB)
2022-06-04 13:14:51 source > 2022-06-04 13:14:50 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101710000
2022-06-04 13:14:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101710000 (21 GB)
2022-06-04 13:14:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101711000 (21 GB)
2022-06-04 13:14:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101712000 (21 GB)
2022-06-04 13:14:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101713000 (21 GB)
2022-06-04 13:14:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101714000 (21 GB)
2022-06-04 13:14:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101715000 (21 GB)
2022-06-04 13:14:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101716000 (21 GB)
2022-06-04 13:14:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101717000 (21 GB)
2022-06-04 13:14:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101718000 (21 GB)
2022-06-04 13:14:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101719000 (21 GB)
2022-06-04 13:14:53 source > 2022-06-04 13:14:52 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101720000
2022-06-04 13:14:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101720000 (21 GB)
2022-06-04 13:14:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101721000 (21 GB)
2022-06-04 13:14:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101722000 (21 GB)
2022-06-04 13:14:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101723000 (21 GB)
2022-06-04 13:14:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101724000 (21 GB)
2022-06-04 13:14:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101725000 (21 GB)
2022-06-04 13:14:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101726000 (21 GB)
2022-06-04 13:14:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101727000 (21 GB)
2022-06-04 13:14:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101728000 (21 GB)
2022-06-04 13:14:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101729000 (21 GB)
2022-06-04 13:14:55 source > 2022-06-04 13:14:54 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101730000
2022-06-04 13:14:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101730000 (21 GB)
2022-06-04 13:14:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101731000 (21 GB)
2022-06-04 13:14:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101732000 (21 GB)
2022-06-04 13:14:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101733000 (21 GB)
2022-06-04 13:14:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101734000 (21 GB)
2022-06-04 13:14:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101735000 (21 GB)
2022-06-04 13:14:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101736000 (21 GB)
2022-06-04 13:14:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101737000 (21 GB)
2022-06-04 13:14:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101738000 (21 GB)
2022-06-04 13:14:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101739000 (21 GB)
2022-06-04 13:14:57 source > 2022-06-04 13:14:56 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101740000
2022-06-04 13:14:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101740000 (21 GB)
2022-06-04 13:14:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101741000 (21 GB)
2022-06-04 13:14:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101742000 (21 GB)
2022-06-04 13:14:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101743000 (21 GB)
2022-06-04 13:14:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101744000 (21 GB)
2022-06-04 13:14:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101745000 (21 GB)
2022-06-04 13:14:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101746000 (21 GB)
2022-06-04 13:14:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101747000 (21 GB)
2022-06-04 13:14:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101748000 (21 GB)
2022-06-04 13:14:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101749000 (21 GB)
2022-06-04 13:14:59 source > 2022-06-04 13:14:58 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101750000
2022-06-04 13:14:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101750000 (21 GB)
2022-06-04 13:14:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101751000 (21 GB)
2022-06-04 13:14:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101752000 (21 GB)
2022-06-04 13:14:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101753000 (21 GB)
2022-06-04 13:15:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101754000 (21 GB)
2022-06-04 13:15:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101755000 (21 GB)
2022-06-04 13:15:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101756000 (21 GB)
2022-06-04 13:15:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101757000 (21 GB)
2022-06-04 13:15:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101758000 (21 GB)
2022-06-04 13:15:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101759000 (21 GB)
2022-06-04 13:15:01 source > 2022-06-04 13:15:00 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101760000
2022-06-04 13:15:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101760000 (21 GB)
2022-06-04 13:15:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101761000 (21 GB)
2022-06-04 13:15:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101762000 (21 GB)
2022-06-04 13:15:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101763000 (21 GB)
2022-06-04 13:15:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101764000 (21 GB)
2022-06-04 13:15:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101765000 (21 GB)
2022-06-04 13:15:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101766000 (21 GB)
2022-06-04 13:15:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101767000 (21 GB)
2022-06-04 13:15:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101768000 (21 GB)
2022-06-04 13:15:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101769000 (21 GB)
2022-06-04 13:15:03 source > 2022-06-04 13:15:02 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101770000
2022-06-04 13:15:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101770000 (21 GB)
2022-06-04 13:15:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101771000 (21 GB)
2022-06-04 13:15:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101772000 (21 GB)
2022-06-04 13:15:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101773000 (21 GB)
2022-06-04 13:15:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101774000 (21 GB)
2022-06-04 13:15:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101775000 (21 GB)
2022-06-04 13:15:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101776000 (21 GB)
2022-06-04 13:15:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101777000 (21 GB)
2022-06-04 13:15:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101778000 (21 GB)
2022-06-04 13:15:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101779000 (21 GB)
2022-06-04 13:15:05 source > 2022-06-04 13:15:04 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101780000
2022-06-04 13:15:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101780000 (21 GB)
2022-06-04 13:15:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101781000 (21 GB)
2022-06-04 13:15:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101782000 (21 GB)
2022-06-04 13:15:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101783000 (21 GB)
2022-06-04 13:15:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101784000 (21 GB)
2022-06-04 13:15:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101785000 (21 GB)
2022-06-04 13:15:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101786000 (21 GB)
2022-06-04 13:15:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101787000 (21 GB)
2022-06-04 13:15:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101788000 (21 GB)
2022-06-04 13:15:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101789000 (21 GB)
2022-06-04 13:15:09 source > 2022-06-04 13:15:07 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101790000
2022-06-04 13:15:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101790000 (21 GB)
2022-06-04 13:15:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101791000 (21 GB)
2022-06-04 13:15:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101792000 (21 GB)
2022-06-04 13:15:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101793000 (21 GB)
2022-06-04 13:15:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101794000 (21 GB)
2022-06-04 13:15:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101795000 (21 GB)
2022-06-04 13:15:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101796000 (21 GB)
2022-06-04 13:15:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101797000 (21 GB)
2022-06-04 13:15:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101798000 (21 GB)
2022-06-04 13:15:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101799000 (21 GB)
2022-06-04 13:15:13 source > 2022-06-04 13:15:11 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101800000
2022-06-04 13:15:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101800000 (21 GB)
2022-06-04 13:15:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101801000 (21 GB)
2022-06-04 13:15:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101802000 (21 GB)
2022-06-04 13:15:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101803000 (21 GB)
2022-06-04 13:15:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101804000 (21 GB)
2022-06-04 13:15:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101805000 (21 GB)
2022-06-04 13:15:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101806000 (21 GB)
2022-06-04 13:15:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101807000 (21 GB)
2022-06-04 13:15:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101808000 (21 GB)
2022-06-04 13:15:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101809000 (21 GB)
2022-06-04 13:15:18 source > 2022-06-04 13:15:15 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101810000
2022-06-04 13:15:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101810000 (21 GB)
2022-06-04 13:15:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101811000 (21 GB)
2022-06-04 13:15:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101812000 (21 GB)
2022-06-04 13:15:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101813000 (21 GB)
2022-06-04 13:15:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101814000 (21 GB)
2022-06-04 13:15:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101815000 (21 GB)
2022-06-04 13:15:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101816000 (21 GB)
2022-06-04 13:15:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101817000 (21 GB)
2022-06-04 13:15:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101818000 (21 GB)
2022-06-04 13:15:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101819000 (21 GB)
2022-06-04 13:15:22 source > 2022-06-04 13:15:21 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101820000
2022-06-04 13:15:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101820000 (21 GB)
2022-06-04 13:15:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101821000 (21 GB)
2022-06-04 13:15:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101822000 (21 GB)
2022-06-04 13:15:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101823000 (21 GB)
2022-06-04 13:15:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101824000 (21 GB)
2022-06-04 13:15:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101825000 (21 GB)
2022-06-04 13:15:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101826000 (21 GB)
2022-06-04 13:15:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101827000 (21 GB)
2022-06-04 13:15:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101828000 (21 GB)
2022-06-04 13:15:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101829000 (21 GB)
2022-06-04 13:15:30 source > 2022-06-04 13:15:25 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101830000
2022-06-04 13:15:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101830000 (21 GB)
2022-06-04 13:15:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101831000 (21 GB)
2022-06-04 13:15:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101832000 (21 GB)
2022-06-04 13:15:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101833000 (21 GB)
2022-06-04 13:15:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101834000 (21 GB)
2022-06-04 13:15:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101835000 (21 GB)
2022-06-04 13:15:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101836000 (21 GB)
2022-06-04 13:15:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101837000 (21 GB)
2022-06-04 13:15:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101838000 (21 GB)
2022-06-04 13:15:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101839000 (21 GB)
2022-06-04 13:15:39 source > 2022-06-04 13:15:35 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101840000
2022-06-04 13:15:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101840000 (21 GB)
2022-06-04 13:15:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101841000 (21 GB)
2022-06-04 13:15:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101842000 (21 GB)
2022-06-04 13:15:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101843000 (21 GB)
2022-06-04 13:15:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101844000 (21 GB)
2022-06-04 13:15:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101845000 (21 GB)
2022-06-04 13:15:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101846000 (21 GB)
2022-06-04 13:15:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101847000 (21 GB)
2022-06-04 13:15:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101848000 (21 GB)
2022-06-04 13:15:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101849000 (21 GB)
2022-06-04 13:15:45 source > 2022-06-04 13:15:42 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101850000
2022-06-04 13:15:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101850000 (21 GB)
2022-06-04 13:15:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101851000 (21 GB)
2022-06-04 13:15:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101852000 (21 GB)
2022-06-04 13:15:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101853000 (21 GB)
2022-06-04 13:15:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101854000 (21 GB)
2022-06-04 13:15:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101855000 (21 GB)
2022-06-04 13:15:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101856000 (21 GB)
2022-06-04 13:15:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101857000 (21 GB)
2022-06-04 13:15:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101858000 (21 GB)
2022-06-04 13:15:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101859000 (21 GB)
2022-06-04 13:15:50 source > 2022-06-04 13:15:48 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101860000
2022-06-04 13:15:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101860000 (21 GB)
2022-06-04 13:15:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101861000 (21 GB)
2022-06-04 13:15:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101862000 (21 GB)
2022-06-04 13:15:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101863000 (21 GB)
2022-06-04 13:15:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101864000 (21 GB)
2022-06-04 13:15:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101865000 (21 GB)
2022-06-04 13:15:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101866000 (21 GB)
2022-06-04 13:15:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101867000 (21 GB)
2022-06-04 13:15:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101868000 (21 GB)
2022-06-04 13:15:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101869000 (21 GB)
2022-06-04 13:15:55 source > 2022-06-04 13:15:53 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101870000
2022-06-04 13:15:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101870000 (21 GB)
2022-06-04 13:15:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101871000 (21 GB)
2022-06-04 13:15:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101872000 (21 GB)
2022-06-04 13:15:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101873000 (21 GB)
2022-06-04 13:15:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101874000 (21 GB)
2022-06-04 13:15:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101875000 (21 GB)
2022-06-04 13:15:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101876000 (21 GB)
2022-06-04 13:15:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101877000 (21 GB)
2022-06-04 13:15:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101878000 (21 GB)
2022-06-04 13:15:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101879000 (21 GB)
2022-06-04 13:15:58 source > 2022-06-04 13:15:57 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101880000
2022-06-04 13:15:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101880000 (21 GB)
2022-06-04 13:15:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101881000 (21 GB)
2022-06-04 13:15:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101882000 (21 GB)
2022-06-04 13:15:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101883000 (21 GB)
2022-06-04 13:15:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101884000 (21 GB)
2022-06-04 13:16:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101885000 (21 GB)
2022-06-04 13:16:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101886000 (21 GB)
2022-06-04 13:16:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101887000 (21 GB)
2022-06-04 13:16:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101888000 (21 GB)
2022-06-04 13:16:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101889000 (21 GB)
2022-06-04 13:16:01 source > 2022-06-04 13:15:59 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101890000
2022-06-04 13:16:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101890000 (21 GB)
2022-06-04 13:16:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101891000 (21 GB)
2022-06-04 13:16:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101892000 (21 GB)
2022-06-04 13:16:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101893000 (21 GB)
2022-06-04 13:16:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101894000 (21 GB)
2022-06-04 13:16:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101895000 (21 GB)
2022-06-04 13:16:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101896000 (21 GB)
2022-06-04 13:16:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101897000 (21 GB)
2022-06-04 13:16:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101898000 (21 GB)
2022-06-04 13:16:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101899000 (21 GB)
2022-06-04 13:16:05 source > 2022-06-04 13:16:02 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101900000
2022-06-04 13:16:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101900000 (21 GB)
2022-06-04 13:16:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101901000 (21 GB)
2022-06-04 13:16:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101902000 (21 GB)
2022-06-04 13:16:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101903000 (21 GB)
2022-06-04 13:16:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101904000 (21 GB)
2022-06-04 13:16:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101905000 (21 GB)
2022-06-04 13:16:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101906000 (21 GB)
2022-06-04 13:16:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101907000 (21 GB)
2022-06-04 13:16:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101908000 (21 GB)
2022-06-04 13:16:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101909000 (21 GB)
2022-06-04 13:16:09 source > 2022-06-04 13:16:07 INFO i.a.i.s.r.AbstractDbSource(lambda$createReadIterator$7):250 - Reading stream training_sessions. Records read: 101910000
2022-06-04 13:16:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101910000 (21 GB)
2022-06-04 13:16:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101911000 (21 GB)
2022-06-04 13:16:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101912000 (21 GB)
2022-06-04 13:16:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):331 - Records read: 101913000 (21 GB)
2022-06-04 13:34:32 ERROR i.a.w.DefaultReplicationWorker(run):174 - Sync worker failed.
java.util.concurrent.ExecutionException: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process message delivery failed
	at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) ~[?:?]
	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) ~[?:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:167) ~[io.airbyte-airbyte-workers-0.38.4-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:59) ~[io.airbyte-airbyte-workers-0.38.4-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:158) ~[io.airbyte-airbyte-workers-0.38.4-alpha.jar:?]
	at java.lang.Thread.run(Thread.java:833) [?:?]
	Suppressed: io.airbyte.workers.WorkerException: Source process exit with code 137. This warning is normal if the job was cancelled.
		at io.airbyte.workers.protocols.airbyte.DefaultAirbyteSource.close(DefaultAirbyteSource.java:136) ~[io.airbyte-airbyte-workers-0.38.4-alpha.jar:?]
		at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:131) ~[io.airbyte-airbyte-workers-0.38.4-alpha.jar:?]
		at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:59) ~[io.airbyte-airbyte-workers-0.38.4-alpha.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:158) ~[io.airbyte-airbyte-workers-0.38.4-alpha.jar:?]
		at java.lang.Thread.run(Thread.java:833) [?:?]
	Suppressed: java.io.IOException: Stream closed
		at java.lang.ProcessBuilder$NullOutputStream.write(ProcessBuilder.java:445) ~[?:?]
		at java.io.OutputStream.write(OutputStream.java:162) ~[?:?]
		at java.io.BufferedOutputStream.write(BufferedOutputStream.java:123) ~[?:?]
		at sun.nio.cs.StreamEncoder.writeBytes(StreamEncoder.java:234) ~[?:?]
		at sun.nio.cs.StreamEncoder.implFlushBuffer(StreamEncoder.java:313) ~[?:?]
		at sun.nio.cs.StreamEncoder.implFlush(StreamEncoder.java:318) ~[?:?]
		at sun.nio.cs.StreamEncoder.flush(StreamEncoder.java:160) ~[?:?]
		at java.io.OutputStreamWriter.flush(OutputStreamWriter.java:248) ~[?:?]
		at java.io.BufferedWriter.flush(BufferedWriter.java:257) ~[?:?]
		at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.notifyEndOfStream(DefaultAirbyteDestination.java:98) ~[io.airbyte-airbyte-workers-0.38.4-alpha.jar:?]
		at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.close(DefaultAirbyteDestination.java:111) ~[io.airbyte-airbyte-workers-0.38.4-alpha.jar:?]
		at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:131) ~[io.airbyte-airbyte-workers-0.38.4-alpha.jar:?]
		at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:59) ~[io.airbyte-airbyte-workers-0.38.4-alpha.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:158) ~[io.airbyte-airbyte-workers-0.38.4-alpha.jar:?]
		at java.lang.Thread.run(Thread.java:833) [?:?]
Caused by: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process message delivery failed
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$6(DefaultReplicationWorker.java:326) ~[io.airbyte-airbyte-workers-0.38.4-alpha.jar:?]
	at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
	... 1 more
Caused by: java.io.IOException: Stream closed
	at java.lang.ProcessBuilder$NullOutputStream.write(ProcessBuilder.java:445) ~[?:?]
	at java.io.OutputStream.write(OutputStream.java:162) ~[?:?]
	at java.io.BufferedOutputStream.write(BufferedOutputStream.java:123) ~[?:?]
	at sun.nio.cs.StreamEncoder.writeBytes(StreamEncoder.java:234) ~[?:?]
	at sun.nio.cs.StreamEncoder.implWrite(StreamEncoder.java:304) ~[?:?]
	at sun.nio.cs.StreamEncoder.implWrite(StreamEncoder.java:282) ~[?:?]
	at sun.nio.cs.StreamEncoder.write(StreamEncoder.java:132) ~[?:?]
	at java.io.OutputStreamWriter.write(OutputStreamWriter.java:205) ~[?:?]
	at java.io.BufferedWriter.flushBuffer(BufferedWriter.java:120) ~[?:?]
	at java.io.BufferedWriter.write(BufferedWriter.java:233) ~[?:?]
	at java.io.Writer.write(Writer.java:249) ~[?:?]
	at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.accept(DefaultAirbyteDestination.java:90) ~[io.airbyte-airbyte-workers-0.38.4-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$6(DefaultReplicationWorker.java:324) ~[io.airbyte-airbyte-workers-0.38.4-alpha.jar:?]
	at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
	... 1 more
2022-06-04 14:00:52 INFO i.a.w.DefaultReplicationWorker(run):233 - sync summary: io.airbyte.config.ReplicationAttemptSummary@506e3f36[status=failed,recordsSynced=101913017,bytesSynced=23616625143,startTime=1654329242278,endTime=1654350954466,totalStats=io.airbyte.config.SyncStats@5b0ff178[recordsEmitted=101913017,bytesEmitted=23616625143,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@600bdab9[streamName=training_sessions,stats=io.airbyte.config.SyncStats@3700c50d[recordsEmitted=101913017,bytesEmitted=23616625143,stateMessagesEmitted=<null>,recordsCommitted=<null>]]]]
2022-06-04 14:02:54 INFO i.a.w.DefaultReplicationWorker(run):262 - Source did not output any state messages
2022-06-04 14:05:15 WARN i.a.w.DefaultReplicationWorker(run):273 - State capture: No state retained.
2022-06-04 14:09:57 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-06-04 14:12:30 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):157 - sync summary: io.airbyte.config.StandardSyncOutput@1a6914d2[standardSyncSummary=io.airbyte.config.StandardSyncSummary@5f6b89fb[status=failed,recordsSynced=101913017,bytesSynced=23616625143,startTime=1654329242278,endTime=1654350954466,totalStats=io.airbyte.config.SyncStats@5b0ff178[recordsEmitted=101913017,bytesEmitted=23616625143,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@600bdab9[streamName=training_sessions,stats=io.airbyte.config.SyncStats@3700c50d[recordsEmitted=101913017,bytesEmitted=23616625143,stateMessagesEmitted=<null>,recordsCommitted=<null>]]]],normalizationSummary=<null>,state=<null>,outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@449c91db[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@6efe520b[stream=io.airbyte.protocol.models.AirbyteStream@3ce31482[name=training_sessions,jsonSchema={"type":"object","properties":{"id":{"type":"string"},"type":{"type":"number"},"score":{"type":"number"},"status":{"type":"number"},"success":{"type":"number"},"series_id":{"type":"number"},"created_at":{"type":"string"},"learner_id":{"type":"number"},"updated_at":{"type":"string"},"questions_count":{"type":"number"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=training_sessions,additionalProperties={}],syncMode=incremental,cursorField=[updated_at],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}]],additionalProperties={}],failures=[io.airbyte.config.FailureReason@3f4476b4[failureOrigin=destination,failureType=<null>,internalMessage=io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process message delivery failed,externalMessage=Something went wrong within the destination connector,metadata=io.airbyte.config.Metadata@1ff62ace[additionalProperties={attemptNumber=2, jobId=5553}],stacktrace=java.util.concurrent.CompletionException: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process message delivery failed
	at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:315)
	at java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:320)
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1807)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
	at java.base/java.lang.Thread.run(Thread.java:833)
Caused by: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process message delivery failed
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$6(DefaultReplicationWorker.java:326)
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
	... 3 more
Caused by: java.io.IOException: Stream closed
	at java.base/java.lang.ProcessBuilder$NullOutputStream.write(ProcessBuilder.java:445)
	at java.base/java.io.OutputStream.write(OutputStream.java:162)
	at java.base/java.io.BufferedOutputStream.write(BufferedOutputStream.java:123)
	at java.base/sun.nio.cs.StreamEncoder.writeBytes(StreamEncoder.java:234)
	at java.base/sun.nio.cs.StreamEncoder.implWrite(StreamEncoder.java:304)
	at java.base/sun.nio.cs.StreamEncoder.implWrite(StreamEncoder.java:282)
	at java.base/sun.nio.cs.StreamEncoder.write(StreamEncoder.java:132)
	at java.base/java.io.OutputStreamWriter.write(OutputStreamWriter.java:205)
	at java.base/java.io.BufferedWriter.flushBuffer(BufferedWriter.java:120)
	at java.base/java.io.BufferedWriter.write(BufferedWriter.java:233)
	at java.base/java.io.Writer.write(Writer.java:249)
	at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.accept(DefaultAirbyteDestination.java:90)
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$6(DefaultReplicationWorker.java:324)
	... 4 more
,retryable=<null>,timestamp=1654348732405]]]
2022-06-04 14:16:23 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):236 - Stopping temporal heartbeating...
2022-06-04 16:02:19 WARN i.t.i.r.GrpcSyncRetryer(retry):56 - Retrying after failure
io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 69.999963780s. [closed=[], open=[[remote_addr=airbyte-temporal/172.20.0.12:7233]]]
	at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:262) ~[grpc-stub-1.44.1.jar:1.44.1]
	at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:243) ~[grpc-stub-1.44.1.jar:1.44.1]
	at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:156) ~[grpc-stub-1.44.1.jar:1.44.1]
	at io.temporal.api.workflowservice.v1.WorkflowServiceGrpc$WorkflowServiceBlockingStub.getWorkflowExecutionHistory(WorkflowServiceGrpc.java:2642) ~[temporal-serviceclient-1.8.1.jar:?]
	at io.temporal.internal.client.WorkflowClientLongPollHelper.lambda$getInstanceCloseEvent$0(WorkflowClientLongPollHelper.java:143) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.retryer.GrpcSyncRetryer.retry(GrpcSyncRetryer.java:61) ~[temporal-serviceclient-1.8.1.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:51) ~[temporal-serviceclient-1.8.1.jar:?]
	at io.temporal.internal.client.WorkflowClientLongPollHelper.getInstanceCloseEvent(WorkflowClientLongPollHelper.java:131) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.client.WorkflowClientLongPollHelper.getWorkflowExecutionResult(WorkflowClientLongPollHelper.java:72) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.client.RootWorkflowClientInvoker.getResult(RootWorkflowClientInvoker.java:93) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.sync.WorkflowStubImpl.getResult(WorkflowStubImpl.java:243) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.sync.WorkflowStubImpl.getResult(WorkflowStubImpl.java:225) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.sync.WorkflowInvocationHandler$SyncWorkflowInvocationHandler.startWorkflow(WorkflowInvocationHandler.java:315) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.sync.WorkflowInvocationHandler$SyncWorkflowInvocationHandler.invoke(WorkflowInvocationHandler.java:270) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.sync.WorkflowInvocationHandler.invoke(WorkflowInvocationHandler.java:178) ~[temporal-sdk-1.8.1.jar:?]
	at jdk.proxy2.$Proxy41.run(Unknown Source) ~[?:?]
	at io.airbyte.workers.temporal.TemporalClient.lambda$submitSync$3(TemporalClient.java:151) ~[io.airbyte-airbyte-workers-0.38.4-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalClient.execute(TemporalClient.java:443) ~[io.airbyte-airbyte-workers-0.38.4-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalClient.submitSync(TemporalClient.java:150) ~[io.airbyte-airbyte-workers-0.38.4-alpha.jar:?]
	at io.airbyte.workers.worker_run.TemporalWorkerRunFactory.lambda$createSupplier$0(TemporalWorkerRunFactory.java:49) ~[io.airbyte-airbyte-workers-0.38.4-alpha.jar:?]
	at io.airbyte.workers.worker_run.WorkerRun.call(WorkerRun.java:51) [io.airbyte-airbyte-workers-0.38.4-alpha.jar:?]
	at io.airbyte.workers.worker_run.WorkerRun.call(WorkerRun.java:22) [io.airbyte-airbyte-workers-0.38.4-alpha.jar:?]
	at io.airbyte.commons.concurrency.LifecycledCallable.execute(LifecycledCallable.java:94) [io.airbyte-airbyte-commons-0.38.4-alpha.jar:?]
	at io.airbyte.commons.concurrency.LifecycledCallable.call(LifecycledCallable.java:78) [io.airbyte-airbyte-commons-0.38.4-alpha.jar:?]
	at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) [?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) [?:?]
	at java.lang.Thread.run(Thread.java:833) [?:?]