minor correction

adwk67 · adwk67 · commit 47a23cbf3aae · 2025-12-16T17:43:47.000+01:00
diff --git a/src/main/java/tech/stackable/hadoop/StackableTopologyProvider.java b/src/main/java/tech/stackable/hadoop/StackableTopologyProvider.java
@@ -282,7 +282,7 @@ private String tryResolveListenerToDatanode(String name) {
     GenericKubernetesResource listener = cache.getListener(name);
     if (listener == null) {
       LOG.debug("Not a listener: {}", name);
-      return name;
+      return null;
     }
     // We found a listener, so we can resolve it directly
     return resolveListenerEndpoint(listener);

Original file line number	Diff line number	Diff line change
`@@ -282,7 +282,7 @@ private String tryResolveListenerToDatanode(String name) {`
`282`	`282`	`GenericKubernetesResource listener = cache.getListener(name);`
`283`	`283`	`if (listener == null) {`
`284`	`284`	`LOG.debug("Not a listener: {}", name);`
`285`		`- return name;`
	`285`	`+ return null;`
`286`	`286`	`}`
`287`	`287`	`// We found a listener, so we can resolve it directly`
`288`	`288`	`return resolveListenerEndpoint(listener);`