Fix type used during resubscribe

linkedin · Sep 4, 2024 · e49394b · e49394b
1 parent 15e436e
commit e49394b
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/d2/src/main/java/com/linkedin/d2/xds/XdsClientImpl.java b/d2/src/main/java/com/linkedin/d2/xds/XdsClientImpl.java
@@ -705,6 +705,7 @@ public void run() {
           resources = resources.stream()
               .map(GlobCollectionUtils::globCollectionUrlForClusterResource)
               .collect(Collectors.toSet());
+          type = ResourceType.D2_URI;
         }
         _adsStream.sendDiscoveryRequest(type, resources);
       }
@@ -943,8 +944,8 @@ public void onCompleted()
     private void sendDiscoveryRequest(ResourceType type, Collection<String> resources)
     {
       _log.info("Sending {} request for resources: {}", type, resources);
-      DiscoveryRequestData request = new DiscoveryRequestData(_node, type, resources);
-      _requestWriter.onNext(request.toEnvoyProto());
+      DeltaDiscoveryRequest request = new DiscoveryRequestData(_node, type, resources).toEnvoyProto();
+      _requestWriter.onNext(request);
       _log.debug("Sent DiscoveryRequest\n{}", request);
     }