[flink] 02/03: [hotfix][datastream] Fix cache invalidate with remote session cluster

[gaoyunhaii]

This is an automated email from the ASF dual-hosted git repository.

gaoyunhaii pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 3d05f275225022984695cf2a14e3800580c3fea2
Author: sxnan <suxuanna...@gmail.com>
AuthorDate: Wed Aug 17 13:39:45 2022 +0800

    [hotfix][datastream] Fix cache invalidate with remote session cluster
---
 .../client/deployment/executors/AbstractSessionClusterExecutor.java     | 2 +-
 .../runtime/rest/handler/dataset/ClusterDataSetDeleteHandlers.java      | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/flink-clients/src/main/java/org/apache/flink/client/deployment/executors/AbstractSessionClusterExecutor.java
 
b/flink-clients/src/main/java/org/apache/flink/client/deployment/executors/AbstractSessionClusterExecutor.java
index 52c58e5d035..9397e506ccf 100644
--- 
a/flink-clients/src/main/java/org/apache/flink/client/deployment/executors/AbstractSessionClusterExecutor.java
+++ 
b/flink-clients/src/main/java/org/apache/flink/client/deployment/executors/AbstractSessionClusterExecutor.java
@@ -135,7 +135,7 @@ public class AbstractSessionClusterExecutor<
             final ClusterClient<ClusterID> clusterClient = 
clusterClientProvider.getClusterClient();
             return clusterClient
                     .invalidateClusterDataset(new 
IntermediateDataSetID(clusterDatasetId))
-                    .thenCompose(acknowledge -> null);
+                    .thenApply(acknowledge -> null);
         }
     }
 }
diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/dataset/ClusterDataSetDeleteHandlers.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/dataset/ClusterDataSetDeleteHandlers.java
index e273d1f5af9..80d9f2c9bb3 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/dataset/ClusterDataSetDeleteHandlers.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/dataset/ClusterDataSetDeleteHandlers.java
@@ -85,7 +85,7 @@ public class ClusterDataSetDeleteHandlers
                             resourceManagerGatewayRetriever);
             return resourceManagerGateway
                     .releaseClusterPartitions(clusterPartitionId)
-                    .thenApply(ignored -> null);
+                    .thenApply(ignored -> new SerializableVoid());
         }
 
         @Override