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

DBZ-2994 Return current SCN as string in LogMinerMetrics

Browse Source
This commit is contained in:
Chris Cranford 2021-03-17 14:57:09 -04:00 committed by Gunnar Morling
parent bd7adb40ed
commit 97da4333a3
3 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/LogMinerMetrics.java
View File

@ -195,8 +195,8 @@ public void incrementNetworkConnectionProblemsCounter() {
} }
@Override @Override
public Long getCurrentScn() { public String getCurrentScn() {
return currentScn.get().longValue(); return currentScn.get().toString();
} }
@Override @Override

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

@ -13,7 +13,7 @@ public interface LogMinerMetricsMXBean {
/** /**
* @return the current system change number of the database * @return the current system change number of the database
*/ */
Long getCurrentScn(); String getCurrentScn();
/** /**
* @return array of current filenames to be used by the mining session. * @return array of current filenames to be used by the mining session.

2
debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/logminer/LogMinerMetricsTest.java
View File

@ -50,7 +50,7 @@ public void testMetrics() {
assertThat(metrics.getTotalCapturedDmlCount() == 1).isTrue(); assertThat(metrics.getTotalCapturedDmlCount() == 1).isTrue();
metrics.setCurrentScn(Scn.valueOf(1000L)); metrics.setCurrentScn(Scn.valueOf(1000L));
assertThat(metrics.getCurrentScn()).isEqualTo(1000L); assertThat(metrics.getCurrentScn()).isEqualTo("1000");
metrics.setBatchSize(10); metrics.setBatchSize(10);
assertThat(metrics.getBatchSize() == connectorConfig.getLogMiningBatchSizeDefault()).isTrue(); assertThat(metrics.getBatchSize() == connectorConfig.getLogMiningBatchSizeDefault()).isTrue();