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

DBZ-4720 Deduplicate call of config.validateAndRecord()

Browse Source
This commit is contained in:
ggaborg 2022-11-11 12:58:44 +02:00 committed by Jiri Pechanec
parent 4a70dccd7d
commit 83a2ab5cbd
1 changed files with 0 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
debezium-storage/debezium-storage-file/src/main/java/io/debezium/storage/file/history/FileSchemaHistory.java
View File

@ -8,8 +8,6 @@
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.nio.charset.Charset;
import java.nio.charset.StandardCharsets;
import java.nio.file.FileAlreadyExistsException;
import java.nio.file.Files;
import java.nio.file.Path;
@ -50,7 +48,6 @@ public final class FileSchemaHistory extends AbstractSchemaHistory {
public static Collection<Field> ALL_FIELDS = Collect.arrayListOf(FILE_PATH);
private static final Charset UTF8 = StandardCharsets.UTF_8;
private final FunctionalReadWriteLock lock = FunctionalReadWriteLock.reentrant();
private final DocumentWriter writer = DocumentWriter.defaultWriter();
private final DocumentReader reader = DocumentReader.defaultReader();
@ -63,7 +60,6 @@ public void configure(Configuration config, HistoryRecordComparator comparator,
throw new ConnectException(
"Error configuring an instance of " + getClass().getSimpleName() + "; check the logs for details");
}
config.validateAndRecord(ALL_FIELDS, logger::error);
if (running.get()) {
throw new IllegalStateException("Database schema history file already initialized to " + path);
}