Skip to content

Commit b2ac472

Browse files
authored
fix: rate not recover (#261)
1 parent 9a0b518 commit b2ac472

File tree

1 file changed

+3
-1
lines changed
  • arex-instrumentation-foundation/src/main/java/io/arex/foundation/healthy

1 file changed

+3
-1
lines changed

arex-instrumentation-foundation/src/main/java/io/arex/foundation/healthy/HealthManager.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,7 @@ public class HealthManager {
4141
private static final AtomicInteger STATE = new AtomicInteger(NORMAL);
4242

4343
private static final RecordRateChecker DATA_SERVICE_CHECKER =
44-
new RecordRateChecker(TimeUnit.MILLISECONDS.toNanos(300));
44+
new RecordRateChecker(TimeUnit.MILLISECONDS.toNanos(3000));
4545
private static final RecordRateChecker BALANCE_CHECKER =
4646
new RecordRateChecker(TimeUnit.MILLISECONDS.toNanos(3000));
4747
private static ScheduledFuture<?> scheduledFuture = null;
@@ -161,6 +161,8 @@ boolean isRecover() {
161161
}
162162

163163
boolean isRecover = (fatal.get() < 3 && ((double)success.get() / total.get()) >= 0.99);
164+
LogManager.warn("isRecover", StringUtil.format("fatal=%s, success=%s, total=%s",
165+
String.valueOf(fatal), String.valueOf(success), String.valueOf(total)));
164166
reset();
165167
return isRecover;
166168
}

0 commit comments

Comments
 (0)