Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
0005485: Ignore missing tables on config channel
  • Loading branch information
erilong committed Sep 30, 2022
1 parent 93065a0 commit 7514d9d
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
Expand Up @@ -22,6 +22,7 @@

final public class IoConstants {
public static final long IGNORE_TABLES_BATCH = -9999;
public static final String CHANNEL_CONFIG = "config";

private IoConstants() {
}
Expand Down
Expand Up @@ -116,9 +116,8 @@ public void write(CsvData data) {
/*
* If the startTable has been called and the targetTable is required then check to see if the writer has been configured to ignore this data event
*/
if (sourceTable != null && targetTable == null &&
data.requiresTable() && (writerSettings.isIgnoreMissingTables()
|| batch.getBatchId() == IoConstants.IGNORE_TABLES_BATCH)) {
if (sourceTable != null && targetTable == null && data.requiresTable() && (writerSettings.isIgnoreMissingTables()
|| batch.getBatchId() == IoConstants.IGNORE_TABLES_BATCH || IoConstants.CHANNEL_CONFIG.equals(batch.getChannelId()))) {
String qualifiedName = sourceTable.getFullyQualifiedTableName();
if (missingTables.add(qualifiedName)) {
log.info("Did not find the {} table in the target database", qualifiedName);
Expand Down

0 comments on commit 7514d9d

Please sign in to comment.