[jira] [Resolved] (FLINK-32447) table hints lost when they inside a view referenced by an external query

["lincoln lee (Jira)" <ji...@apache.org>]

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

lincoln lee resolved FLINK-32447.
---------------------------------
    Resolution: Fixed

fixed in master: e35f33f539b09b2c18fb826a144c08541e148dd0

> table hints lost when they inside a view referenced by an external query
> ------------------------------------------------------------------------
>
>                 Key: FLINK-32447
>                 URL: https://issues.apache.org/jira/browse/FLINK-32447
>             Project: Flink
>          Issue Type: Bug
>          Components: Table SQL / Planner
>    Affects Versions: 1.17.1
>            Reporter: lincoln lee
>            Assignee: lincoln lee
>            Priority: Major
>              Labels: pull-request-available
>             Fix For: 1.18.0, 1.17.2
>
>
> Table hints will lost when they inside a view referenced by an external query, this is due to the upgrading of calcite-1.28 (affected by CALCITE-4640 which changed the default implementation of SqlDialect suppresses all table hints).
> This can be reproduced by adding a new case to current {code}OptionsHintTest{code}:
> {code}
> +
> +  @Test
> +  def testOptionsHintInsideView(): Unit = {
> +    util.tableEnv.executeSql(
> +      "create view v1 as select * from t1 /*+ OPTIONS(k1='#v111', k4='#v444')*/")
> +    util.verifyExecPlan(s"""
> +                           |select * from t2 join v1 on v1.a = t2.d
> +                           |""".stripMargin)
> +  }
> {code}
> wrong plan which lost table hints(dynamic options):
> {code}
> Join(joinType=[InnerJoin], where=[(a = d)], select=[d, e, f, a, b, c], leftInputSpec=[NoUniqueKey], rightInputSpec=[NoUniqueKey])
> :- Exchange(distribution=[hash[d]])
> :  +- LegacyTableSourceScan(table=[[default_catalog, default_database, t2, source: [OptionsTableSource(props={k3=v3, k4=v4})]]], fields=[d, e, f])
> +- Exchange(distribution=[hash[a]])
>    +- Calc(select=[a, b, (a + 1) AS c])
>       +- LegacyTableSourceScan(table=[[default_catalog, default_database, t1, source: [OptionsTableSource(props={k1=v1, k2=v2})]]], fields=[a, b])
> {code}
> We should use {code}AnsiSqlDialect{code} instead to reserve table hints.



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