2023-01-13 06:50:32 source > exceptionCaught(MinaSession[local=/127.0.0.1:34469, remote=/127.0.0.1:41906]) EOFException: Queue is closed\
2023-01-13 06:50:32 source > Snapshot - Final stage\
2023-01-13 06:50:32 source > Producer failure\
Stack Trace: io.debezium.DebeziumException: java.lang.RuntimeException: org.postgresql.util.PSQLException: This connection has been closed.\
	at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:85)\
	at io.debezium.pipeline.ChangeEventSourceCoordinator.doSnapshot(ChangeEventSourceCoordinator.java:155)\
	at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:137)\
	at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:109)\
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)\
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)\
	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: java.lang.RuntimeException: org.postgresql.util.PSQLException: This connection has been closed.\
	at io.debezium.relational.RelationalSnapshotChangeEventSource.rollbackTransaction(RelationalSnapshotChangeEventSource.java:548)\
	at io.debezium.relational.RelationalSnapshotChangeEventSource.doExecute(RelationalSnapshotChangeEventSource.java:146)\
	at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:76)\
	... 8 more\
Caused by: org.postgresql.util.PSQLException: This connection has been closed.\
	at org.postgresql.jdbc.PgConnection.checkClosed(PgConnection.java:883)\
	at org.postgresql.jdbc.PgConnection.rollback(PgConnection.java:890)\
	at io.debezium.relational.RelationalSnapshotChangeEventSource.rollbackTransaction(RelationalSnapshotChangeEventSource.java:545)\
	... 10 more\
\
2023-01-13 06:50:32 source > Connected metrics set to 'false'\
2023-01-13 06:50:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):321 - Records read: 405619000 (251 GB)\
2023-01-13 06:50:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):321 - Records read: 405620000 (251 GB)\
2023-01-13 06:50:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):321 - Records read: 405621000 (251 GB)\
2023-01-13 06:50:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):321 - Records read: 405622000 (251 GB)\
2023-01-13 06:50:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):321 - Records read: 405623000 (251 GB)\
2023-01-13 06:50:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):321 - Records read: 405624000 (251 GB)\
2023-01-13 06:50:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):321 - Records read: 405625000 (251 GB)\
2023-01-13 06:50:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):321 - Records read: 405626000 (251 GB)\
2023-01-13 06:50:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):321 - Records read: 405627000 (251 GB)\
2023-01-13 06:50:33 source > Stopping the task and engine\
2023-01-13 06:50:33 source > Stopping down connector\
2023-01-13 06:50:33 source > Connection gracefully closed\
2023-01-13 06:50:33 source > Stopped FileOffsetBackingStore\
2023-01-13 06:50:33 source > Debezium engine shutdown.\
2023-01-13 06:50:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):321 - Records read: 405628000 (251 GB)\
2023-01-13 06:50:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):321 - Records read: 405629000 (251 GB)\
2023-01-13 06:50:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):321 - Records read: 405630000 (251 GB)\
2023-01-13 06:50:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):321 - Records read: 405631000 (251 GB)\
2023-01-13 06:50:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):321 - Records read: 405632000 (251 GB)\
2023-01-13 06:50:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):321 - Records read: 405633000 (251 GB)\
2023-01-13 06:50:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):321 - Records read: 405634000 (251 GB)\
2023-01-13 06:50:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):321 - Records read: 405635000 (251 GB)\
2023-01-13 06:50:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):321 - Records read: 405636000 (251 GB)\
2023-01-13 06:50:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):321 - Records read: 405637000 (251 GB)\
2023-01-13 06:51:34 source > Closing: queue returned null event\
2023-01-13 06:51:34 source > Stopping the embedded engine\
2023-01-13 06:51:34 source > The main thread is exiting while children non-daemon threads from a connector are still active.\
Ideally, this situation should not happen...\
Please check with maintainers if the connector or library code should safely clean up its threads before quitting instead.\
The main thread is: main (RUNNABLE)\
 Thread stacktrace: java.base/java.lang.Thread.getStackTrace(Thread.java:1610)\
        at io.airbyte.integrations.base.IntegrationRunner.dumpThread(IntegrationRunner.java:301)\
        at io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:249)\
        at io.airbyte.integrations.base.IntegrationRunner.produceMessages(IntegrationRunner.java:186)\
        at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:139)\
        at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:98)\
        at io.airbyte.integrations.base.adaptive.AdaptiveSourceRunner$Runner.run(AdaptiveSourceRunner.java:86)\
        at io.airbyte.integrations.source.postgres.PostgresSourceRunner.main(PostgresSourceRunner.java:15)\
2023-01-13 06:51:34 source > Active non-daemon thread: NioSocketAcceptor-2 (RUNNABLE)\
 Thread stacktrace: java.base@17.0.4.1/sun.nio.ch.EPoll.wait(Native Method)\
        at java.base@17.0.4.1/sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:118)\
        at java.base@17.0.4.1/sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:129)\
        at java.base@17.0.4.1/sun.nio.ch.SelectorImpl.select(SelectorImpl.java:146)\
        at app//org.apache.mina.transport.socket.nio.NioSocketAcceptor.select(NioSocketAcceptor.java:299)\
        at app//org.apache.mina.core.polling.AbstractPollingIoAcceptor$Acceptor.run(AbstractPollingIoAcceptor.java:466)\
        at app//org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:64)\
        at java.base@17.0.4.1/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)\
        at java.base@17.0.4.1/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)\
        at java.base@17.0.4.1/java.lang.Thread.run(Thread.java:833)\
2023-01-13 06:51:34 source > Closing: Iterator closing\
2023-01-13 06:51:34 source > exception while closing\
Stack Trace: java.lang.RuntimeException: Closing down debezium engine but snapshot has not finished\
	at io.airbyte.integrations.debezium.internals.DebeziumRecordIterator.throwExceptionIfSnapshotNotFinished(DebeziumRecordIterator.java:195)\
	at io.airbyte.integrations.debezium.internals.DebeziumRecordIterator.requestClose(DebeziumRecordIterator.java:190)\
	at io.airbyte.integrations.debezium.internals.DebeziumRecordIterator.close(DebeziumRecordIterator.java:176)\
	at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15)\
	at io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:49)\
	at io.airbyte.commons.util.CompositeIterator.close(CompositeIterator.java:91)\
	at io.airbyte.commons.util.CompositeIterator.close(CompositeIterator.java:91)\
	at io.airbyte.commons.util.AutoCloseableIterators.lambda$appendOnClose$0(AutoCloseableIterators.java:88)\
	at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15)\
	at io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:49)\
	at io.airbyte.commons.util.AutoCloseableIterators.lambda$appendOnClose$0(AutoCloseableIterators.java:88)\
	at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15)\
	at io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:49)\
	at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:138)\
	at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:98)\
	at io.airbyte.integrations.base.adaptive.AdaptiveSourceRunner$Runner.run(AdaptiveSourceRunner.java:86)\
	at io.airbyte.integrations.source.postgres.PostgresSourceRunner.main(PostgresSourceRunner.java:15)\
\
2023-01-13 06:51:34 source > exception while closing\
Stack Trace: java.lang.RuntimeException: Closing down debezium engine but snapshot has not finished\
	at io.airbyte.integrations.debezium.internals.DebeziumRecordIterator.throwExceptionIfSnapshotNotFinished(DebeziumRecordIterator.java:195)\
	at io.airbyte.integrations.debezium.internals.DebeziumRecordIterator.requestClose(DebeziumRecordIterator.java:190)\
	at io.airbyte.integrations.debezium.internals.DebeziumRecordIterator.close(DebeziumRecordIterator.java:176)\
	at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15)\
	at io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:49)\
	at io.airbyte.commons.util.CompositeIterator.close(CompositeIterator.java:91)\
	at io.airbyte.commons.util.CompositeIterator.close(CompositeIterator.java:91)\
	at io.airbyte.commons.util.AutoCloseableIterators.lambda$appendOnClose$0(AutoCloseableIterators.java:88)\
	at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15)\
	at io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:49)\
	at io.airbyte.commons.util.AutoCloseableIterators.lambda$appendOnClose$0(AutoCloseableIterators.java:88)\
	at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15)\
	at io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:49)\
	at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:138)\
	at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:98)\
	at io.airbyte.integrations.base.adaptive.AdaptiveSourceRunner$Runner.run(AdaptiveSourceRunner.java:86)\
	at io.airbyte.integrations.source.postgres.PostgresSourceRunner.main(PostgresSourceRunner.java:15)\
\
2023-01-13 06:51:34 source > Something went wrong in the connector. See the logs for more details.\
Stack Trace: java.lang.RuntimeException: java.lang.RuntimeException: org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.\
	at io.airbyte.integrations.debezium.internals.DebeziumRecordIterator.requestClose(DebeziumRecordIterator.java:188)\
	at io.airbyte.integrations.debezium.internals.DebeziumRecordIterator.computeNext(DebeziumRecordIterator.java:103)\
	at io.airbyte.integrations.debezium.internals.DebeziumRecordIterator.computeNext(DebeziumRecordIterator.java:34)\
	at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:146)\
	at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:141)\
	at com.google.common.collect.TransformedIterator.hasNext(TransformedIterator.java:46)\
	at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:38)\
	at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:146)\
	at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:141)\
	at io.airbyte.commons.util.CompositeIterator.computeNext(CompositeIterator.java:63)\
	at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:146)\
	at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:141)\
	at io.airbyte.commons.util.CompositeIterator.computeNext(CompositeIterator.java:63)\
	at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:146)\
	at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:141)\
	at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:38)\
	at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:146)\
	at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:141)\
	at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:38)\
	at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:146)\
	at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:141)\
	at java.base/java.util.Iterator.forEachRemaining(Iterator.java:132)\
	at io.airbyte.integrations.base.IntegrationRunner.lambda$produceMessages$0(IntegrationRunner.java:187)\
	at io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:237)\
	at io.airbyte.integrations.base.IntegrationRunner.produceMessages(IntegrationRunner.java:186)\
	at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:139)\
	at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:98)\
	at io.airbyte.integrations.base.adaptive.AdaptiveSourceRunner$Runner.run(AdaptiveSourceRunner.java:86)\
	at io.airbyte.integrations.source.postgres.PostgresSourceRunner.main(PostgresSourceRunner.java:15)\
	Suppressed: java.lang.RuntimeException: Closing down debezium engine but snapshot has not finished\
		at io.airbyte.integrations.debezium.internals.DebeziumRecordIterator.throwExceptionIfSnapshotNotFinished(DebeziumRecordIterator.java:195)\
		at io.airbyte.integrations.debezium.internals.DebeziumRecordIterator.requestClose(DebeziumRecordIterator.java:190)\
		at io.airbyte.integrations.debezium.internals.DebeziumRecordIterator.close(DebeziumRecordIterator.java:176)\
		at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15)\
		at io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:49)\
		at io.airbyte.commons.util.CompositeIterator.close(CompositeIterator.java:91)\
		at io.airbyte.commons.util.CompositeIterator.close(CompositeIterator.java:91)\
		at io.airbyte.commons.util.AutoCloseableIterators.lambda$appendOnClose$0(AutoCloseableIterators.java:88)\
		at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15)\
		at io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:49)\
		at io.airbyte.commons.util.AutoCloseableIterators.lambda$appendOnClose$0(AutoCloseableIterators.java:88)\
		at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15)\
		at io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:49)\
		at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:138)\
		... 3 more\
Caused by: java.lang.RuntimeException: org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.\
	at io.airbyte.integrations.debezium.internals.DebeziumRecordPublisher.close(DebeziumRecordPublisher.java:105)\
	at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15)\
	at io.airbyte.integrations.debezium.internals.DebeziumRecordIterator.requestClose(DebeziumRecordIterator.java:185)\
	... 28 more\
Caused by: org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.\
	at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:50)\
	at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:116)\
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)\
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)\
	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.debezium.DebeziumException: java.lang.RuntimeException: org.postgresql.util.PSQLException: This connection has been closed.\
	at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:85)\
	at io.debezium.pipeline.ChangeEventSourceCoordinator.doSnapshot(ChangeEventSourceCoordinator.java:155)\
	at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:137)\
	at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:109)\
	... 5 more\
Caused by: java.lang.RuntimeException: org.postgresql.util.PSQLException: This connection has been closed.\
	at io.debezium.relational.RelationalSnapshotChangeEventSource.rollbackTransaction(RelationalSnapshotChangeEventSource.java:548)\
	at io.debezium.relational.RelationalSnapshotChangeEventSource.doExecute(RelationalSnapshotChangeEventSource.java:146)\
	at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:76)\
	... 8 more\
Caused by: org.postgresql.util.PSQLException: This connection has been closed.\
	at org.postgresql.jdbc.PgConnection.checkClosed(PgConnection.java:883)\
	at org.postgresql.jdbc.PgConnection.rollback(PgConnection.java:890)\
	at io.debezium.relational.RelationalSnapshotChangeEventSource.rollbackTransaction(RelationalSnapshotChangeEventSource.java:545)\
	... 10 more\
\
2023-01-13 06:51:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):324 - Source has no more messages, closing connection.\
2023-01-13 06:51:35 destination > Airbyte message consumer: succeeded.\
2023-01-13 06:51:35 destination > executing on success close procedure.\
2023-01-13 06:51:35 destination > Flushing all 1 current buffers (177 MB in total)\
2023-01-13 06:51:35 destination > Flushing buffer of stream R_rights_db_assetshare (177 MB)\
2023-01-13 06:51:35 destination > Flushing buffer for stream R_rights_db_assetshare (177 MB) to staging\
2023-01-13 06:51:35 destination > Wrapping up compression and write GZIP trailer data.\
2023-01-13 06:51:35 destination > Finished writing data to f8671af4-cdd5-4bb5-b54c-34d986f8272a12750472249219687234.csv.gz (177 MB)\
2023-01-13 06:51:41 destination > closing connection\
2023-01-13 06:51:41 destination > Deleting tempFile data f8671af4-cdd5-4bb5-b54c-34d986f8272a12750472249219687234.csv.gz\
2023-01-13 06:51:41 destination > Closing buffer for stream R_rights_db_assetshare\
2023-01-13 06:51:41 destination > Copying into tables in destination started for 1 streams\
2023-01-13 06:51:41 destination > Copying stream R_rights_db_assetshare of schema MRC_RAW into tmp table _airbyte_tmp_iar_R_rights_db_assetshare to final table _airbyte_raw_R_rights_db_assetshare from stage path 2023/01/12/18/CDDD0E65-31A2-4EE6-8FEF-270C61EA833A/ with 151 file(s) [8bedb404-8dda-4d2a-a5e9-555b1027cfdf4658098028317926043.csv.gz,b5aa6a73-6b96-4077-a701-d65ddce5c25310019314339221509840.csv.gz,287d31c6-9c50-47b9-8293-901bdee9818c650287682998801050.csv.gz,5eee7866-d038-498b-9c27-6580dda2860e12500234930145776354.csv.gz,a9b67776-f316-42b2-8aee-f2ed6eae725817701083588427959033.csv.gz,f34ca9ce-9b3e-4639-ae46-dec26fae18f08625804376751273632.csv.gz,4e8792ff-660c-4094-b746-b14918199ade14215545047993052444.csv.gz,3fe4e572-12ac-4724-adac-22ab2ea1c16618083987652579036877.csv.gz,0b4135d2-f0b0-4636-94fe-db4d98bc37e51739786883629765855.csv.gz,1507143f-bdda-4f7f-9bc3-ae21fe272cb512346275437586209644.csv.gz,805f92c4-3e7c-4120-a331-dcfe99f9621f345382269898966070.csv.gz,58a44ce3-038c-4c0b-ba91-3afe2223efe16581300080083013089.csv.gz,43a70031-8df8-4501-81ac-deb953c9d02914546432977127350333.csv.gz,c2c8363e-cfb3-45e4-91d0-6c70bd069f4515509137942000390896.csv.gz,96ea3ecf-3547-4016-8fc7-1b50635ea37610767043767992382849.csv.gz,29243fa5-d966-400d-b9f5-fa7262f7c6f116357638706292259426.csv.gz,157f0b90-aa7f-449e-ae7d-d0dad209a1af6967338319710441334.csv.gz,24c54057-7269-449a-b0be-c83b17bce4c4897523045579776128.csv.gz,b7392963-e111-4b1d-b46a-f70993983a2317352442757939389181.csv.gz,f8cb068b-f1b6-43c6-93ac-b9aff010be1a11176320927633427773.csv.gz,596af646-ebf1-4c76-a513-caebbbd39eb8540522211497418756.csv.gz,f3ccbb2a-1e33-4d3a-afee-61b0f2fcd16d9025550659392802711.csv.gz,8bf31f34-dfb6-46f1-9a39-1e50a41f96f4525234066543444933.csv.gz,4304898d-5afd-4a07-93da-252cc689afbb8660201166982371585.csv.gz,5e00b866-68f1-4661-9fff-025d9ca82e931359689260108830297.csv.gz,075f8063-b92f-4431-9278-dc42a5d635e414038938731898987896.csv.gz,a884f428-81fa-4f55-960e-b1fbe95dedfc2201521912983497265.csv.gz,125e3e23-4a03-4268-8429-e3911cb294da18120878163598228484.csv.gz,12ab9267-49b9-426e-9f6b-8efd1d03b14511514031803093312630.csv.gz,5a75acf7-67ca-43ca-b95d-b15ccc6a5e9712328897980943633684.csv.gz,d841b42a-8888-4169-b369-61a9504fa7fb18374202562096998141.csv.gz,deca5a6e-688f-422d-ac7f-000da0a4f73f12998264908715424922.csv.gz,7e4e2096-b030-4360-9f4e-304af2e909c115708914707036824871.csv.gz,510284c9-b367-421d-a181-98e160fea1df8303842854031746389.csv.gz,ede105a3-831f-484f-9dce-1962c6002de612413519275801536057.csv.gz,eb0cd7bd-f528-401c-a878-c68ec404ade26640727719882450869.csv.gz,ac3b05fe-2cf9-49f9-9fa2-73bb128bff1d15983793540592691681.csv.gz,8f31d733-ee1c-4907-b825-f485c73cbe8f10892591060566207477.csv.gz,2dcb7996-aa1b-47d5-9f7a-1efe6d60c28d9049517326615229755.csv.gz,d3e80497-7770-471b-892e-23d5759ad32811917490424487093479.csv.gz,02196639-e4b7-4d04-8253-e75f66028c6a17094684708835742829.csv.gz,6778cbef-e052-42f9-95c0-d5499cf796bc7193219970060471730.csv.gz,491e4ebe-09a3-4e42-a0bf-06e4e353a2fc8117122784616413951.csv.gz,8f49884b-7680-42cc-860e-61a894c7a28f12236350496873340987.csv.gz,2a7861f6-2468-4147-9617-ebfdb12c861b4335440959410774500.csv.gz,2b8b8a6e-6ed5-48c7-ac82-d7aa1ac2137b14350636926223075549.csv.gz,ce150daa-2857-4407-812a-4a1c8d5deb514642111737984096224.csv.gz,edac5d44-d898-44d7-b155-0da3398dcb4e11763383855262569670.csv.gz,16098715-a270-4c7c-a7a4-d29537224f6514395960418476821825.csv.gz,2a6b0952-ef8d-4f57-a55e-78a78115431f1971548547338947983.csv.gz,b5da08c5-f684-417e-b8dd-9f553149dad912921721368142281451.csv.gz,c3193f08-3ab9-472b-a1d3-cc81ec82eea88224905117554616993.csv.gz,e4774ae3-9bd4-40c9-8a09-e494e24a9ed411488891260312917366.csv.gz,2bbacab1-2b95-4e25-bad0-d198f1b181c22577984724806832861.csv.gz,b719bf96-258e-4564-8f5a-99b675680a3b3684835719585620471.csv.gz,aca8897a-163e-4436-bca6-61c04fefb3e22079435499237753319.csv.gz,8c36d377-fa54-4f46-a319-4421a7f8148812959247402491785977.csv.gz,2ced78ba-916f-4330-b163-f0b0cbcd507a14520062592797027017.csv.gz,aa79d3b8-bea2-49dd-badd-80834489cc6810960421931483753895.csv.gz,e6f76296-a337-4776-a6b0-c607faf6a560324721961707167120.csv.gz,9d8812e1-e015-478f-94db-151276ace7bc5361938508222251088.csv.gz,74114f8a-a541-43ce-8dbb-c192dfc2219115054326797809978088.csv.gz,b6d143c7-7309-428f-beff-e649fd02642a6600449467705067759.csv.gz,bd2e8e18-de03-4741-aea0-5f022b02da811392176149565002647.csv.gz,e91b6aa7-6e3a-422c-9702-e2b7fb3688831972379867649788547.csv.gz,69e346a0-c05d-41da-8f71-c5efcd4629244343758970292738451.csv.gz,11d321a1-02a4-4c8e-b1e3-fb59b6dcd47c16241663885159375609.csv.gz,58ed1efe-bb1d-45f1-8ae1-704db9f6df8a10751584580888708187.csv.gz,03131612-e970-4d23-bca4-7572a8eb96a213741994145502441744.csv.gz,3eb5bfc2-47f2-4ac5-b142-080bad8d4dcc16993326781125436583.csv.gz,797d3ca7-3436-4fe5-9149-333cce2ff44e3134274838815344436.csv.gz,0ef6b7ea-ab4d-4423-8f2a-6cec771006d015126500113094817783.csv.gz,5d89000d-4e73-4888-a2f2-f710250ada494036731664008713846.csv.gz,09510991-4ec7-449c-8cb3-6557f54c591b5128528554726901513.csv.gz,18c0c6d2-eab9-44dd-8332-8f0382c9d42714430008494268323092.csv.gz,fc3a1009-9114-4e3d-9029-beb144af92ff12406958625947022320.csv.gz,665da069-aaef-40af-89cc-5271c8c4c8ad8400965776126797772.csv.gz,1f9e2cb9-e105-4921-9f89-662569b0c14516082304259135301272.csv.gz,399123ed-a7d5-43a7-8bb5-ca910f5ffa0810076425819678368351.csv.gz,4bc2c17d-f51c-4ad4-a1ee-46592641d5967924336819144060267.csv.gz,21653baf-d4ad-49b5-9048-70ad88f497e71677873837362312090.csv.gz,1b0d20ee-308d-412d-b910-43054a56cd01613577163721472611.csv.gz,e542e102-0342-4f61-8dd2-6ee0a4a02bb85229363682513405408.csv.gz,0aa3d35b-88f0-4ef6-8eea-6b89a2852aac18358996219991940581.csv.gz,17d599a2-1c41-4b98-ae10-cc6f81a4e89b13486463141318410903.csv.gz,5c5a3a63-ccf7-4868-97c7-761bfb5b958910450465258579775026.csv.gz,11c717a3-0482-4479-800b-69419921bc945384180387579122642.csv.gz,a54563cf-0fb0-44a5-a73a-c357a04ce90b2065316440251640417.csv.gz,c485079b-e88b-4b53-8053-5f60fb755fb48690296178932407001.csv.gz,747931d1-f914-4260-a6a2-24ebc5268e9e5871194759671578897.csv.gz,b0e7d185-6de6-4057-a3a6-93e8da0522c63367248941730807485.csv.gz,5ef445d8-13c3-4368-8abc-0a8dc49ed3233930258864570380688.csv.gz,353858ad-9e90-4040-baf6-033250d384314644114958047949834.csv.gz,96939a36-36eb-4aa2-8b2b-e73a4653154d7049279871456235183.csv.gz,214ab585-1d08-4307-99a1-e8b50bb2529c14717758077612202498.csv.gz,c0ae34c2-6af7-435f-8ba2-00307d86c31e2792933624994138963.csv.gz,4c1961e7-4a85-41db-a527-36c39805a10b10779944675763446843.csv.gz,2dada8c5-795b-4ace-974a-c1097a2c63813426129267081327976.csv.gz,7cf8c1cb-8409-4e57-9a3b-29b20257c9688214042790162317312.csv.gz,e0f30c32-3359-4a68-ab4f-e1d71eec9b772236968585807453672.csv.gz,75a2d85a-9913-4132-991b-1b24549ef6896390668536843550434.csv.gz,ee46e974-222f-4ae3-b513-2bf9b04c7a9a9789077176905127397.csv.gz,ddbad9e1-cf54-41c8-9a8a-c2379e8cdd615644728611161938454.csv.gz,473a5ba6-4ed7-40d8-9e3d-dcfa62186b0814224647618946830605.csv.gz,5ee90c75-40d0-40a4-934e-37b084a3c8d416357380969499587365.csv.gz,46952378-7c76-4840-8546-bc4be43b8a7314116372793326654221.csv.gz,dbc23c6c-467e-481d-b403-b4c5a3b390fb5317817212264070014.csv.gz,1186e282-70af-47b4-8a9f-12c48c936cb55058773217217612517.csv.gz,08666fd4-2609-4611-91d0-b22d8a8b1adc7529623908009896347.csv.gz,d1a4e6f9-e3f0-4438-ba29-3a2516a796a64430645743926464946.csv.gz,352a07c6-2a39-452e-a242-cc8653515bc717466233410837608081.csv.gz,75ab4b77-d3a4-4e84-848b-1f90d07bcd402501974999614160162.csv.gz,ef39efa6-82ed-40b0-b636-5a48654fea1d2407734416716014697.csv.gz,31d6a648-5e40-4ff8-9703-7a8c703013293761890198291996788.csv.gz,9e54301e-a786-4155-a271-f6824858c2549937652243041756231.csv.gz,6f13ca9e-460a-4410-8436-e1091fd700322601023912430668510.csv.gz,82f6112f-694b-4125-b5f5-015ffc6ef8ed10618170311417920670.csv.gz,f657d732-2414-4b1b-87b2-b02c3e90fcb510111782579117545804.csv.gz,d519f136-b109-4f36-9d84-185e8692f26b10322132440659745333.csv.gz,e68b9d41-1084-418a-8a9f-2ff08da49a357395488976363175030.csv.gz,0fd63079-aa30-42e9-bc02-10566fb6c35217699305171128898503.csv.gz,b95c923c-f892-4957-9dd2-6d2eeebfb9d417909766822792708955.csv.gz,31fb9f62-7f0d-4751-b399-f0da9784a10b13395464249199034650.csv.gz,627217ae-6275-471f-8d3f-a1d8311b929c8729499162533766339.csv.gz,f0b94260-2f4e-43a8-8c59-74448dcf1a0812446979595461883589.csv.gz,0373a47d-f514-4581-9f40-cedddec0a66c9536619107581381420.csv.gz,2ebb8081-884b-4f81-b8a2-4c19eaa9d6f013910637510725337690.csv.gz,b7cd3965-d681-4035-b4a2-6388b50640954557775962413400228.csv.gz,a0260595-0744-4516-a508-e9f1f03c08227605966881825644205.csv.gz,7ab6027c-0b76-4623-8ffa-3bb2a836f20e12362867336003548679.csv.gz,34b3cf61-12d0-4311-a07a-db7ff656ba761896191899622196355.csv.gz,78b53e3b-3bab-43b2-83b4-15207ec2955e1870536930831124437.csv.gz,549184b3-569f-4237-92ae-c93cc8a9666e5136163137313391.csv.gz,a27e533f-f01c-4f03-84fc-e38ca7527e2412066556515960207490.csv.gz,85af3f04-6a6d-428e-b75c-1d85e1a176822231469624692103308.csv.gz,7e994513-c669-4a3e-8e18-3f6144cd5a1110871111018804286699.csv.gz,0bad0b5a-8ade-4ac2-9989-9d3323e5ffd26879761915951564593.csv.gz,35b9ce16-8638-4f9c-aa93-5a8d0765711b1571011375115525447.csv.gz,ce6be107-651e-413f-addd-e543ea5616694044372959237844496.csv.gz,c8d711d3-b94f-43c9-bbbd-0015b7d200d17744116384562079899.csv.gz,d64e0ae3-8291-438a-b24c-8fc299e72904616021447247580417.csv.gz,b6355141-88a0-43e7-ba76-0f3b15d8c86014360813403857413312.csv.gz,3185a823-dede-41bc-a137-297508eee0202813771612085955182.csv.gz,e64cde82-86f7-4a8c-8771-509ceeb03bf012604552900016085200.csv.gz,b0eb4398-f664-4b05-a0b9-4c36f26602945494110356387526600.csv.gz,8904f08b-7d73-4d99-853e-df7e89340b0813109608014349369523.csv.gz,9f67ce7b-4c8f-4482-875e-1b2ca6d09ca29031024905124850891.csv.gz,d6c5a96a-9012-4839-a444-f1e34b60aca618256636651718808414.csv.gz,9f20bc04-fa0d-4ed9-988d-9a118a43287b15989377608066293714.csv.gz,893f7a47-4907-4d49-9fe9-b31233c725c313612896477957531795.csv.gz,f8671af4-cdd5-4bb5-b54c-34d986f8272a12750472249219687234.csv.gz]\
2023-01-13 06:52:35 ERROR i.a.w.g.DefaultReplicationWorker(replicate):229 - Sync worker failed.\
java.util.concurrent.ExecutionException: io.airbyte.workers.general.DefaultReplicationWorker$SourceException: Source cannot be stopped!\
	at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) ~[?:?]\
	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) ~[?:?]\
	at io.airbyte.workers.general.DefaultReplicationWorker.replicate(DefaultReplicationWorker.java:221) ~[io.airbyte-airbyte-commons-worker-0.40.22.jar:?]\
	at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:157) ~[io.airbyte-airbyte-commons-worker-0.40.22.jar:?]\
	at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:80) ~[io.airbyte-airbyte-commons-worker-0.40.22.jar:?]\
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$4(TemporalAttemptExecution.java:192) ~[io.airbyte-airbyte-workers-0.40.22.jar:?]\
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]\
	Suppressed: io.airbyte.workers.exception.WorkerException: Source process exit with code 1. This warning is normal if the job was cancelled.\
		at io.airbyte.workers.internal.DefaultAirbyteSource.close(DefaultAirbyteSource.java:144) ~[io.airbyte-airbyte-commons-worker-0.40.22.jar:?]\
		at io.airbyte.workers.general.DefaultReplicationWorker.replicate(DefaultReplicationWorker.java:178) ~[io.airbyte-airbyte-commons-worker-0.40.22.jar:?]\
		at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:157) ~[io.airbyte-airbyte-commons-worker-0.40.22.jar:?]\
		at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:80) ~[io.airbyte-airbyte-commons-worker-0.40.22.jar:?]\
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$4(TemporalAttemptExecution.java:192) ~[io.airbyte-airbyte-workers-0.40.22.jar:?]\
		at java.lang.Thread.run(Thread.java:1589) ~[?:?]\
	Suppressed: io.airbyte.workers.exception.WorkerException: Destination process exit with code 143. This warning is normal if the job was cancelled.\
		at io.airbyte.workers.internal.DefaultAirbyteDestination.close(DefaultAirbyteDestination.java:124) ~[io.airbyte-airbyte-commons-worker-0.40.22.jar:?]\
		at io.airbyte.workers.general.DefaultReplicationWorker.replicate(DefaultReplicationWorker.java:178) ~[io.airbyte-airbyte-commons-worker-0.40.22.jar:?]\
		at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:157) ~[io.airbyte-airbyte-commons-worker-0.40.22.jar:?]\
		at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:80) ~[io.airbyte-airbyte-commons-worker-0.40.22.jar:?]\
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$4(TemporalAttemptExecution.java:192) ~[io.airbyte-airbyte-workers-0.40.22.jar:?]\
		at java.lang.Thread.run(Thread.java:1589) ~[?:?]\
Caused by: io.airbyte.workers.general.DefaultReplicationWorker$SourceException: Source cannot be stopped!\
	at io.airbyte.workers.general.DefaultReplicationWorker.lambda$readFromSrcAndWriteToDstRunnable$6(DefaultReplicationWorker.java:328) ~[io.airbyte-airbyte-commons-worker-0.40.22.jar:?]\
	at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ~[?:?]\
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?]\
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?]\
	... 1 more\
Caused by: io.airbyte.workers.exception.WorkerException: Source process exit with code 1. This warning is normal if the job was cancelled.\
	at io.airbyte.workers.internal.DefaultAirbyteSource.close(DefaultAirbyteSource.java:144) ~[io.airbyte-airbyte-commons-worker-0.40.22.jar:?]\
	at io.airbyte.workers.general.DefaultReplicationWorker.lambda$readFromSrcAndWriteToDstRunnable$6(DefaultReplicationWorker.java:326) ~[io.airbyte-airbyte-commons-worker-0.40.22.jar:?]\
	at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ~[?:?]\
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?]\
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?]\
	... 1 more\
2023-01-13 06:52:35 INFO i.a.w.g.DefaultReplicationWorker(prepStateForLaterSaving):477 - Source did not output any state messages\
2023-01-13 06:52:35 WARN i.a.w.g.DefaultReplicationWorker(prepStateForLaterSaving):488 - State capture: No state retained.\
2023-01-13 06:52:35 INFO i.a.w.g.DefaultReplicationWorker(getReplicationOutput):408 - sync summary: \{\
  "status" : "failed",\
  "recordsSynced" : 405637118,\
  "bytesSynced" : 269833414051,\
  "startTime" : 1673546985358,\
  "endTime" : 1673592755291,\
  "totalStats" : \{\
    "recordsEmitted" : 405637118,\
    "bytesEmitted" : 269833414051,\
    "sourceStateMessagesEmitted" : 0,\
    "destinationStateMessagesEmitted" : 0,\
    "recordsCommitted" : 0,\
    "meanSecondsBeforeSourceStateMessageEmitted" : 0,\
    "maxSecondsBeforeSourceStateMessageEmitted" : 0,\
    "maxSecondsBetweenStateMessageEmittedandCommitted" : 0,\
    "meanSecondsBetweenStateMessageEmittedandCommitted" : 0,\
    "replicationStartTime" : 1673546985358,\
    "replicationEndTime" : 1673592755291,\
    "sourceReadStartTime" : 1673546985412,\
    "sourceReadEndTime" : 0,\
    "destinationWriteStartTime" : 1673546985501,\
    "destinationWriteEndTime" : 0\
  \},\
  "streamStats" : [ \{\
    "streamName" : "R_rights_db_assetshare",\
    "stats" : \{\
      "recordsEmitted" : 405637118,\
      "bytesEmitted" : 269833414051\
    \}\
  \} ]\
\}\
2023-01-13 06:52:35 INFO i.a.w.g.DefaultReplicationWorker(getReplicationOutput):409 - failures: [ \{\
  "failureOrigin" : "source",\
  "failureType" : "system_error",\
  "internalMessage" : "java.lang.RuntimeException: java.lang.RuntimeException: org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.",\
  "externalMessage" : "Something went wrong in the connector. See the logs for more details.",\
  "metadata" : \{\
    "attemptNumber" : 2,\
    "jobId" : 1167,\
    "from_trace_message" : true,\
    "connector_command" : "read"\
  \},\
  "stacktrace" : "java.lang.RuntimeException: java.lang.RuntimeException: org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.\\n\\tat io.airbyte.integrations.debezium.internals.DebeziumRecordIterator.requestClose(DebeziumRecordIterator.java:188)\\n\\tat io.airbyte.integrations.debezium.internals.DebeziumRecordIterator.computeNext(DebeziumRecordIterator.java:103)\\n\\tat io.airbyte.integrations.debezium.internals.DebeziumRecordIterator.computeNext(DebeziumRecordIterator.java:34)\\n\\tat com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:146)\\n\\tat com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:141)\\n\\tat com.google.common.collect.TransformedIterator.hasNext(TransformedIterator.java:46)\\n\\tat io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:38)\\n\\tat com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:146)\\n\\tat com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:141)\\n\\tat io.airbyte.commons.util.CompositeIterator.computeNext(CompositeIterator.java:63)\\n\\tat com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:146)\\n\\tat com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:141)\\n\\tat io.airbyte.commons.util.CompositeIterator.computeNext(CompositeIterator.java:63)\\n\\tat com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:146)\\n\\tat com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:141)\\n\\tat io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:38)\\n\\tat com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:146)\\n\\tat com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:141)\\n\\tat io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:38)\\n\\tat com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:146)\\n\\tat com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:141)\\n\\tat java.base/java.util.Iterator.forEachRemaining(Iterator.java:132)\\n\\tat io.airbyte.integrations.base.IntegrationRunner.lambda$produceMessages$0(IntegrationRunner.java:187)\\n\\tat io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:237)\\n\\tat io.airbyte.integrations.base.IntegrationRunner.produceMessages(IntegrationRunner.java:186)\\n\\tat io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:139)\\n\\tat io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:98)\\n\\tat io.airbyte.integrations.base.adaptive.AdaptiveSourceRunner$Runner.run(AdaptiveSourceRunner.java:86)\\n\\tat io.airbyte.integrations.source.postgres.PostgresSourceRunner.main(PostgresSourceRunner.java:15)\\n\\tSuppressed: java.lang.RuntimeException: Closing down debezium engine but snapshot has not finished\\n\\t\\tat io.airbyte.integrations.debezium.internals.DebeziumRecordIterator.throwExceptionIfSnapshotNotFinished(DebeziumRecordIterator.java:195)\\n\\t\\tat io.airbyte.integrations.debezium.internals.DebeziumRecordIterator.requestClose(DebeziumRecordIterator.java:190)\\n\\t\\tat io.airbyte.integrations.debezium.internals.DebeziumRecordIterator.close(DebeziumRecordIterator.java:176)\\n\\t\\tat io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15)\\n\\t\\tat io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:49)\\n\\t\\tat io.airbyte.commons.util.CompositeIterator.close(CompositeIterator.java:91)\\n\\t\\tat io.airbyte.commons.util.CompositeIterator.close(CompositeIterator.java:91)\\n\\t\\tat io.airbyte.commons.util.AutoCloseableIterators.lambda$appendOnClose$0(AutoCloseableIterators.java:88)\\n\\t\\tat io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15)\\n\\t\\tat io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:49)\\n\\t\\tat io.airbyte.commons.util.AutoCloseableIterators.lambda$appendOnClose$0(AutoCloseableIterators.java:88)\\n\\t\\tat io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15)\\n\\t\\tat io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:49)\\n\\t\\tat io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:138)\\n\\t\\t... 3 more\\nCaused by: java.lang.RuntimeException: org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.\\n\\tat io.airbyte.integrations.debezium.internals.DebeziumRecordPublisher.close(DebeziumRecordPublisher.java:105)\\n\\tat io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15)\\n\\tat io.airbyte.integrations.debezium.internals.DebeziumRecordIterator.requestClose(DebeziumRecordIterator.java:185)\\n\\t... 28 more\\nCaused by: org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.\\n\\tat io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:50)\\n\\tat io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:116)\\n\\tat java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)\\n\\tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)\\n\\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)\\n\\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)\\n\\tat java.base/java.lang.Thread.run(Thread.java:833)\\nCaused by: io.debezium.DebeziumException: java.lang.RuntimeException: org.postgresql.util.PSQLException: This connection has been closed.\\n\\tat io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:85)\\n\\tat io.debezium.pipeline.ChangeEventSourceCoordinator.doSnapshot(ChangeEventSourceCoordinator.java:155)\\n\\tat io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:137)\\n\\tat io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:109)\\n\\t... 5 more\\nCaused by: java.lang.RuntimeException: org.postgresql.util.PSQLException: This connection has been closed.\\n\\tat io.debezium.relational.RelationalSnapshotChangeEventSource.rollbackTransaction(RelationalSnapshotChangeEventSource.java:548)\\n\\tat io.debezium.relational.RelationalSnapshotChangeEventSource.doExecute(RelationalSnapshotChangeEventSource.java:146)\\n\\tat io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:76)\\n\\t... 8 more\\nCaused by: org.postgresql.util.PSQLException: This connection has been closed.\\n\\tat org.postgresql.jdbc.PgConnection.checkClosed(PgConnection.java:883)\\n\\tat org.postgresql.jdbc.PgConnection.rollback(PgConnection.java:890)\\n\\tat io.debezium.relational.RelationalSnapshotChangeEventSource.rollbackTransaction(RelationalSnapshotChangeEventSource.java:545)\\n\\t... 10 more\\n",\
  "timestamp" : 1673592694547\
\}, \{\
  "failureOrigin" : "source",\
  "internalMessage" : "io.airbyte.workers.general.DefaultReplicationWorker$SourceException: Source cannot be stopped!",\
  "externalMessage" : "Something went wrong within the source connector",\
  "metadata" : \{\
    "attemptNumber" : 2,\
    "jobId" : 1167,\
    "connector_command" : "read"\
  \},\
  "stacktrace" : "java.util.concurrent.CompletionException: io.airbyte.workers.general.DefaultReplicationWorker$SourceException: Source cannot be stopped!\\n\\tat java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:315)\\n\\tat java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:320)\\n\\tat java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1807)\\n\\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)\\n\\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)\\n\\tat java.base/java.lang.Thread.run(Thread.java:1589)\\nCaused by: io.airbyte.workers.general.DefaultReplicationWorker$SourceException: Source cannot be stopped!\\n\\tat io.airbyte.workers.general.DefaultReplicationWorker.lambda$readFromSrcAndWriteToDstRunnable$6(DefaultReplicationWorker.java:328)\\n\\tat java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)\\n\\t... 3 more\\nCaused by: io.airbyte.workers.exception.WorkerException: Source process exit with code 1. This warning is normal if the job was cancelled.\\n\\tat io.airbyte.workers.internal.DefaultAirbyteSource.close(DefaultAirbyteSource.java:144)\\n\\tat io.airbyte.workers.general.DefaultReplicationWorker.lambda$readFromSrcAndWriteToDstRunnable$6(DefaultReplicationWorker.java:326)\\n\\t... 4 more\\n",\
  "timestamp" : 1673592695091\
\}, \{\
  "failureOrigin" : "replication",\
  "internalMessage" : "java.lang.RuntimeException: java.io.UncheckedIOException: java.io.IOException: Stream closed",\
  "externalMessage" : "Something went wrong during replication",\
  "metadata" : \{\
    "attemptNumber" : 2,\
    "jobId" : 1167\
  \},\
  "stacktrace" : "java.util.concurrent.CompletionException: java.lang.RuntimeException: java.io.UncheckedIOException: java.io.IOException: Stream closed\\n\\tat java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:315)\\n\\tat java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:320)\\n\\tat java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1807)\\n\\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)\\n\\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)\\n\\tat java.base/java.lang.Thread.run(Thread.java:1589)\\nCaused by: java.lang.RuntimeException: java.io.UncheckedIOException: java.io.IOException: Stream closed\\n\\tat io.airbyte.workers.general.DefaultReplicationWorker.lambda$readFromDstRunnable$4(DefaultReplicationWorker.java:272)\\n\\tat java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)\\n\\t... 3 more\\nCaused by: java.io.UncheckedIOException: java.io.IOException: Stream closed\\n\\tat java.base/java.io.BufferedReader$1.hasNext(BufferedReader.java:685)\\n\\tat java.base/java.util.Spliterators$IteratorSpliterator.tryAdvance(Spliterators.java:1931)\\n\\tat java.base/java.util.stream.StreamSpliterators$WrappingSpliterator.lambda$initPartialTraversalState$0(StreamSpliterators.java:292)\\n\\tat java.base/java.util.stream.StreamSpliterators$AbstractWrappingSpliterator.fillBuffer(StreamSpliterators.java:206)\\n\\tat java.base/java.util.stream.StreamSpliterators$AbstractWrappingSpliterator.doAdvance(StreamSpliterators.java:161)\\n\\tat java.base/java.util.stream.StreamSpliterators$WrappingSpliterator.tryAdvance(StreamSpliterators.java:298)\\n\\tat java.base/java.util.Spliterators$1Adapter.hasNext(Spliterators.java:681)\\n\\tat io.airbyte.workers.internal.DefaultAirbyteDestination.isFinished(DefaultAirbyteDestination.java:150)\\n\\tat io.airbyte.workers.general.DefaultReplicationWorker.lambda$readFromDstRunnable$4(DefaultReplicationWorker.java:245)\\n\\t... 4 more\\nCaused by: java.io.IOException: Stream closed\\n\\tat java.base/java.io.BufferedInputStream.getBufIfOpen(BufferedInputStream.java:172)\\n\\tat java.base/java.io.BufferedInputStream.implRead(BufferedInputStream.java:373)\\n\\tat java.base/java.io.BufferedInputStream.read(BufferedInputStream.java:367)\\n\\tat java.base/sun.nio.cs.StreamDecoder.readBytes(StreamDecoder.java:333)\\n\\tat java.base/sun.nio.cs.StreamDecoder.implRead(StreamDecoder.java:376)\\n\\tat java.base/sun.nio.cs.StreamDecoder.lockedRead(StreamDecoder.java:219)\\n\\tat java.base/sun.nio.cs.StreamDecoder.read(StreamDecoder.java:173)\\n\\tat java.base/java.io.InputStreamReader.read(InputStreamReader.java:189)\\n\\tat java.base/java.io.BufferedReader.fill(BufferedReader.java:161)\\n\\tat java.base/java.io.BufferedReader.implReadLine(BufferedReader.java:371)\\n\\tat java.base/java.io.BufferedReader.readLine(BufferedReader.java:348)\\n\\tat java.base/java.io.BufferedReader.readLine(BufferedReader.java:437)\\n\\tat java.base/java.io.BufferedReader$1.hasNext(BufferedReader.java:682)\\n\\t... 12 more\\n",\
  "timestamp" : 1673592755289\
\} ]\
2023-01-13 06:52:35 INFO i.a.w.t.TemporalAttemptExecution(get):160 - Stopping cancellation check scheduling...\
2023-01-13 06:52:35 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):198 - sync summary: io.airbyte.config.StandardSyncOutput@6e6dc8de[standardSyncSummary=io.airbyte.config.StandardSyncSummary@4770fcae[status=failed,recordsSynced=405637118,bytesSynced=269833414051,startTime=1673546985358,endTime=1673592755291,totalStats=io.airbyte.config.SyncStats@697192df[recordsEmitted=405637118,bytesEmitted=269833414051,sourceStateMessagesEmitted=0,destinationStateMessagesEmitted=0,recordsCommitted=0,meanSecondsBeforeSourceStateMessageEmitted=0,maxSecondsBeforeSourceStateMessageEmitted=0,maxSecondsBetweenStateMessageEmittedandCommitted=0,meanSecondsBetweenStateMessageEmittedandCommitted=0,replicationStartTime=1673546985358,replicationEndTime=1673592755291,sourceReadStartTime=1673546985412,sourceReadEndTime=0,destinationWriteStartTime=1673546985501,destinationWriteEndTime=0,additionalProperties=\{\}],streamStats=[io.airbyte.config.StreamSyncStats@132897f0[streamName=R_rights_db_assetshare,streamNamespace=<null>,stats=io.airbyte.config.SyncStats@13038673[recordsEmitted=405637118,bytesEmitted=269833414051,sourceStateMessagesEmitted=<null>,destinationStateMessagesEmitted=<null>,recordsCommitted=<null>,meanSecondsBeforeSourceStateMessageEmitted=<null>,maxSecondsBeforeSourceStateMessageEmitted=<null>,maxSecondsBetweenStateMessageEmittedandCommitted=<null>,meanSecondsBetweenStateMessageEmittedandCommitted=<null>,replicationStartTime=<null>,replicationEndTime=<null>,sourceReadStartTime=<null>,sourceReadEndTime=<null>,destinationWriteStartTime=<null>,destinationWriteEndTime=<null>,additionalProperties=\{\}]]]],normalizationSummary=<null>,webhookOperationSummary=<null>,state=<null>,outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@53569d31[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@36540aee[stream=io.airbyte.protocol.models.AirbyteStream@61948cc3[name=R_rights_db_assetshare,jsonSchema=\{"type":"object","properties":\{"id":\{"type":"string"\},"type":\{"type":"string"\},"shares":\{"type":"string"\},"asset_id":\{"type":"string"\},"party_id":\{"type":"string"\},"sibling_id":\{"type":"string"\},"_ab_cdc_lsn":\{"type":"number"\},"valid_period":\{"type":"string"\},"mr_society_id":\{"type":"string"\},"pr_society_id":\{"type":"string"\},"sr_society_id":\{"type":"string"\},"linked_share_id":\{"type":"string"\},"_ab_cdc_deleted_at":\{"type":"string"\},"_ab_cdc_updated_at":\{"type":"string"\},"representation_type":\{"type":"string"\},"excluded_territories":\{"type":"array","items":\{"type":"string"\}\},"included_territories":\{"type":"array","items":\{"type":"string"\}\},"publisher_sequence_n":\{"type":"string"\}\}\},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=<null>,additionalProperties=\{\}],syncMode=incremental,cursorField=[],destinationSyncMode=append_dedup,primaryKey=[[id]],additionalProperties=\{\}]],additionalProperties=\{\}],failures=[io.airbyte.config.FailureReason@6eabae9c[failureOrigin=source,failureType=system_error,internalMessage=java.lang.RuntimeException: java.lang.RuntimeException: org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.,externalMessage=Something went wrong in the connector. See the logs for more details.,metadata=io.airbyte.config.Metadata@973096d[additionalProperties=\{attemptNumber=2, jobId=1167, from_trace_message=true, connector_command=read\}],stacktrace=java.lang.RuntimeException: java.lang.RuntimeException: org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.\
	at io.airbyte.integrations.debezium.internals.DebeziumRecordIterator.requestClose(DebeziumRecordIterator.java:188)\
	at io.airbyte.integrations.debezium.internals.DebeziumRecordIterator.computeNext(DebeziumRecordIterator.java:103)\
	at io.airbyte.integrations.debezium.internals.DebeziumRecordIterator.computeNext(DebeziumRecordIterator.java:34)\
	at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:146)\
	at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:141)\
	at com.google.common.collect.TransformedIterator.hasNext(TransformedIterator.java:46)\
	at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:38)\
	at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:146)\
	at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:141)\
	at io.airbyte.commons.util.CompositeIterator.computeNext(CompositeIterator.java:63)\
	at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:146)\
	at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:141)\
	at io.airbyte.commons.util.CompositeIterator.computeNext(CompositeIterator.java:63)\
	at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:146)\
	at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:141)\
	at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:38)\
	at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:146)\
	at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:141)\
	at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:38)\
	at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:146)\
	at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:141)\
	at java.base/java.util.Iterator.forEachRemaining(Iterator.java:132)\
	at io.airbyte.integrations.base.IntegrationRunner.lambda$produceMessages$0(IntegrationRunner.java:187)\
	at io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:237)\
	at io.airbyte.integrations.base.IntegrationRunner.produceMessages(IntegrationRunner.java:186)\
	at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:139)\
	at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:98)\
	at io.airbyte.integrations.base.adaptive.AdaptiveSourceRunner$Runner.run(AdaptiveSourceRunner.java:86)\
	at io.airbyte.integrations.source.postgres.PostgresSourceRunner.main(PostgresSourceRunner.java:15)\
	Suppressed: java.lang.RuntimeException: Closing down debezium engine but snapshot has not finished\
		at io.airbyte.integrations.debezium.internals.DebeziumRecordIterator.throwExceptionIfSnapshotNotFinished(DebeziumRecordIterator.java:195)\
		at io.airbyte.integrations.debezium.internals.DebeziumRecordIterator.requestClose(DebeziumRecordIterator.java:190)\
		at io.airbyte.integrations.debezium.internals.DebeziumRecordIterator.close(DebeziumRecordIterator.java:176)\
		at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15)\
		at io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:49)\
		at io.airbyte.commons.util.CompositeIterator.close(CompositeIterator.java:91)\
		at io.airbyte.commons.util.CompositeIterator.close(CompositeIterator.java:91)\
		at io.airbyte.commons.util.AutoCloseableIterators.lambda$appendOnClose$0(AutoCloseableIterators.java:88)\
		at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15)\
		at io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:49)\
		at io.airbyte.commons.util.AutoCloseableIterators.lambda$appendOnClose$0(AutoCloseableIterators.java:88)\
		at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15)\
		at io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:49)\
		at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:138)\
		... 3 more\
Caused by: java.lang.RuntimeException: org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.\
	at io.airbyte.integrations.debezium.internals.DebeziumRecordPublisher.close(DebeziumRecordPublisher.java:105)\
	at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15)\
	at io.airbyte.integrations.debezium.internals.DebeziumRecordIterator.requestClose(DebeziumRecordIterator.java:185)\
	... 28 more\
Caused by: org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.\
	at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:50)\
	at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:116)\
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)\
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)\
	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.debezium.DebeziumException: java.lang.RuntimeException: org.postgresql.util.PSQLException: This connection has been closed.\
	at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:85)\
	at io.debezium.pipeline.ChangeEventSourceCoordinator.doSnapshot(ChangeEventSourceCoordinator.java:155)\
	at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:137)\
	at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:109)\
	... 5 more\
Caused by: java.lang.RuntimeException: org.postgresql.util.PSQLException: This connection has been closed.\
	at io.debezium.relational.RelationalSnapshotChangeEventSource.rollbackTransaction(RelationalSnapshotChangeEventSource.java:548)\
	at io.debezium.relational.RelationalSnapshotChangeEventSource.doExecute(RelationalSnapshotChangeEventSource.java:146)\
	at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:76)\
	... 8 more\
Caused by: org.postgresql.util.PSQLException: This connection has been closed.\
	at org.postgresql.jdbc.PgConnection.checkClosed(PgConnection.java:883)\
	at org.postgresql.jdbc.PgConnection.rollback(PgConnection.java:890)\
	at io.debezium.relational.RelationalSnapshotChangeEventSource.rollbackTransaction(RelationalSnapshotChangeEventSource.java:545)\
	... 10 more\
,retryable=<null>,timestamp=1673592694547], io.airbyte.config.FailureReason@1fe671d7[failureOrigin=source,failureType=<null>,internalMessage=io.airbyte.workers.general.DefaultReplicationWorker$SourceException: Source cannot be stopped!,externalMessage=Something went wrong within the source connector,metadata=io.airbyte.config.Metadata@5ad1047c[additionalProperties=\{attemptNumber=2, jobId=1167, connector_command=read\}],stacktrace=java.util.concurrent.CompletionException: io.airbyte.workers.general.DefaultReplicationWorker$SourceException: Source cannot be stopped!\
	at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:315)\
	at java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:320)\
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1807)\
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)\
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)\
	at java.base/java.lang.Thread.run(Thread.java:1589)\
Caused by: io.airbyte.workers.general.DefaultReplicationWorker$SourceException: Source cannot be stopped!\
	at io.airbyte.workers.general.DefaultReplicationWorker.lambda$readFromSrcAndWriteToDstRunnable$6(DefaultReplicationWorker.java:328)\
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)\
	... 3 more\
Caused by: io.airbyte.workers.exception.WorkerException: Source process exit with code 1. This warning is normal if the job was cancelled.\
	at io.airbyte.workers.internal.DefaultAirbyteSource.close(DefaultAirbyteSource.java:144)\
	at io.airbyte.workers.general.DefaultReplicationWorker.lambda$readFromSrcAndWriteToDstRunnable$6(DefaultReplicationWorker.java:326)\
	... 4 more\
,retryable=<null>,timestamp=1673592695091], io.airbyte.config.FailureReason@693d9ef4[failureOrigin=replication,failureType=<null>,internalMessage=java.lang.RuntimeException: java.io.UncheckedIOException: java.io.IOException: Stream closed,externalMessage=Something went wrong during replication,metadata=io.airbyte.config.Metadata@7894cadf[additionalProperties=\{attemptNumber=2, jobId=1167\}],stacktrace=java.util.concurrent.CompletionException: java.lang.RuntimeException: java.io.UncheckedIOException: java.io.IOException: Stream closed\
	at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:315)\
	at java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:320)\
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1807)\
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)\
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)\
	at java.base/java.lang.Thread.run(Thread.java:1589)\
Caused by: java.lang.RuntimeException: java.io.UncheckedIOException: java.io.IOException: Stream closed\
	at io.airbyte.workers.general.DefaultReplicationWorker.lambda$readFromDstRunnable$4(DefaultReplicationWorker.java:272)\
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)\
	... 3 more\
Caused by: java.io.UncheckedIOException: java.io.IOException: Stream closed\
	at java.base/java.io.BufferedReader$1.hasNext(BufferedReader.java:685)\
	at java.base/java.util.Spliterators$IteratorSpliterator.tryAdvance(Spliterators.java:1931)\
	at java.base/java.util.stream.StreamSpliterators$WrappingSpliterator.lambda$initPartialTraversalState$0(StreamSpliterators.java:292)\
	at java.base/java.util.stream.StreamSpliterators$AbstractWrappingSpliterator.fillBuffer(StreamSpliterators.java:206)\
	at java.base/java.util.stream.StreamSpliterators$AbstractWrappingSpliterator.doAdvance(StreamSpliterators.java:161)\
	at java.base/java.util.stream.StreamSpliterators$WrappingSpliterator.tryAdvance(StreamSpliterators.java:298)\
	at java.base/java.util.Spliterators$1Adapter.hasNext(Spliterators.java:681)\
	at io.airbyte.workers.internal.DefaultAirbyteDestination.isFinished(DefaultAirbyteDestination.java:150)\
	at io.airbyte.workers.general.DefaultReplicationWorker.lambda$readFromDstRunnable$4(DefaultReplicationWorker.java:245)\
	... 4 more\
Caused by: java.io.IOException: Stream closed\
	at java.base/java.io.BufferedInputStream.getBufIfOpen(BufferedInputStream.java:172)\
	at java.base/java.io.BufferedInputStream.implRead(BufferedInputStream.java:373)\
	at java.base/java.io.BufferedInputStream.read(BufferedInputStream.java:367)\
	at java.base/sun.nio.cs.StreamDecoder.readBytes(StreamDecoder.java:333)\
	at java.base/sun.nio.cs.StreamDecoder.implRead(StreamDecoder.java:376)\
	at java.base/sun.nio.cs.StreamDecoder.lockedRead(StreamDecoder.java:219)\
	at java.base/sun.nio.cs.StreamDecoder.read(StreamDecoder.java:173)\
	at java.base/java.io.InputStreamReader.read(InputStreamReader.java:189)\
	at java.base/java.io.BufferedReader.fill(BufferedReader.java:161)\
	at java.base/java.io.BufferedReader.implReadLine(BufferedReader.java:371)\
	at java.base/java.io.BufferedReader.readLine(BufferedReader.java:348)\
	at java.base/java.io.BufferedReader.readLine(BufferedReader.java:437)\
	at java.base/java.io.BufferedReader$1.hasNext(BufferedReader.java:682)\
	... 12 more\
,retryable=<null>,timestamp=1673592755289]]]\
2023-01-13 06:52:35 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):203 - Sync summary length: 15733\
2023-01-13 06:52:35 INFO i.a.c.i.LineGobbler(voidCall):114 - \
2023-01-13 06:52:35 INFO i.a.c.i.LineG}