- Notifications
You must be signed in to change notification settings - Fork 4.9k
[DB-sources] : Improve heartbeat logic #40516
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
| The latest updates on your projects. Learn more about Vercel for Git ↗︎ 1 Ignored Deployment
|
...ces/src/main/kotlin/io/airbyte/cdk/integrations/debezium/internals/DebeziumRecordIterator.kt Show resolved Hide resolved
...ces/src/main/kotlin/io/airbyte/cdk/integrations/debezium/internals/DebeziumRecordIterator.kt Outdated Show resolved Hide resolved
.../connectors/source-mssql/src/main/java/io/airbyte/integrations/source/mssql/MssqlSource.java Show resolved Hide resolved
...src/test/kotlin/io/airbyte/cdk/integrations/debezium/internals/DebeziumRecordIteratorTest.kt Outdated Show resolved Hide resolved
| It seems the PR description is not very accurate. It looks like instead of removing heartbeat logic, we added a switch that allows us to ignore HB errors. The heartbeat still happens. I have a general question: if we do not exercise them in production, why do we still want them in the test? Why not simply remove those codes, as we no longer need the HB? |
Unfortunately, we require heartbeat in the tests. The goal here is to rely on the platform to shut down the sync if no records are emitted. However, in there are some unit tests where we want to force this heartbeat shutdown behavior - and we cannot lean on the platform. Having the debezium level heartbeat shutdown in this case helps simulates the "sync not progressing" case |
...ces/src/main/kotlin/io/airbyte/cdk/integrations/debezium/internals/DebeziumRecordIterator.kt Outdated Show resolved Hide resolved
...ces/src/main/kotlin/io/airbyte/cdk/integrations/debezium/internals/DebeziumRecordIterator.kt Show resolved Hide resolved
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Looks good! Thank you!
| /publish-java-cdk
|
| /publish-java-cdk
|
| @akashkulk did you mean to publish 0.40.6? |
Ah I did! but 0.40.6 failed. Turns out it was due to a compilation error (but I assumed it was due to version mismatch). If you have a PR in flight, can you publish 0.40.8? I think this PR should be in v soon so you can merge the changes in. SOrry for the confusion |
| cool, will do. I cancelled my 0.40.6 publish before it did anything, so we should be in a reasonable state |
Closes https://github.com/airbytehq/airbyte-internal-issues/issues/8255