You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@spark.apache.org by "Max Gekk (Jira)" <ji...@apache.org> on 2023/03/07 14:49:00 UTC
[jira] [Created] (SPARK-42702) Support parameterized CTE
Max Gekk created SPARK-42702:
--------------------------------
Summary: Support parameterized CTE
Key: SPARK-42702
URL: https://issues.apache.org/jira/browse/SPARK-42702
Project: Spark
Issue Type: New Feature
Components: SQL
Affects Versions: 3.4.0
Reporter: Max Gekk
Support named parameters in named common table expressions (CTE). At the moment, such queries failed:
{code:java}
CREATE TABLE tbl(namespace STRING) USING parquet
INSERT INTO tbl SELECT 'abc'
WITH transitions AS (
SELECT * FROM tbl WHERE namespace = :namespace
) SELECT * FROM transitions {code}
w/ the following error:
{code:java}
[UNBOUND_SQL_PARAMETER] Found the unbound parameter: `namespace`. Please, fix `args` and provide a mapping of the parameter to a SQL literal.; line 3 pos 38;
'WithCTE
:- 'CTERelationDef 0, false
: +- 'SubqueryAlias transitions
: +- 'Project [*]
: +- 'Filter (namespace#3 = parameter(namespace))
: +- SubqueryAlias spark_catalog.default.tbl
: +- Relation spark_catalog.default.tbl[namespace#3] parquet
+- 'Project [*]
+- 'SubqueryAlias transitions
+- 'CTERelationRef 0, falseorg.apache.spark.sql.AnalysisException: [UNBOUND_SQL_PARAMETER] Found the unbound parameter: `namespace`. Please, fix `args` and provide a mapping of the parameter to a SQL literal.; line 3 pos 38;
'WithCTE
:- 'CTERelationDef 0, false
: +- 'SubqueryAlias transitions
: +- 'Project [*]
: +- 'Filter (namespace#3 = parameter(namespace))
: +- SubqueryAlias spark_catalog.default.tbl
: +- Relation spark_catalog.default.tbl[namespace#3] parquet
+- 'Project [*]
+- 'SubqueryAlias transitions
+- 'CTERelationRef 0, false at org.apache.spark.sql.catalyst.analysis.package$AnalysisErrorAt.failAnalysis(package.scala:52)
at org.apache.spark.sql.catalyst.analysis.CheckAnalysis.$anonfun$checkAnalysis0$5(CheckAnalysis.scala:339)
at org.apache.spark.sql.catalyst.analysis.CheckAnalysis.$anonfun$checkAnalysis0$5$adapted(CheckAnalysis.scala:244) {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@spark.apache.org
For additional commands, e-mail: issues-help@spark.apache.org