[hotfix][client] Fix the NPE in LookupSender caused by the method not exiting when getting a null gateway

swuferhong · swuferhong · commit 56fe5933ae45 · 2025-12-08T11:12:16.000+08:00
diff --git a/fluss-client/src/main/java/org/apache/fluss/client/lookup/LookupSender.java b/fluss-client/src/main/java/org/apache/fluss/client/lookup/LookupSender.java
@@ -207,6 +207,7 @@ private void sendLookupRequest(int destination, List<AbstractLookupQuery<?>> loo
                                                     + " is not found in metadata cache."),
                                     destination,
                                     lookupsByBucket));
+            return;
         }
 
         lookupByTableId.forEach(
@@ -244,6 +245,7 @@ private void sendPrefixLookupRequest(
                                                     + " is not found in metadata cache."),
                                     destination,
                                     lookupsByBucket));
+            return;
         }
 
         lookupByTableId.forEach(

Original file line number	Diff line number	Diff line change
`@@ -207,6 +207,7 @@ private void sendLookupRequest(int destination, List<AbstractLookupQuery<?>> loo`
`207`	`207`	`+ " is not found in metadata cache."),`
`208`	`208`	`destination,`
`209`	`209`	`lookupsByBucket));`
	`210`	`+ return;`
`210`	`211`	`}`
`211`	`212`
`212`	`213`	`lookupByTableId.forEach(`
`@@ -244,6 +245,7 @@ private void sendPrefixLookupRequest(`
`244`	`245`	`+ " is not found in metadata cache."),`
`245`	`246`	`destination,`
`246`	`247`	`lookupsByBucket));`
	`248`	`+ return;`
`247`	`249`	`}`
`248`	`250`
`249`	`251`	`lookupByTableId.forEach(`