Long Google Ads Sync Failing with "Heartbeat has Stopped" #32351
Unanswered
dustincolvin-transitiv
asked this question in
Connector Questions
Replies: 0 comments
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Uh oh!
There was an error while loading. Please reload this page.
-
Hey everyone. I have a Google Ads v0.2.23 Source that just gave me a new failure reason I have not seen before:
Heartbeat has stopped. Heartbeat freshness threshold: 10800 secs Actual heartbeat age: 10831 secs
It looks like this is occurring when the sync is done, but I can't tell if I'm just not reading this correctly
2023-11-09 12:00:47 INFO i.a.w.g.BufferedReplicationWorker(readFromDestination):464 - readFromDestination: done. (writeToDestFailed:false, dest.isFinished:true) 2023-11-09 12:01:47 INFO i.a.w.g.BufferedReplicationWorker(readFromSource):353 - readFromSource: exception caught java.io.UncheckedIOException: java.io.IOException: Stream closed at java.io.BufferedReader$1.hasNext(BufferedReader.java:685) ~[?:?] at java.util.Spliterators$IteratorSpliterator.tryAdvance(Spliterators.java:1931) ~[?:?] at java.util.stream.StreamSpliterators$WrappingSpliterator.lambda$initPartialTraversalState$0(StreamSpliterators.java:292) ~[?:?] at java.util.stream.StreamSpliterators$AbstractWrappingSpliterator.fillBuffer(StreamSpliterators.java:206) ~[?:?] at java.util.stream.StreamSpliterators$AbstractWrappingSpliterator.doAdvance(StreamSpliterators.java:169) ~[?:?] at java.util.stream.StreamSpliterators$WrappingSpliterator.tryAdvance(StreamSpliterators.java:298) ~[?:?] at java.util.Spliterators$1Adapter.hasNext(Spliterators.java:681) ~[?:?] at io.airbyte.workers.internal.DefaultAirbyteSource.isFinished(DefaultAirbyteSource.java:108) ~[io.airbyte-airbyte-commons-worker-0.50.29.jar:?] at io.airbyte.workers.general.BufferedReplicationWorker.sourceIsFinished(BufferedReplicationWorker.java:319) ~[io.airbyte-airbyte-commons-worker-0.50.29.jar:?] at io.airbyte.workers.general.BufferedReplicationWorker.readFromSource(BufferedReplicationWorker.java:330) ~[io.airbyte-airbyte-commons-worker-0.50.29.jar:?] at io.airbyte.workers.general.BufferedReplicationWorker.lambda$runAsyncWithHeartbeatCheck$3(BufferedReplicationWorker.java:236) ~[io.airbyte-airbyte-commons-worker-0.50.29.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:1589) ~[?:?] Caused by: java.io.IOException: Stream closed at java.io.BufferedInputStream.getBufIfOpen(BufferedInputStream.java:172) ~[?:?] at java.io.BufferedInputStream.implRead(BufferedInputStream.java:373) ~[?:?] at java.io.BufferedInputStream.read(BufferedInputStream.java:367) ~[?:?] at sun.nio.cs.StreamDecoder.readBytes(StreamDecoder.java:333) ~[?:?] at sun.nio.cs.StreamDecoder.implRead(StreamDecoder.java:376) ~[?:?] at sun.nio.cs.StreamDecoder.lockedRead(StreamDecoder.java:219) ~[?:?] at sun.nio.cs.StreamDecoder.read(StreamDecoder.java:173) ~[?:?] at java.io.InputStreamReader.read(InputStreamReader.java:189) ~[?:?] at java.io.BufferedReader.fill(BufferedReader.java:161) ~[?:?] at java.io.BufferedReader.implReadLine(BufferedReader.java:371) ~[?:?] at java.io.BufferedReader.readLine(BufferedReader.java:348) ~[?:?] at java.io.BufferedReader.readLine(BufferedReader.java:437) ~[?:?] at java.io.BufferedReader$1.hasNext(BufferedReader.java:682) ~[?:?] ... 14 more
After this it goes to normalize. All of my data appears to be there so I am unsure if this is just a false negative or something? VM size is not an issue as this is the only sync that was running at the time and there was plenty of juice left in the VM.
Has anyone else seen this error? Was it actually an error, or just a false negative like I think it might be?
Beta Was this translation helpful? Give feedback.
All reactions