You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by mo...@apache.org on 2020/08/13 15:41:04 UTC
[incubator-doris] branch master updated: [Bug][RoutineLoad] Fix
routine load timezone property invalid (#4339)
This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-doris.git
The following commit(s) were added to refs/heads/master by this push:
new 4fa35c9 [Bug][RoutineLoad] Fix routine load timezone property invalid (#4339)
4fa35c9 is described below
commit 4fa35c9f39b8b641cb1852d2d86a671dea02735a
Author: HangyuanLiu <46...@qq.com>
AuthorDate: Thu Aug 13 23:40:54 2020 +0800
[Bug][RoutineLoad] Fix routine load timezone property invalid (#4339)
---
.../src/main/java/org/apache/doris/load/routineload/RoutineLoadJob.java | 1 +
1 file changed, 1 insertion(+)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadJob.java b/fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadJob.java
index fc32273..e747cfa 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadJob.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadJob.java
@@ -281,6 +281,7 @@ public abstract class RoutineLoadJob extends AbstractTxnStateChangeCallback impl
if (stmt.getMaxBatchSize() != -1) {
this.maxBatchSizeBytes = stmt.getMaxBatchSize();
}
+ jobProperties.put(LoadStmt.TIMEZONE, stmt.getTimezone());
jobProperties.put(LoadStmt.STRICT_MODE, String.valueOf(stmt.isStrictMode()));
if (Strings.isNullOrEmpty(stmt.getFormat()) || stmt.getFormat().equals("csv")) {
jobProperties.put(PROPS_FORMAT, "csv");
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org