From 5d7bf24cf60db23b880b6e7662b44211c0930924 Mon Sep 17 00:00:00 2001
From: bryanwongsz <bryanwangsz@163.com>
Date: Sat, 8 Oct 2022 09:28:36 +0800
Subject: [PATCH] fixed duplicate child input error

---
 .../boostkit/spark/expression/OmniExpressionAdaptor.scala      | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/omnioperator/omniop-spark-extension/java/src/main/scala/com/huawei/boostkit/spark/expression/OmniExpressionAdaptor.scala b/omnioperator/omniop-spark-extension/java/src/main/scala/com/huawei/boostkit/spark/expression/OmniExpressionAdaptor.scala
index dbda2a73b..ffdf5852b 100644
--- a/omnioperator/omniop-spark-extension/java/src/main/scala/com/huawei/boostkit/spark/expression/OmniExpressionAdaptor.scala
+++ b/omnioperator/omniop-spark-extension/java/src/main/scala/com/huawei/boostkit/spark/expression/OmniExpressionAdaptor.scala
@@ -53,7 +53,8 @@ object OmniExpressionAdaptor extends Logging {
   }
   def getExprIdMap(inputAttrs: Seq[Attribute]): Map[ExprId, Int] = {
     var attrMap: Map[ExprId, Int] = Map()
-    inputAttrs.zipWithIndex.foreach { case (inputAttr, i) =>
+    inputAttrs.zipWithIndex.foreach { case (inputAttr, i)
+      if (!attrMap.contains(inputAttr.exprId)) =>
       attrMap += (inputAttr.exprId -> i)
     }
     attrMap
-- 
Gitee