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

DBZ-7640 Guard row calculation with logger BinlogRowEstimateLogger

Browse Source
This commit is contained in:
Chris Cranford 2024-06-11 16:32:29 -04:00 committed by Jiri Pechanec
parent c792a94e44
commit ea281cf225
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
debezium-connector-binlog/src/main/java/io/debezium/connector/binlog/BinlogSnapshotChangeEventSource.java
View File

@ -67,6 +67,7 @@ public abstract class BinlogSnapshotChangeEventSource<P extends BinlogPartition,
extends RelationalSnapshotChangeEventSource<P, O> {
private static final Logger LOGGER = LoggerFactory.getLogger(BinlogSnapshotChangeEventSource.class);
private static final Logger BINLOG_ROW_ESTIMATE_LOGGER = LoggerFactory.getLogger("BinlogRowEstimateLogger");
private final BinlogConnectorConfig connectorConfig;
private final BinlogConnectorConnection connection;
@ -547,9 +548,12 @@ protected OptionalLong rowCountForTable(TableId tableId) {
if (getSnapshotSelectOverridesByTable(tableId, connectorConfig.getSnapshotSelectOverridesByTable()) != null) {
return super.rowCountForTable(tableId);
}
OptionalLong rowCount = connection.getEstimatedTableSize(tableId);
LOGGER.info("Estimated row count for table {} is {}", tableId, rowCount);
return rowCount;
if (BINLOG_ROW_ESTIMATE_LOGGER.isInfoEnabled()) {
OptionalLong rowCount = connection.getEstimatedTableSize(tableId);
LOGGER.info("Estimated row count for table {} is {}", tableId, rowCount);
return rowCount;
}
return OptionalLong.empty();
}
@Override