You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by gu...@apache.org on 2023/07/12 03:12:38 UTC
[flink] 01/02: [hotfix][network] Fix the availability of tiered result partition
This is an automated email from the ASF dual-hosted git repository.
guoweijie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 61d8fec84ad8d976d2186182e84548bf9cbfcd44
Author: Yuxin Tan <ta...@gmail.com>
AuthorDate: Mon Jul 10 13:18:17 2023 +0800
[hotfix][network] Fix the availability of tiered result partition
---
.../partition/hybrid/tiered/shuffle/TieredResultPartition.java | 5 +++++
1 file changed, 5 insertions(+)
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/shuffle/TieredResultPartition.java b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/shuffle/TieredResultPartition.java
index 8758a811ef4..605cb925fff 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/shuffle/TieredResultPartition.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/shuffle/TieredResultPartition.java
@@ -189,6 +189,11 @@ public class TieredResultPartition extends ResultPartition {
}
}
+ @Override
+ public CompletableFuture<?> getAvailableFuture() {
+ return AVAILABLE;
+ }
+
@Override
public void alignedBarrierTimeout(long checkpointId) throws IOException {
// Nothing to do.