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/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 6fc74def02 [fix](Broker load): fix bug for broker label has already
been used (#12630)
6fc74def02 is described below
commit 6fc74def02023f5d6bc9dbbad43ae0ad4301f7eb
Author: yongjinhou <[email protected]>
AuthorDate: Fri Sep 16 20:46:01 2022 +0800
[fix](Broker load): fix bug for broker label has already been used (#12630)
---
fe/fe-core/src/main/java/org/apache/doris/planner/BrokerScanNode.java | 3 +++
1 file changed, 3 insertions(+)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/planner/BrokerScanNode.java
b/fe/fe-core/src/main/java/org/apache/doris/planner/BrokerScanNode.java
index 7dcf633598..672419d3cd 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/planner/BrokerScanNode.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/planner/BrokerScanNode.java
@@ -243,6 +243,9 @@ public class BrokerScanNode extends LoadScanNode {
params.setLineDelimiterLength(fileGroup.getLineDelimiter().getBytes(Charset.forName("UTF-8")).length);
params.setStrictMode(strictMode);
params.setProperties(brokerDesc.getProperties());
+ if (params.getSrcSlotIds() == null) {
+ params.setSrcSlotIds(new java.util.ArrayList<java.lang.Integer>());
+ }
deleteCondition = fileGroup.getDeleteCondition();
mergeType = fileGroup.getMergeType();
initColumns(context);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
