From a38fd90cb11eabcf6ddc18305818f422e10cede1 Mon Sep 17 00:00:00 2001
From: chaoyli <lichaoyong@baidu.com>
Date: Mon, 10 Jun 2019 12:54:21 +0800
Subject: [PATCH] Set timeout configuration for stream load

---
 .../main/java/org/apache/doris/planner/StreamLoadPlanner.java   | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/fe/src/main/java/org/apache/doris/planner/StreamLoadPlanner.java b/fe/src/main/java/org/apache/doris/planner/StreamLoadPlanner.java
index 5b1cdd92b1bdcb..6ab185624ada9c 100644
--- a/fe/src/main/java/org/apache/doris/planner/StreamLoadPlanner.java
+++ b/fe/src/main/java/org/apache/doris/planner/StreamLoadPlanner.java
@@ -19,6 +19,7 @@
 
 import org.apache.doris.catalog.AggregateType;
 import org.apache.doris.analysis.Analyzer;
+import org.apache.doris.common.Config;
 import org.apache.doris.common.DdlException;
 import org.apache.doris.analysis.DescriptorTable;
 import org.apache.doris.analysis.SlotDescriptor;
@@ -140,6 +141,7 @@ public TExecPlanFragmentParams plan() throws UserException {
         params.setParams(execParams);
         TQueryOptions queryOptions = new TQueryOptions();
         queryOptions.setQuery_type(TQueryType.LOAD);
+        queryOptions.setQuery_timeout(Config.stream_load_default_timeout_second);
         params.setQuery_options(queryOptions);
         TQueryGlobals queryGlobals = new TQueryGlobals();
         queryGlobals.setNow_string(DATE_FORMAT.format(new Date()));