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

DBZ-7640 Changed naming

Browse Source
This commit is contained in:
Jiri Pechanec 2024-06-12 06:20:10 +02:00
parent ea281cf225
commit 657492d323
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -67,7 +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 static final Logger ROW_ESTIMATE_LOGGER = LoggerFactory.getLogger(BinlogSnapshotChangeEventSource.class.getName() + ".RowEstimate");
private final BinlogConnectorConfig connectorConfig;
private final BinlogConnectorConnection connection;
@ -548,7 +548,7 @@ protected OptionalLong rowCountForTable(TableId tableId) {
if (getSnapshotSelectOverridesByTable(tableId, connectorConfig.getSnapshotSelectOverridesByTable()) != null) {
return super.rowCountForTable(tableId);
}
if (BINLOG_ROW_ESTIMATE_LOGGER.isInfoEnabled()) {
if (ROW_ESTIMATE_LOGGER.isInfoEnabled()) {
OptionalLong rowCount = connection.getEstimatedTableSize(tableId);
LOGGER.info("Estimated row count for table {} is {}", tableId, rowCount);
return rowCount;