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

DBZ-2410 Fix string compare.

Browse Source
This commit is contained in:
Bingqin Zhou 2020-08-24 22:22:22 -07:00 committed by Jiri Pechanec
parent d540d6d761
commit ad206b58bd
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-cassandra/src/main/java/io/debezium/connector/cassandra/CommitLogProcessor.java
View File

@ -125,8 +125,8 @@ void processCommitLog(File file) throws IOException {
if (!latestOnly) {
queue.enqueue(new EOFEvent(file, false));
}
LOGGER.warn("Error occurred while processing commit log " + file.getName(), e);
if (commitLogTransfer.getClass().toString() == CassandraConnectorConfig.DEFAULT_COMMIT_LOG_TRANSFER_CLASS) {
LOGGER.error("Error occurred while processing commit log " + file.getName(), e);
if (commitLogTransfer.getClass().getName().equals(CassandraConnectorConfig.DEFAULT_COMMIT_LOG_TRANSFER_CLASS)) {
throw e;
}
}