[doris] branch master updated: [Improve](Routineload)Set the maximum timeout for obtaining partition to 60s (#24173)

[diwu]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new b4020a13ef [Improve](Routineload)Set the maximum timeout for obtaining 
partition to 60s (#24173)
b4020a13ef is described below

commit b4020a13ef43db4a792e902c8353980e3aa61cb1
Author: Calvin Kirs <acm_mas...@163.com>
AuthorDate: Mon Sep 11 14:15:06 2023 +0800

    [Improve](Routineload)Set the maximum timeout for obtaining partition to 
60s (#24173)
---
 fe/fe-core/src/main/java/org/apache/doris/common/util/KafkaUtil.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/fe/fe-core/src/main/java/org/apache/doris/common/util/KafkaUtil.java 
b/fe/fe-core/src/main/java/org/apache/doris/common/util/KafkaUtil.java
index 581a1ca48e..40041502ca 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/common/util/KafkaUtil.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/common/util/KafkaUtil.java
@@ -41,6 +41,7 @@ import java.util.stream.Collectors;
 
 public class KafkaUtil {
     private static final Logger LOG = LogManager.getLogger(KafkaUtil.class);
+    private static final int MAX_KAFKA_PARTITION_TIMEOUT_SECOND = 60;
 
     public static List<Integer> getAllKafkaPartitions(String brokerList, 
String topic,
             Map<String, String> convertedCustomProperties) throws 
UserException {
@@ -70,7 +71,7 @@ public class KafkaUtil {
 
             // get info
             Future<InternalService.PProxyResult> future = 
BackendServiceProxy.getInstance().getInfo(address, request);
-            InternalService.PProxyResult result = future.get(5, 
TimeUnit.SECONDS);
+            InternalService.PProxyResult result = 
future.get(MAX_KAFKA_PARTITION_TIMEOUT_SECOND, TimeUnit.SECONDS);
             TStatusCode code = 
TStatusCode.findByValue(result.getStatus().getStatusCode());
             if (code != TStatusCode.OK) {
                 throw new UserException("failed to get kafka partition info: " 
+ result.getStatus().getErrorMsgsList());


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org