[jira] [Created] (FLINK-12252) Support not escaped table name for External Catalogs in INSERT SQL statement

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-12252) Support not escaped table name for External Catalogs in INSERT SQL statement

Shang Yuanchun (Jira)
Artsem Semianenka created FLINK-12252:
-----------------------------------------

             Summary: Support not escaped table name for External Catalogs in INSERT SQL statement
                 Key: FLINK-12252
                 URL: https://issues.apache.org/jira/browse/FLINK-12252
             Project: Flink
          Issue Type: Improvement
          Components: Table SQL / Planner
    Affects Versions: 1.8.0, 1.9.0
            Reporter: Artsem Semianenka
            Assignee: Artsem Semianenka


In case if I want to write SQL stream query which inserting data into the sink which described in the external catalog I have to escape full table description in quotes. Example :

INSERT INTO +`test.db3.tb3`+ SELECT a,b,c,d FROM test.db2.tb2

I see a discrepancy in query semantic because the SELECT statement described without quotes.

I propose to add support of queries without quotes in INSERT statement like
 INSERT INTO test.db3.tb3 SELECT a,b,c,d FROM test.db2.tb2

Pull request is available



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)