This is an automated email from the ASF dual-hosted git repository. xtsong pushed a commit to branch release-1.18 in repository https://gitbox.apache.org/repos/asf/flink.git
commit ae647e2b489f22a32b25d3625e5a7d2090e85f06 Author: Yuxin Tan <tanyuxinw...@gmail.com> AuthorDate: Mon Aug 14 19:45:34 2023 +0800 [hotfix][network] Fix the close method for the tiered producer client --- .../network/partition/hybrid/tiered/shuffle/TieredResultPartition.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 d3aae631620..f7070165fa1 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 @@ -180,13 +180,13 @@ public class TieredResultPartition extends ResultPartition { @Override public void finish() throws IOException { broadcastEvent(EndOfPartitionEvent.INSTANCE, false); + tieredStorageProducerClient.close(); checkState(!isReleased(), "Result partition is already released."); super.finish(); } @Override public void close() { - tieredStorageProducerClient.close(); super.close(); }