[GOBBLIN-1851] Unit tests for MysqlMultiActiveLeaseArbiter with Singl…

…e Participant (#3715) * Unit tests and corresponding fixes for 6 lease acquisition cases * remove logs * address review comments with small changes * clean up naming, logs, java doc * close resultSets * check if test passes on github * fix unit test * insert or update constants into table correctly * rename prop * address comments --------- Co-authored-by: Urmi Mustafi <[email protected]> Co-authored-by: Urmi Mustafi <[email protected]>
apache · Jul 18, 2023 · ca48bcd · ca48bcd
1 parent 2c2ffac
commit ca48bcd
Show file tree

Hide file tree

Showing 5 changed files with 413 additions and 138 deletions.
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/configuration/ConfigurationKeys.java b/gobblin-api/src/main/java/org/apache/gobblin/configuration/ConfigurationKeys.java
@@ -99,7 +99,7 @@ public class ConfigurationKeys {
   public static final String MYSQL_LEASE_ARBITER_PREFIX = "MysqlMultiActiveLeaseArbiter";
   public static final String MULTI_ACTIVE_SCHEDULER_CONSTANTS_DB_TABLE_KEY = MYSQL_LEASE_ARBITER_PREFIX + ".constantsTable";
   public static final String DEFAULT_MULTI_ACTIVE_SCHEDULER_CONSTANTS_DB_TABLE = "gobblin_multi_active_scheduler_constants_store";
-  public static final String SCHEDULER_LEASE_DETERMINATION_STORE_DB_TABLE_KEY = MYSQL_LEASE_ARBITER_PREFIX + ".schedulerLeaseArbiterTable";
+  public static final String SCHEDULER_LEASE_DETERMINATION_STORE_DB_TABLE_KEY = MYSQL_LEASE_ARBITER_PREFIX + ".schedulerLeaseArbiter.store.db.table";
   public static final String DEFAULT_SCHEDULER_LEASE_DETERMINATION_STORE_DB_TABLE = "gobblin_scheduler_lease_determination_store";
   public static final String SCHEDULER_EVENT_TO_REVISIT_TIMESTAMP_MILLIS_KEY = "eventToRevisitTimestampMillis";
   public static final String SCHEDULER_EVENT_TO_TRIGGER_TIMESTAMP_MILLIS_KEY = "triggerEventTimestampMillis";