Skip to content

Commit 10ae1ae

Browse files
PanternBaodcy10000
authored andcommitted
typo
1 parent c2b61e5 commit 10ae1ae

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

src/main/java/com/actiontech/dble/backend/heartbeat/MySQLDelayDetector.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -45,9 +45,9 @@ private void delayCal(long delay, long delayThreshold) {
4545
long logic = dbGroup.getLogicTimestamp().get();
4646
long result = logic - delay;
4747
if (result >= 0) {
48-
int delayPeriodMillis = dbGroup.getDbGroupConfig().getDelayPeriodMillis();
4948
long delayVal = 0;
5049
if (result > 0) {
50+
int delayPeriodMillis = dbGroup.getDbGroupConfig().getDelayPeriodMillis();
5151
delayVal = (result * delayPeriodMillis) + (delayPeriodMillis / 2);
5252
}
5353
if (delayThreshold > 0 && delayVal > delayThreshold) {

0 commit comments

Comments
 (0)