[ 
https://issues.apache.org/jira/browse/SPARK-43541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Max Gekk resolved SPARK-43541.
------------------------------
    Fix Version/s: 3.5.0
       Resolution: Fixed

Issue resolved by pull request 41204
[https://github.com/apache/spark/pull/41204]

> Incorrect column resolution on FULL OUTER JOIN with USING
> ---------------------------------------------------------
>
>                 Key: SPARK-43541
>                 URL: https://issues.apache.org/jira/browse/SPARK-43541
>             Project: Spark
>          Issue Type: Bug
>          Components: SQL
>    Affects Versions: 3.3.2, 3.4.0
>            Reporter: Max Gekk
>            Assignee: Max Gekk
>            Priority: Major
>             Fix For: 3.5.0
>
>
> This was tested on Spark 3.3.2 and Spark 3.4.0.
> {code}
> Causes [UNRESOLVED_COLUMN.WITH_SUGGESTION] A column or function parameter 
> with name `aws_dbr_a`.`key` cannot be resolved. Did you mean one of the 
> following? [`key`].; line 4, pos 7
> {code}
> FULL OUTER JOIN with USING and/or the WHERE seems relevant since I can get 
> the query to work with any of these modifications. 
> {code}
> # -- FULL OUTER JOIN
>                    WITH
>                    aws_dbr_a AS (select key from values ('a') t(key)),
>                    gcp_pro_b AS (select key from values ('a') t(key))
>                    SELECT aws_dbr_a.key
>                    FROM aws_dbr_a
>                    FULL OUTER JOIN gcp_pro_b USING (key)
>                    WHERE aws_dbr_a.key NOT LIKE 'spark.clusterUsageTags.%';
> [UNRESOLVED_COLUMN.WITH_SUGGESTION] A column or function parameter with name 
> `aws_dbr_a`.`key` cannot be resolved. Did you mean one of the following? 
> [`key`].; line 4 pos 7
> # -- INNER JOIN
>                    WITH
>                    aws_dbr_a AS (select key from values ('a') t(key)),
>                    gcp_pro_b AS (select key from values ('a') t(key))
>                    SELECT aws_dbr_a.key
>                    FROM aws_dbr_a
>                    JOIN gcp_pro_b USING (key)
>                    WHERE aws_dbr_a.key NOT LIKE 'spark.clusterUsageTags.%';
> +-----+
> | key |
> |-----|
> | a   |
> +-----+
> 1 row in set
> Time: 0.507s
> # -- NO Filter
>                    WITH
>                    aws_dbr_a AS (select key from values ('a') t(key)),
>                    gcp_pro_b AS (select key from values ('a') t(key))
>                    SELECT aws_dbr_a.key
>                    FROM aws_dbr_a
>                    FULL OUTER JOIN gcp_pro_b USING (key);
> +-----+
> | key |
> |-----|
> | a   |
> +-----+
> 1 row in set
> Time: 1.021s
> # -- ON instead of USING
>                    WITH
>                    aws_dbr_a AS (select key from values ('a') t(key)),
>                    gcp_pro_b AS (select key from values ('a') t(key))
>                    SELECT aws_dbr_a.key
>                    FROM aws_dbr_a
>                    FULL OUTER JOIN gcp_pro_b ON aws_dbr_a.key = gcp_pro_b.key
>                    WHERE aws_dbr_a.key NOT LIKE 'spark.clusterUsageTags.%';
> +-----+
> | key |
> |-----|
> | a   |
> +-----+
> 1 row in set
> Time: 0.514s
> {code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org
For additional commands, e-mail: issues-h...@spark.apache.org

Reply via email to