alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-7964 Fix formatting

Browse Source
This commit is contained in:
Jiri Pechanec 2024-06-27 12:04:49 +02:00
parent cac16464b4
commit be368e18d7
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
debezium-core/src/main/java/io/debezium/connector/common/BaseSourceTask.java
View File

@ -343,7 +343,7 @@ private void updateLastOffset(Map<String, ?> partition, Map<String, ?> lastOffse
protected void resetErrorHandlerRetriesIfNeeded(List<SourceRecord> records) {
// When a connector throws a retriable error, the task is not re-created and instead the previous
// error handler is passed into the new error handler, propagating the retry count. This method
// allows resetting that counter when a successful poll iteration step contains new records so that when a
// allows resetting that counter when a successful poll iteration step contains new records so that when a
// future failure is thrown, the maximum retry count can be utilized.
if (!records.isEmpty() && coordinator.getErrorHandler().getRetries() > 0) {
coordinator.getErrorHandler().resetRetries();