debug

Author: youngsofun

databend-jdbc/src/main/java/com/databend/jdbc/DatabendClientLoadBalancingPolicy.java

@@ -27,6 +27,7 @@ protected URI pickUri(String query_id, DatabendNodes nodes) {
             // Use the deterministic value to select a URI
             int index = Math.abs(deterministicValue) % uris.size();
 
+            System.out.println("rand uri:" + index);
             return uris.get(index);
         }
 
@@ -45,9 +46,10 @@ protected URI pickUri(String query_id, DatabendNodes nodes) {
                 return null;
             }
 
-            // Use round robin to select a URI
+            // Use round-robin to select a URI
             int index = nodes.index.getAndUpdate(v -> v + 1 >= uris.size() ? 0 : v + 1);
 
+            System.out.println("rr get uri " + index + uris.get(index));
             return uris.get(index);
         }
 

databend-jdbc/src/test/java/com/databend/jdbc/TestMultiHost.java

@@ -218,6 +218,7 @@ public void testAutoDiscovery()
                     } else {
                         unknown++;
                     }
+                    System.out.println(i + "," + j + "" + p);
                 }
             }
         }