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 2021/12/08 12:51:29 UTC
[incubator-doris] branch master updated: [fix](routine load) fix bug that can not read image when using keyword STREAM (#7323)
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 dc281eb [fix](routine load) fix bug that can not read image when using keyword STREAM (#7323)
dc281eb is described below
commit dc281ebc34ec726e3061c8247c9fe625530c3a13
Author: qiye <ji...@gmail.com>
AuthorDate: Wed Dec 8 20:51:17 2021 +0800
[fix](routine load) fix bug that can not read image when using keyword STREAM (#7323)
issue #7322
1. Support `stream` as an identifier.
2. Optimize exception log output in `RoutineLoad`
---
fe/fe-core/src/main/cup/sql_parser.cup | 2 ++
.../src/main/java/org/apache/doris/load/routineload/RoutineLoadJob.java | 2 +-
2 files changed, 3 insertions(+), 1 deletion(-)
diff --git a/fe/fe-core/src/main/cup/sql_parser.cup b/fe/fe-core/src/main/cup/sql_parser.cup
index 601fd79..9dfe8c6 100644
--- a/fe/fe-core/src/main/cup/sql_parser.cup
+++ b/fe/fe-core/src/main/cup/sql_parser.cup
@@ -5537,6 +5537,8 @@ keyword ::=
{: RESULT = id; :}
| KW_STORAGE:id
{: RESULT = id; :}
+ | KW_STREAM:id
+ {: RESULT = id; :}
| KW_STRING:id
{: RESULT = id; :}
| KW_TABLES:id
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 470c99b..2549ce3 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
@@ -1605,7 +1605,7 @@ public abstract class RoutineLoadJob extends AbstractTxnStateChangeCallback impl
stmt.checkLoadProperties();
setRoutineLoadDesc(stmt.getRoutineLoadDesc());
} catch (Exception e) {
- throw new IOException("error happens when parsing create routine load stmt: " + origStmt, e);
+ throw new IOException("error happens when parsing create routine load stmt: " + origStmt.originStmt, e);
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org