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

DBZ-7944 Revert exclude signal data collection from Oracle supplemental log check

Browse Source
This commit is contained in:
Chris Cranford 2024-06-13 10:19:49 -04:00 committed by Jiri Pechanec
parent cf3cf909e5
commit 4c3781a22f
1 changed files with 1 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -53,7 +53,6 @@
import io.debezium.util.Clock;
import io.debezium.util.Metronome;
import io.debezium.util.Stopwatch;
import io.debezium.util.Strings;
/**
* A {@link StreamingChangeEventSource} based on Oracle's LogMiner utility.
@ -863,16 +862,8 @@ private void checkDatabaseAndTableState(OracleConnection connection, String pdbN
+ "Use: ALTER DATABASE ADD SUPPLEMENTAL LOG DATA");
}
Set<TableId> tablesToCheck = schema.tableIds();
if (!Strings.isNullOrEmpty(connectorConfig.getSignalingDataCollectionId())) {
final TableId signalDataCollectionTableId = TableId.parse(connectorConfig.getSignalingDataCollectionId());
tablesToCheck = schema.tableIds().stream()
.filter(t -> !t.equals(signalDataCollectionTableId))
.collect(Collectors.toSet());
}
// Check if ALL COLUMNS supplemental logging is enabled for each captured table
for (TableId tableId : tablesToCheck) {
for (TableId tableId : schema.tableIds()) {
if (!connection.isTableExists(tableId)) {
LOGGER.warn("Database table '{}' no longer exists, supplemental log check skipped", tableId);
}