diff --git a/d2/src/main/java/com/linkedin/d2/balancer/dualread/DualReadLoadBalancer.java b/d2/src/main/java/com/linkedin/d2/balancer/dualread/DualReadLoadBalancer.java index 0bd74f3e56..dd3c3cae56 100644 --- a/d2/src/main/java/com/linkedin/d2/balancer/dualread/DualReadLoadBalancer.java +++ b/d2/src/main/java/com/linkedin/d2/balancer/dualread/DualReadLoadBalancer.java @@ -153,7 +153,7 @@ public void getLoadBalancedServiceProperties(String serviceName, Callback _newLb.getLoadBalancedServiceProperties(serviceName, Callbacks.empty())); _oldLb.getLoadBalancedServiceProperties(serviceName, clientCallback); break; case OLD_LB_ONLY: @@ -172,7 +172,7 @@ public void getLoadBalancedClusterAndUriProperties(String clusterName, _newLb.getLoadBalancedClusterAndUriProperties(clusterName, callback); break; case DUAL_READ: - _newLb.getLoadBalancedClusterAndUriProperties(clusterName, Callbacks.empty()); + getLoadBalancerThreadPool().execute(() -> _newLb.getLoadBalancedClusterAndUriProperties(clusterName, Callbacks.empty())); _oldLb.getLoadBalancedClusterAndUriProperties(clusterName, callback); break; case OLD_LB_ONLY: