Skip to content

Commit 53f2204

Browse files
committed
[fix-36472][logminer]删除sleep
1 parent d79c4d2 commit 53f2204

File tree

1 file changed

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

1 file changed

+0
-3
lines changed

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

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -121,9 +121,6 @@ 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.....................");
127124
logMinerConnection.queryData(positionManager.getPosition(), logMinerSelectSql);
128125
LOG.debug("Update log and continue read:{}", positionManager.getPosition());
129126
}

0 commit comments

Comments
 (0)