Skip to content

Commit d79c4d2

Browse files
committed
[fix-36472][logminer]增加sleep 模拟加载数据期间 日志切换
1 parent a80157c commit d79c4d2

File tree

1 file changed

+3
-0
lines changed
  • flinkx-oraclelogminer/flinkx-oraclelogminer-reader/src/main/java/com/dtstack/flinkx/oraclelogminer/format

1 file changed

+3
-0
lines changed

flinkx-oraclelogminer/flinkx-oraclelogminer-reader/src/main/java/com/dtstack/flinkx/oraclelogminer/format/LogMinerListener.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -121,6 +121,9 @@ public void run() {
121121
} else {
122122
logMinerConnection.closeStmt();
123123
logMinerConnection.startOrUpdateLogMiner(positionManager.getPosition());
124+
LOG.info("start sleep.....................");
125+
Thread.sleep(1000*60*2);
126+
LOG.info("end sleep.....................");
124127
logMinerConnection.queryData(positionManager.getPosition(), logMinerSelectSql);
125128
LOG.debug("Update log and continue read:{}", positionManager.getPosition());
126129
}

0 commit comments

Comments
 (0)