airbytehq / airbyte

The leading data integration platform for ETL / ELT data pipelines from APIs, databases & files to data warehouses, data lakes & data lakehouses. Both self-hosted and Cloud-hosted.
https://airbyte.com
Other
14.95k stars 3.84k forks source link

[source-MongoDB] connector is getting BufferedReplicationWorker(readFromSource) exception #41018

Open AronsonDan opened 2 weeks ago

AronsonDan commented 2 weeks ago

Connector Name

source-mongodb

Connector Version

1.4.2

What step the error happened?

During the sync

Relevant information

Mongo source is constantly throwing errors on readFromSource

Relevant log output

2024-07-07 14:25:23 replication-orchestrator > readFromSource: source exception
io.airbyte.workers.internal.exception.SourceException: Source process exited with non-zero exit code 2
        at io.airbyte.workers.general.BufferedReplicationWorker.readFromSource(BufferedReplicationWorker.java:365) ~[io.airbyte-airbyte-commons-worker-0.50.38.jar:?]
        at io.airbyte.workers.general.BufferedReplicationWorker.lambda$runAsyncWithHeartbeatCheck$3(BufferedReplicationWorker.java:235) ~[io.airbyte-airbyte-commons-worker-0.50.38.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) ~[?:?]
        at java.lang.Thread.run(Thread.java:1583) ~[?:?]


### Contribute

- [ ] Yes, I want to contribute
marcosmarxm commented 2 weeks ago

@AronsonDan can you share the complete sync log file?

AronsonDan commented 2 weeks ago

@marcosmarxm Just added :-) 68c1d0e2_4cc2_43bc_b5db_99b9f5cea75d_job_71651_attempt_5_txt.txt

AronsonDan commented 2 weeks ago

@marcosmarxm We have been seeing the following behavior:

68c1d0e2_4cc2_43bc_b5db_99b9f5cea75d_job_71501_attempt_1_txt.txt

Attaching the log image

akashkulk commented 12 hours ago

Interesting. This seems to be an issue with debezium.

During shutdown, we are seeing that debezium shuts down correctly but still has a orphaned thread running which does not shut down correctly because it's waiting on some internal lock.

@AronsonDan can you try increasing the timeout here and trying again?

AronsonDan commented 10 hours ago

@akashkulk How do I do that?