File tree Expand file tree Collapse file tree 1 file changed +3
-0
lines changed
k8s-dns-name-resolver/src/main/java/com/evolution/jgrpc/tools/k8sdns Expand file tree Collapse file tree 1 file changed +3
-0
lines changed Original file line number Diff line number Diff line change @@ -143,6 +143,7 @@ private void handleResolutionFailure(Throwable err) {
143143 private void handleResolutionSuccess (List <InetAddress > addresses ) {
144144 // do not notify if addresses didn't change
145145 if (this .lastSuccessfulResult == null
146+ // the addresses list is always sorted here and contains only unique values
146147 || !this .lastSuccessfulResult .addresses .equals (addresses )) {
147148 var addrGroups = addresses .stream ().map (this ::mkAddressGroup ).toList ();
148149 getListener ().onAddresses (addrGroups , Attributes .EMPTY );
@@ -167,6 +168,8 @@ private void resolveAllAsync(
167168 Optional .ofNullable (result ).map (LookupResult ::getRecords ).orElse (List .of ());
168169 return records .stream ()
169170 .map (Record ::rdataToString )
171+ .distinct ()
172+ .sorted () // make sure that result comparison does not depend on order
170173 .map (InetAddresses ::forString )
171174 .toList ();
172175 })
You can’t perform that action at this time.
0 commit comments