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

DBZ-7461 Remove redundant log

Browse Source
This commit is contained in:
mfvitale 2024-02-22 09:41:47 +01:00 committed by Fiore Mario Vitale
parent ce17bdcce6
commit e174eae235
6 changed files with 6 additions and 34 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/MySqlSnapshotChangeEventSource.java
View File

@ -106,10 +106,7 @@ public SnapshottingTask getSnapshottingTask(MySqlPartition partition, MySqlOffse
boolean offsetExists = previousOffset != null;
boolean snapshotInProgress = false;
if (!offsetExists) {
LOGGER.info("No previous offset found");
}
else {
if (offsetExists) {
snapshotInProgress = previousOffset.isSnapshotRunning();
}

2
debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleConnectorTask.java
View File

@ -103,7 +103,7 @@ public ChangeEventSourceCoordinator<OraclePartition, OracleOffsetContext> start(
taskContext = new OracleTaskContext(connectorConfig, schema);
// If the binlog position is not available it is necessary to re-execute snapshot
// If the redo log position is not available it is necessary to re-execute snapshot
if (previousOffset == null) {
LOGGER.info("No previous offset found");
}

5
debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleSnapshotChangeEventSource.java
View File

@ -76,10 +76,7 @@ public SnapshottingTask getSnapshottingTask(OraclePartition partition, OracleOff
boolean offsetExists = previousOffset != null;
boolean snapshotInProgress = false;
if (!offsetExists) {
LOGGER.info("No previous offset found");
}
else {
if (offsetExists) {
snapshotInProgress = previousOffset.isSnapshotRunning();
}

19
debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/LogMinerStreamingChangeEventSource.java
View File

@ -397,25 +397,6 @@ private LogMinerEventProcessor createProcessor(ChangeEventSourceContext context,
return bufferType.createProcessor(context, connectorConfig, jdbcConnection, dispatcher, partition, offsetContext, schema, streamingMetrics);
}
/**
* Gets the first system change number in both archive and redo logs.
*
* @param connection database connection, should not be {@code null}
* @return the oldest system change number
* @throws SQLException if a database exception occurred
* @throws DebeziumException if the oldest system change number cannot be found due to no logs available
*/
private Optional<Scn> getFirstScnInLogs(OracleConnection connection) throws SQLException {
final String oldestFirstChangeQuery = SqlUtils.oldestFirstChangeQuery(archiveLogRetention, archiveDestinationName);
final String oldestScn = connection.singleOptionalValue(oldestFirstChangeQuery, rs -> rs.getString(1));
if (oldestScn == null) {
return Optional.empty();
}
LOGGER.trace("Oldest SCN in logs is '{}'", oldestScn);
return Optional.of(Scn.valueOf(oldestScn));
}
private void initializeRedoLogsForMining(OracleConnection connection, boolean postEndMiningSession, Scn startScn)
throws SQLException {
if (!postEndMiningSession) {

5
debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/PostgresSnapshotChangeEventSource.java
View File

@ -70,10 +70,7 @@ public SnapshottingTask getSnapshottingTask(PostgresPartition partition, Postgre
boolean offsetExists = previousOffset != null;
boolean snapshotInProgress = false;
if (!offsetExists) {
LOGGER.info("No previous offset found");
}
else {
if (offsetExists) {
snapshotInProgress = previousOffset.isSnapshotRunning();
}

4
debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerConnectorIT.java
View File

@ -2975,7 +2975,7 @@ private void shouldStopRetriableRestartsAtConfiguredMaximum(SqlRunnable scenario
connection.execute("ALTER DATABASE " + TestHelper.TEST_DATABASE_2 + " SET ONLINE");
}
catch (SQLException e) {
System.out.println("Exception while setting database online " + e.getMessage());
Testing.print("Exception while setting database online " + e.getMessage());
}
Awaitility.await().atMost(120, TimeUnit.SECONDS)
@ -2989,7 +2989,7 @@ private Callable<Boolean> databaseIsOnline() {
return () -> connection.queryAndMap("select state from sys.databases where name = '" + TEST_DATABASE_2 + "'", rs -> {
rs.next();
System.out.println("DB status " + rs.getInt(1));
Testing.print("DB status " + rs.getInt(1));
return rs.getInt(1) == ON_LINE;
});
}