Remove unnecessary null-check

trinodb · Oct 3, 2024 · 82ed10a · 82ed10a
1 parent 23b1e77
commit 82ed10a
Showing 1 changed file with 6 additions and 9 deletions.
diff --git a/core/trino-main/src/main/java/io/trino/memory/RemoteNodeMemory.java b/core/trino-main/src/main/java/io/trino/memory/RemoteNodeMemory.java
@@ -24,7 +24,6 @@
 import io.airlift.log.Logger;
 import io.airlift.units.Duration;
 import io.trino.metadata.InternalNode;
-import jakarta.annotation.Nullable;
 
 import java.net.URI;
 import java.util.Optional;
@@ -95,17 +94,15 @@ public void asyncRefresh()
             Futures.addCallback(responseFuture, new FutureCallback<>()
             {
                 @Override
-                public void onSuccess(@Nullable JsonResponse<MemoryInfo> result)
+                public void onSuccess(JsonResponse<MemoryInfo> result)
                 {
                     lastUpdateNanos.set(System.nanoTime());
                     future.compareAndSet(responseFuture, null);
-                    if (result != null) {
-                        if (result.hasValue()) {
-                            memoryInfo.set(Optional.ofNullable(result.getValue()));
-                        }
-                        if (result.getStatusCode() != OK.code()) {
-                            log.warn("Error fetching memory info from %s returned status %d", memoryInfoUri, result.getStatusCode());
-                        }
+                    if (result.hasValue()) {
+                        memoryInfo.set(Optional.ofNullable(result.getValue()));
+                    }
+                    if (result.getStatusCode() != OK.code()) {
+                        log.warn("Error fetching memory info from %s returned status %d", memoryInfoUri, result.getStatusCode());
                     }
                 }