Add debug logging for config file load

trinodb · Oct 23, 2023 · 67d5d76 · 67d5d76
1 parent 03601a2
commit 67d5d76
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
diff --git a/gateway-ha/src/main/java/io/trino/gateway/ha/router/RuleReloadingRoutingGroupSelector.java b/gateway-ha/src/main/java/io/trino/gateway/ha/router/RuleReloadingRoutingGroupSelector.java
@@ -48,6 +48,7 @@ public String findRoutingGroup(HttpServletRequest request) {
     try {
       BasicFileAttributes attr = Files.readAttributes(Path.of(rulesConfigPath),
               BasicFileAttributes.class);
+      log.debug("File modified time: " + attr.lastModifiedTime() + ". lastUpdatedTime: " + lastUpdatedTime);
       if (attr.lastModifiedTime().toMillis() > lastUpdatedTime) {
         Lock writeLock = readWriteLock.writeLock();
         writeLock.lock();

diff --git a/gateway-ha/src/test/java/io/trino/gateway/ha/router/TestRoutingGroupSelector.java b/gateway-ha/src/test/java/io/trino/gateway/ha/router/TestRoutingGroupSelector.java
@@ -95,8 +95,8 @@ public void testByRoutingRulesEngineFileChange() throws Exception {
     FileWriter fw = new FileWriter(file);
     fw.write(
         "---\n"
-            + "name: \"airflow\"\n"
-            + "description: \"if query from airflow, route to etl group\"\n"
+            + "name: \"airflow1\"\n"
+            + "description: \"original rule\"\n"
             + "condition: \"request.getHeader(\\\"X-Trino-Source\\\") == \\\"airflow\\\"\"\n"
             + "actions:\n"
             + "  - \"result.put(\\\"routingGroup\\\", \\\"etl\\\")\"");
@@ -114,8 +114,8 @@ public void testByRoutingRulesEngineFileChange() throws Exception {
     fw = new FileWriter(file);
     fw.write(
         "---\n"
-            + "name: \"airflow\"\n"
-            + "description: \"if query from airflow, route to etl group\"\n"
+            + "name: \"airflow2\"\n"
+            + "description: \"updated rule\"\n"
             + "condition: \"request.getHeader(\\\"X-Trino-Source\\\") == \\\"airflow\\\"\"\n"
             + "actions:\n"
             + "  - \"result.put(\\\"routingGroup\\\", \\\"etl2\\\")\""); // change from etl to etl2