[hotfix][datastream] Fix cache invalidate with remote session cluster

Gerrrr · Sep 8, 2022 · 3d05f27 · 3d05f27
1 parent a901911
commit 3d05f27
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...ain/java/org/apache/flink/client/deployment/executors/AbstractSessionClusterExecutor.java b/...ain/java/org/apache/flink/client/deployment/executors/AbstractSessionClusterExecutor.java
@@ -135,7 +135,7 @@ public CompletableFuture<Void> invalidateClusterDataset(
             final ClusterClient<ClusterID> clusterClient = clusterClientProvider.getClusterClient();
             return clusterClient
                     .invalidateClusterDataset(new IntermediateDataSetID(clusterDatasetId))
-                    .thenCompose(acknowledge -> null);
+                    .thenApply(acknowledge -> null);
         }
     }
 }
diff --git a/...main/java/org/apache/flink/runtime/rest/handler/dataset/ClusterDataSetDeleteHandlers.java b/...main/java/org/apache/flink/runtime/rest/handler/dataset/ClusterDataSetDeleteHandlers.java
@@ -85,7 +85,7 @@ protected CompletableFuture<SerializableVoid> triggerOperation(
                             resourceManagerGatewayRetriever);
             return resourceManagerGateway
                     .releaseClusterPartitions(clusterPartitionId)
-                    .thenApply(ignored -> null);
+                    .thenApply(ignored -> new SerializableVoid());
         }
 
         @Override