Junyewu opened a new issue #838:
URL: https://github.com/apache/submarine/issues/838
env:
spark-3.1.1
ranger-2.1
submarine-security-0.6.0
sql code
```
spark-sql> create or replace temporary view user_city_temp as
select id,case when if(city_zip_active >0,city_zip_active,if(city_zip_check
>0 ,city_zip_check,city_zip_phone)) in ('0100','0200','0300','0400') then
if(city_zip_active >0,city_zip_active,if(city_zip_check >0
,city_zip_check,city_zip_phone)) else 'other' end as city from user_city;
colum_name type
city_zip_phone int NULL
city_zip_check int NULL
city_zip_active int NULL
```
it will return a error
```
org.apache.spark.sql.catalyst.analysis.UnresolvedException: Invalid call to
exprId on unresolved object, tree: 'city_zip_active
at
org.apache.spark.sql.catalyst.analysis.UnresolvedAttribute.exprId(unresolved.scala:157)
at
org.apache.spark.sql.catalyst.optimizer.SubmarineDataMaskingExtension$$anonfun$collectAllAliases$1$$anonfun$applyOrElse$2.$anonfun$applyOrElse$3(SubmarineDataMaskingExtension.scala:191)
at scala.collection.mutable.HashMap.getOrElseUpdate(HashMap.scala:86)
at
org.apache.spark.sql.catalyst.optimizer.SubmarineDataMaskingExtension$$anonfun$collectAllAliases$1$$anonfun$applyOrElse$2.applyOrElse(SubmarineDataMaskingExtension.scala:191)
at
org.apache.spark.sql.catalyst.optimizer.SubmarineDataMaskingExtension$$anonfun$collectAllAliases$1$$anonfun$applyOrElse$2.applyOrElse(SubmarineDataMaskingExtension.scala:189)
at
org.apache.spark.sql.catalyst.trees.TreeNode.$anonfun$transformUp$2(TreeNode.scala:352)
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
