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
The following commit(s) were added to refs/heads/master by this push:
new b63c65a10bc [FLINK-31393][runtime] Fix the bug that HsFileDataManager
use an incorrect default timeout.
b63c65a10bc is described below
commit b63c65a10bc76b4dadd6ae17305ee1941b773601
Author: Weijie Guo <[email protected]>
AuthorDate: Fri Mar 10 15:56:08 2023 +0800
[FLINK-31393][runtime] Fix the bug that HsFileDataManager use an incorrect
default timeout.
This closes #22147
---
.../runtime/io/network/partition/hybrid/HybridShuffleConfiguration.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/HybridShuffleConfiguration.java
b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HybridShuffleConfiguration.java
index fdc252ad02b..27667afcd47 100644
---
a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HybridShuffleConfiguration.java
+++
b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HybridShuffleConfiguration.java
@@ -24,7 +24,7 @@ import java.time.Duration;
public class HybridShuffleConfiguration {
private static final int DEFAULT_MAX_BUFFERS_READ_AHEAD = 5;
- private static final Duration DEFAULT_BUFFER_REQUEST_TIMEOUT =
Duration.ofMillis(5);
+ private static final Duration DEFAULT_BUFFER_REQUEST_TIMEOUT =
Duration.ofMinutes(5);
private static final float DEFAULT_SELECTIVE_STRATEGY_SPILL_THRESHOLD =
0.7f;