[flink] 01/02: [hotfix][network] Fix the close method for the tiered producer client

[xtsong]

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

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

commit e41b0b2676166de582c4dd9f0289c585c31aca3b
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();
     }