diff --git a/d2/src/main/java/com/linkedin/d2/xds/XdsClientImpl.java b/d2/src/main/java/com/linkedin/d2/xds/XdsClientImpl.java index 426a54ab39..b5ee6b0126 100644 --- 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 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); }