From af663be14d52774c602e39f97316673016b9e6bc Mon Sep 17 00:00:00 2001 From: Urmi Mustafi Date: Tue, 10 Oct 2023 13:05:59 -0700 Subject: [PATCH] Add TODO comment --- .../apache/gobblin/runtime/api/MysqlMultiActiveLeaseArbiter.java | 1 + 1 file changed, 1 insertion(+) diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/MysqlMultiActiveLeaseArbiter.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/MysqlMultiActiveLeaseArbiter.java index 0f69bbbd6a9..4c2e8d2da2b 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/MysqlMultiActiveLeaseArbiter.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/MysqlMultiActiveLeaseArbiter.java @@ -299,6 +299,7 @@ public LeaseAttemptStatus tryAcquireLease(DagActionStore.DagAction flowAction, l return new NoLongerLeasingStatus(); } if (eventTimeMillis > dbEventTimestamp.getTime()) { + // TODO: emit metric here to capture this unexpected behavior log.warn("tryAcquireLease for [{}, is: {}, eventTimestamp: {}] - dbEventTimeMillis: {} - Severe constraint " + "violation encountered: a reminder event newer than db event was found when db laundering should " + "ensure monotonically increasing laundered event times.", flowAction,