[jira] [Commented] (FLINK-22827) Hive dialect supports CLUSTERED BY clause of CREATE TABLE DDL

2022-08-16 Thread Ma Jun (Jira) 


[ 
https://issues.apache.org/jira/browse/FLINK-22827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17580540#comment-17580540
 ] 

Ma Jun commented on FLINK-22827:


[~luoyuxia] Thank you!  I merge you branch to my branch! 

> Hive dialect supports CLUSTERED BY clause of CREATE TABLE DDL
> -
>
> Key: FLINK-22827
> URL: https://issues.apache.org/jira/browse/FLINK-22827
> Project: Flink
>  Issue Type: New Feature
>  Components: Connectors / Hive
>Affects Versions: 1.13.1
>Reporter: Ma Jun
>Priority: Not a Priority
>  Labels: auto-deprioritized-major, auto-deprioritized-minor
>
> {code:java}
> # hive syntax:
> CREATE [ EXTERNAL ] TABLE [ IF NOT EXISTS ] table_identifier
> [ ( col_name1[:] col_type1 [ COMMENT col_comment1 ], ... ) ]
> [ COMMENT table_comment ]
> [ PARTITIONED BY ( col_name2[:] col_type2 [ COMMENT col_comment2 ], ... ) 
> | ( col_name1, col_name2, ... ) ]
> [ CLUSTERED BY ( col_name1, col_name2, ...) 
> [ SORTED BY ( col_name1 [ ASC | DESC ], col_name2 [ ASC | DESC ], ... 
> ) ] 
> INTO num_buckets BUCKETS ]
> [ ROW FORMAT row_format ]
> [ STORED AS file_format ]
> [ LOCATION path ]
> [ TBLPROPERTIES ( key1=val1, key2=val2, ... ) ]
> [ AS select_statement ]
> {code}
>  
> {code:java}
> [ CLUSTERED BY ( col_name1, col_name2, ...) [ SORTED BY ( col_name1 [ ASC | 
> DESC ], col_name2 [ ASC | DESC ], ... ) ] 
> {code}
> Will Flink support the way of creating tables and supporting clustered by | 
> sort by into buckets in later versions？



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

[jira] [Commented] (FLINK-22827) Hive dialect supports CLUSTERED BY clause of CREATE TABLE DDL

2022-07-08 Thread Ma Jun (Jira) 


[ 
https://issues.apache.org/jira/browse/FLINK-22827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564198#comment-17564198
 ] 

Ma Jun commented on FLINK-22827:


close issue

> Hive dialect supports CLUSTERED BY clause of CREATE TABLE DDL
> -
>
> Key: FLINK-22827
> URL: https://issues.apache.org/jira/browse/FLINK-22827
> Project: Flink
>  Issue Type: New Feature
>  Components: Connectors / Hive
>Affects Versions: 1.13.1
>Reporter: Ma Jun
>Priority: Not a Priority
>  Labels: auto-deprioritized-major, auto-deprioritized-minor
>
> {code:java}
> # hive syntax:
> CREATE [ EXTERNAL ] TABLE [ IF NOT EXISTS ] table_identifier
> [ ( col_name1[:] col_type1 [ COMMENT col_comment1 ], ... ) ]
> [ COMMENT table_comment ]
> [ PARTITIONED BY ( col_name2[:] col_type2 [ COMMENT col_comment2 ], ... ) 
> | ( col_name1, col_name2, ... ) ]
> [ CLUSTERED BY ( col_name1, col_name2, ...) 
> [ SORTED BY ( col_name1 [ ASC | DESC ], col_name2 [ ASC | DESC ], ... 
> ) ] 
> INTO num_buckets BUCKETS ]
> [ ROW FORMAT row_format ]
> [ STORED AS file_format ]
> [ LOCATION path ]
> [ TBLPROPERTIES ( key1=val1, key2=val2, ... ) ]
> [ AS select_statement ]
> {code}
>  
> {code:java}
> [ CLUSTERED BY ( col_name1, col_name2, ...) [ SORTED BY ( col_name1 [ ASC | 
> DESC ], col_name2 [ ASC | DESC ], ... ) ] 
> {code}
> Will Flink support the way of creating tables and supporting clustered by | 
> sort by into buckets in later versions？



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

[jira] [Comment Edited] (FLINK-22827) Hive CREATE TABLE Support CLUSTERED BY

2021-06-01 Thread Ma Jun (Jira) 


[ 
https://issues.apache.org/jira/browse/FLINK-22827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17355014#comment-17355014
 ] 

Ma Jun edited comment on FLINK-22827 at 6/1/21, 11:14 AM:
--

Hi [~joemoe], In our project, we mainly use the Flink planner to make a SQL 
verification judgment, and then we can let users submit the Flink SQL directly. 
because our environment is mainly the table hive environment, because I know 
whether the future Flink SQL parser intends to support this. In the 
flink-sql-parser-hive unit test, cluterered by is the TODO state.Now we have 
expanded the syntax support of createtable by modifying it, so we want to ask 
if the community needs to join in? 


was (Author: aidenma):
Hi [~joemoe], In our project, we mainly use the Flink planner to make a SQL 
verification judgment, and then we can let users submit the Flink SQL directly, 
because our environment is mainly the table hive environment, because I know 
whether the future Flink SQL parser intends to support this. In the 
flink-sql-parser-hive unit test, cluterered by is the TODO state.Now we have 
expanded the syntax support of createtable by modifying it, so we want to ask 
if the community needs to join in? 

> Hive CREATE TABLE Support CLUSTERED BY
> --
>
> Key: FLINK-22827
> URL: https://issues.apache.org/jira/browse/FLINK-22827
> Project: Flink
>  Issue Type: New Feature
>  Components: Table SQL / API
>Affects Versions: 1.13.1
>Reporter: Ma Jun
>Priority: Major
>
> {code:java}
> # hive syntax:
> CREATE [ EXTERNAL ] TABLE [ IF NOT EXISTS ] table_identifier
> [ ( col_name1[:] col_type1 [ COMMENT col_comment1 ], ... ) ]
> [ COMMENT table_comment ]
> [ PARTITIONED BY ( col_name2[:] col_type2 [ COMMENT col_comment2 ], ... ) 
> | ( col_name1, col_name2, ... ) ]
> [ CLUSTERED BY ( col_name1, col_name2, ...) 
> [ SORTED BY ( col_name1 [ ASC | DESC ], col_name2 [ ASC | DESC ], ... 
> ) ] 
> INTO num_buckets BUCKETS ]
> [ ROW FORMAT row_format ]
> [ STORED AS file_format ]
> [ LOCATION path ]
> [ TBLPROPERTIES ( key1=val1, key2=val2, ... ) ]
> [ AS select_statement ]
> {code}
>  
> {code:java}
> [ CLUSTERED BY ( col_name1, col_name2, ...) [ SORTED BY ( col_name1 [ ASC | 
> DESC ], col_name2 [ ASC | DESC ], ... ) ] 
> {code}
> Will Flink support the way of creating tables and supporting clustered by | 
> sort by into buckets in later versions？



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Commented] (FLINK-22827) Hive CREATE TABLE Support CLUSTERED BY

2021-06-01 Thread Ma Jun (Jira) 


[ 
https://issues.apache.org/jira/browse/FLINK-22827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17355014#comment-17355014
 ] 

Ma Jun commented on FLINK-22827:


Hi [~joemoe], In our project, we mainly use the Flink planner to make a SQL 
verification judgment, and then we can let users submit the Flink SQL directly, 
because our environment is mainly the table hive environment, because I know 
whether the future Flink SQL parser intends to support this. In the 
flink-sql-parser-hive unit test, cluterered by is the TODO state.Now we have 
expanded the syntax support of createtable by modifying it, so we want to ask 
if the community needs to join in? 

> Hive CREATE TABLE Support CLUSTERED BY
> --
>
> Key: FLINK-22827
> URL: https://issues.apache.org/jira/browse/FLINK-22827
> Project: Flink
>  Issue Type: New Feature
>  Components: Table SQL / API
>Affects Versions: 1.13.1
>Reporter: Ma Jun
>Priority: Major
>
> {code:java}
> # hive syntax:
> CREATE [ EXTERNAL ] TABLE [ IF NOT EXISTS ] table_identifier
> [ ( col_name1[:] col_type1 [ COMMENT col_comment1 ], ... ) ]
> [ COMMENT table_comment ]
> [ PARTITIONED BY ( col_name2[:] col_type2 [ COMMENT col_comment2 ], ... ) 
> | ( col_name1, col_name2, ... ) ]
> [ CLUSTERED BY ( col_name1, col_name2, ...) 
> [ SORTED BY ( col_name1 [ ASC | DESC ], col_name2 [ ASC | DESC ], ... 
> ) ] 
> INTO num_buckets BUCKETS ]
> [ ROW FORMAT row_format ]
> [ STORED AS file_format ]
> [ LOCATION path ]
> [ TBLPROPERTIES ( key1=val1, key2=val2, ... ) ]
> [ AS select_statement ]
> {code}
>  
> {code:java}
> [ CLUSTERED BY ( col_name1, col_name2, ...) [ SORTED BY ( col_name1 [ ASC | 
> DESC ], col_name2 [ ASC | DESC ], ... ) ] 
> {code}
> Will Flink support the way of creating tables and supporting clustered by | 
> sort by into buckets in later versions？



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Updated] (FLINK-22827) Hive CREATE TABLE Support CLUSTERED BY

2021-06-01 Thread Ma Jun (Jira) 


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

Ma Jun updated FLINK-22827:
---
Issue Type: New Feature  (was: Improvement)

> Hive CREATE TABLE Support CLUSTERED BY
> --
>
> Key: FLINK-22827
> URL: https://issues.apache.org/jira/browse/FLINK-22827
> Project: Flink
>  Issue Type: New Feature
>  Components: Table SQL / API
>Affects Versions: 1.13.1
>Reporter: Ma Jun
>Priority: Major
>
> {code:java}
> # hive syntax:
> CREATE [ EXTERNAL ] TABLE [ IF NOT EXISTS ] table_identifier
> [ ( col_name1[:] col_type1 [ COMMENT col_comment1 ], ... ) ]
> [ COMMENT table_comment ]
> [ PARTITIONED BY ( col_name2[:] col_type2 [ COMMENT col_comment2 ], ... ) 
> | ( col_name1, col_name2, ... ) ]
> [ CLUSTERED BY ( col_name1, col_name2, ...) 
> [ SORTED BY ( col_name1 [ ASC | DESC ], col_name2 [ ASC | DESC ], ... 
> ) ] 
> INTO num_buckets BUCKETS ]
> [ ROW FORMAT row_format ]
> [ STORED AS file_format ]
> [ LOCATION path ]
> [ TBLPROPERTIES ( key1=val1, key2=val2, ... ) ]
> [ AS select_statement ]
> {code}
>  
> {code:java}
> [ CLUSTERED BY ( col_name1, col_name2, ...) [ SORTED BY ( col_name1 [ ASC | 
> DESC ], col_name2 [ ASC | DESC ], ... ) ] 
> {code}
> Will Flink support the way of creating tables and supporting clustered by | 
> sort by into buckets in later versions？



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Updated] (FLINK-22827) Hive CREATE TABLE Support CLUSTERED BY

2021-06-01 Thread Ma Jun (Jira) 


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

Ma Jun updated FLINK-22827:
---
Issue Type: Improvement  (was: New Feature)

> Hive CREATE TABLE Support CLUSTERED BY
> --
>
> Key: FLINK-22827
> URL: https://issues.apache.org/jira/browse/FLINK-22827
> Project: Flink
>  Issue Type: Improvement
>  Components: Table SQL / API
>Affects Versions: 1.13.1
>Reporter: Ma Jun
>Priority: Major
>
> {code:java}
> # hive syntax:
> CREATE [ EXTERNAL ] TABLE [ IF NOT EXISTS ] table_identifier
> [ ( col_name1[:] col_type1 [ COMMENT col_comment1 ], ... ) ]
> [ COMMENT table_comment ]
> [ PARTITIONED BY ( col_name2[:] col_type2 [ COMMENT col_comment2 ], ... ) 
> | ( col_name1, col_name2, ... ) ]
> [ CLUSTERED BY ( col_name1, col_name2, ...) 
> [ SORTED BY ( col_name1 [ ASC | DESC ], col_name2 [ ASC | DESC ], ... 
> ) ] 
> INTO num_buckets BUCKETS ]
> [ ROW FORMAT row_format ]
> [ STORED AS file_format ]
> [ LOCATION path ]
> [ TBLPROPERTIES ( key1=val1, key2=val2, ... ) ]
> [ AS select_statement ]
> {code}
>  
> {code:java}
> [ CLUSTERED BY ( col_name1, col_name2, ...) [ SORTED BY ( col_name1 [ ASC | 
> DESC ], col_name2 [ ASC | DESC ], ... ) ] 
> {code}
> Will Flink support the way of creating tables and supporting clustered by | 
> sort by into buckets in later versions？



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Created] (FLINK-22827) Hive CREATE TABLE Support CLUSTERED BY

2021-06-01 Thread Ma Jun (Jira) 
Ma Jun created FLINK-22827:
--

 Summary: Hive CREATE TABLE Support CLUSTERED BY
 Key: FLINK-22827
 URL: https://issues.apache.org/jira/browse/FLINK-22827
 Project: Flink
  Issue Type: New Feature
  Components: Table SQL / API
Affects Versions: 1.13.1
Reporter: Ma Jun


{code:java}
# hive syntax:
CREATE [ EXTERNAL ] TABLE [ IF NOT EXISTS ] table_identifier
[ ( col_name1[:] col_type1 [ COMMENT col_comment1 ], ... ) ]
[ COMMENT table_comment ]
[ PARTITIONED BY ( col_name2[:] col_type2 [ COMMENT col_comment2 ], ... ) 
| ( col_name1, col_name2, ... ) ]
[ CLUSTERED BY ( col_name1, col_name2, ...) 
[ SORTED BY ( col_name1 [ ASC | DESC ], col_name2 [ ASC | DESC ], ... ) 
] 
INTO num_buckets BUCKETS ]
[ ROW FORMAT row_format ]
[ STORED AS file_format ]
[ LOCATION path ]
[ TBLPROPERTIES ( key1=val1, key2=val2, ... ) ]
[ AS select_statement ]

{code}
 
{code:java}
[ CLUSTERED BY ( col_name1, col_name2, ...) [ SORTED BY ( col_name1 [ ASC | 
DESC ], col_name2 [ ASC | DESC ], ... ) ] 
{code}
Will Flink support the way of creating tables and supporting clustered by | 
sort by into buckets in later versions？



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Commented] (FLINK-22408) Flink Table Parsr Hive Drop Partitions Syntax unparse is Error

2021-05-11 Thread Ma Jun (Jira) 


[ 
https://issues.apache.org/jira/browse/FLINK-22408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17342528#comment-17342528
 ] 

Ma Jun commented on FLINK-22408:


Hi [~lirui] , The branch release-1.13 need to submit?

> Flink Table Parsr Hive Drop Partitions Syntax unparse is Error
> --
>
> Key: FLINK-22408
> URL: https://issues.apache.org/jira/browse/FLINK-22408
> Project: Flink
>  Issue Type: Bug
>  Components: Connectors / Hive
>Affects Versions: 1.11.3
>Reporter: Ma Jun
>Assignee: Ma Jun
>Priority: Major
>  Labels: pull-request-available
>
> Flink Table Parser is error：
> *Synopsis:*
>  
> *SQL：*
> {code:java}
> alter table tbl drop partition (p1='a',p2=1), partition(p1='b',p2=2);{code}
> *hive muit partition unparse toSqlString is :*
> {code:java}
> ALTER TABLE `TBL`\n" +
>   "DROP\n" +
>   "PARTITION (`P1` = 'a', `P2` = 1)\n" +
>   "PARTITION (`P1` = 'b', `P2` = 2)
> {code}
> Missing comma in Partition SqlNodeList 
>  Hive syntax：
> {code:java}
> ALTER TABLE table_name DROP [IF EXISTS] PARTITION (partition_spec) [, 
> PARTITION (partition_spec)];
> {code}
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Commented] (FLINK-22408) Flink Table Parsr Hive Drop Partitions Syntax unparse is Error

2021-05-07 Thread Ma Jun (Jira) 


[ 
https://issues.apache.org/jira/browse/FLINK-22408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17340600#comment-17340600
 ] 

Ma Jun commented on FLINK-22408:


[~lirui] The branch has been pulled according to realease-1.12. See the link 
for details.

> Flink Table Parsr Hive Drop Partitions Syntax unparse is Error
> --
>
> Key: FLINK-22408
> URL: https://issues.apache.org/jira/browse/FLINK-22408
> Project: Flink
>  Issue Type: Bug
>  Components: Connectors / Hive
>Affects Versions: 1.11.3
>Reporter: Ma Jun
>Priority: Major
>  Labels: pull-request-available
>
> Flink Table Parser is error：
> *Synopsis:*
>  
> *SQL：*
> {code:java}
> alter table tbl drop partition (p1='a',p2=1), partition(p1='b',p2=2);{code}
> *hive muit partition unparse toSqlString is :*
> {code:java}
> ALTER TABLE `TBL`\n" +
>   "DROP\n" +
>   "PARTITION (`P1` = 'a', `P2` = 1)\n" +
>   "PARTITION (`P1` = 'b', `P2` = 2)
> {code}
> Missing comma in Partition SqlNodeList 
>  Hive syntax：
> {code:java}
> ALTER TABLE table_name DROP [IF EXISTS] PARTITION (partition_spec) [, 
> PARTITION (partition_spec)];
> {code}
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Comment Edited] (FLINK-22408) Flink Table Parsr Hive Drop Partitions Syntax unparse is Error

2021-04-26 Thread Ma Jun (Jira) 


[ 
https://issues.apache.org/jira/browse/FLINK-22408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17332910#comment-17332910
 ] 

Ma Jun edited comment on FLINK-22408 at 4/27/21, 3:54 AM:
--

Hi [~lirui] Thank！I got it! I know that if there is a subsequent release of 
version 1.13, I will switch the version of the existing business. I have a 
business requirement here: I use the module SQL translation in Flink to do some 
front-end SQL verification and formatting, because I found that the syntax of 
hive is inconsistent when converting dialects. There may be misunderstandings 
among users. So I think we should keep the syntax consistent with hive.


was (Author: aidenma):
Hi [~lirui] Thank！I got it! I know that if there is a subsequent release of 
version 1.13, I will switch the version of the existing business. I have a 
business requirement here: I use the module SQL translation in Flink to do some 
front-end SQL verification and formatting, because I found that the syntax of 
hive is inconsistent when converting dialects. So I think we should keep the 
syntax consistent with hive.

> Flink Table Parsr Hive Drop Partitions Syntax unparse is Error
> --
>
> Key: FLINK-22408
> URL: https://issues.apache.org/jira/browse/FLINK-22408
> Project: Flink
>  Issue Type: Bug
>  Components: Connectors / Hive
>Affects Versions: 1.11.3
>Reporter: Ma Jun
>Priority: Major
>  Labels: pull-request-available
>
> Flink Table Parser is error：
> *Synopsis:*
>  
> *SQL：*
> {code:java}
> alter table tbl drop partition (p1='a',p2=1), partition(p1='b',p2=2);{code}
> *hive muit partition unparse toSqlString is :*
> {code:java}
> ALTER TABLE `TBL`\n" +
>   "DROP\n" +
>   "PARTITION (`P1` = 'a', `P2` = 1)\n" +
>   "PARTITION (`P1` = 'b', `P2` = 2)
> {code}
> Missing comma in Partition SqlNodeList 
>  Hive syntax：
> {code:java}
> ALTER TABLE table_name DROP [IF EXISTS] PARTITION (partition_spec) [, 
> PARTITION (partition_spec)];
> {code}
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Commented] (FLINK-22408) Flink Table Parsr Hive Drop Partitions Syntax unparse is Error

2021-04-26 Thread Ma Jun (Jira) 


[ 
https://issues.apache.org/jira/browse/FLINK-22408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17332910#comment-17332910
 ] 

Ma Jun commented on FLINK-22408:


Hi [~lirui] Thank！I got it! I know that if there is a subsequent release of 
version 1.13, I will switch the version of the existing business. I have a 
business requirement here: I use the module SQL translation in Flink to do some 
front-end SQL verification and formatting, because I found that the syntax of 
hive is inconsistent when converting dialects. So I think we should keep the 
syntax consistent with hive.

> Flink Table Parsr Hive Drop Partitions Syntax unparse is Error
> --
>
> Key: FLINK-22408
> URL: https://issues.apache.org/jira/browse/FLINK-22408
> Project: Flink
>  Issue Type: Bug
>  Components: Connectors / Hive
>Affects Versions: 1.11.3
>Reporter: Ma Jun
>Priority: Major
>  Labels: pull-request-available
>
> Flink Table Parser is error：
> *Synopsis:*
>  
> *SQL：*
> {code:java}
> alter table tbl drop partition (p1='a',p2=1), partition(p1='b',p2=2);{code}
> *hive muit partition unparse toSqlString is :*
> {code:java}
> ALTER TABLE `TBL`\n" +
>   "DROP\n" +
>   "PARTITION (`P1` = 'a', `P2` = 1)\n" +
>   "PARTITION (`P1` = 'b', `P2` = 2)
> {code}
> Missing comma in Partition SqlNodeList 
>  Hive syntax：
> {code:java}
> ALTER TABLE table_name DROP [IF EXISTS] PARTITION (partition_spec) [, 
> PARTITION (partition_spec)];
> {code}
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Comment Edited] (FLINK-22408) Flink Table Parsr Hive Drop Partitions Syntax unparse is Error

2021-04-22 Thread Ma Jun (Jira) 


[ 
https://issues.apache.org/jira/browse/FLINK-22408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17329983#comment-17329983
 ] 

Ma Jun edited comment on FLINK-22408 at 4/23/21, 5:08 AM:
--

I think the final Unparse result：
{code:java}
ALTER TABLE tbl DROP PARTITION (p1='a',p2=1), PARTITION (p1='b',p2=2);
{code}


was (Author: aidenma):
I think the final Unparse result：
{code:java}
ALTER TABLE tbl DROP PARTITION (p1='a',p2=1), PARTITION  (p1='b',p2=2);
{code}

> Flink Table Parsr Hive Drop Partitions Syntax unparse is Error
> --
>
> Key: FLINK-22408
> URL: https://issues.apache.org/jira/browse/FLINK-22408
> Project: Flink
>  Issue Type: New Feature
>  Components: Table SQL / API, Table SQL / Planner
>Affects Versions: 1.11.3
>Reporter: Ma Jun
>Priority: Major
>  Labels: pull-request-available
>
> Flink Table Parser is error：
> *Synopsis:*
>  
> *SQL：*
> {code:java}
> alter table tbl drop partition (p1='a',p2=1), partition(p1='b',p2=2);{code}
> *hive muit partition unparse toSqlString is :*
> {code:java}
> ALTER TABLE `TBL`\n" +
>   "DROP\n" +
>   "PARTITION (`P1` = 'a', `P2` = 1)\n" +
>   "PARTITION (`P1` = 'b', `P2` = 2)
> {code}
> Missing comma in Partition SqlNodeList 
>  Hive syntax：
> {code:java}
> ALTER TABLE table_name DROP [IF EXISTS] PARTITION (partition_spec) [, 
> PARTITION (partition_spec)];
> {code}
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Commented] (FLINK-22408) Flink Table Parsr Hive Drop Partitions Syntax unparse is Error

2021-04-22 Thread Ma Jun (Jira) 


[ 
https://issues.apache.org/jira/browse/FLINK-22408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17329983#comment-17329983
 ] 

Ma Jun commented on FLINK-22408:


I think the final Unparse result：
{code:java}
alter table tbl drop partition (p1='a',p2=1), partition(p1='b',p2=2);
{code}

> Flink Table Parsr Hive Drop Partitions Syntax unparse is Error
> --
>
> Key: FLINK-22408
> URL: https://issues.apache.org/jira/browse/FLINK-22408
> Project: Flink
>  Issue Type: New Feature
>  Components: Table SQL / API, Table SQL / Planner
>Affects Versions: 1.11.3
>Reporter: Ma Jun
>Priority: Major
>  Labels: pull-request-available
>
> Flink Table Parser is error：
> *Synopsis:*
>  
> *SQL：*
> {code:java}
> alter table tbl drop partition (p1='a',p2=1), partition(p1='b',p2=2);{code}
> *hive muit partition unparse toSqlString is :*
> {code:java}
> ALTER TABLE `TBL`\n" +
>   "DROP\n" +
>   "PARTITION (`P1` = 'a', `P2` = 1)\n" +
>   "PARTITION (`P1` = 'b', `P2` = 2)
> {code}
> Missing comma in Partition SqlNodeList 
>  Hive syntax：
> {code:java}
> ALTER TABLE table_name DROP [IF EXISTS] PARTITION (partition_spec) [, 
> PARTITION (partition_spec)];
> {code}
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Comment Edited] (FLINK-22408) Flink Table Parsr Hive Drop Partitions Syntax unparse is Error

2021-04-22 Thread Ma Jun (Jira) 


[ 
https://issues.apache.org/jira/browse/FLINK-22408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17329983#comment-17329983
 ] 

Ma Jun edited comment on FLINK-22408 at 4/23/21, 5:07 AM:
--

I think the final Unparse result：
{code:java}
ALTER TABLE tbl DROP PARTITION (p1='a',p2=1), PARTITION  (p1='b',p2=2);
{code}


was (Author: aidenma):
I think the final Unparse result：
{code:java}
alter table tbl drop partition (p1='a',p2=1), partition(p1='b',p2=2);
{code}

> Flink Table Parsr Hive Drop Partitions Syntax unparse is Error
> --
>
> Key: FLINK-22408
> URL: https://issues.apache.org/jira/browse/FLINK-22408
> Project: Flink
>  Issue Type: New Feature
>  Components: Table SQL / API, Table SQL / Planner
>Affects Versions: 1.11.3
>Reporter: Ma Jun
>Priority: Major
>  Labels: pull-request-available
>
> Flink Table Parser is error：
> *Synopsis:*
>  
> *SQL：*
> {code:java}
> alter table tbl drop partition (p1='a',p2=1), partition(p1='b',p2=2);{code}
> *hive muit partition unparse toSqlString is :*
> {code:java}
> ALTER TABLE `TBL`\n" +
>   "DROP\n" +
>   "PARTITION (`P1` = 'a', `P2` = 1)\n" +
>   "PARTITION (`P1` = 'b', `P2` = 2)
> {code}
> Missing comma in Partition SqlNodeList 
>  Hive syntax：
> {code:java}
> ALTER TABLE table_name DROP [IF EXISTS] PARTITION (partition_spec) [, 
> PARTITION (partition_spec)];
> {code}
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Commented] (FLINK-22408) Flink Table Parsr Hive Drop Partitions Syntax unparse is Error

2021-04-22 Thread Ma Jun (Jira) 


[ 
https://issues.apache.org/jira/browse/FLINK-22408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17329981#comment-17329981
 ] 

Ma Jun commented on FLINK-22408:


We mainly use hive in the table environment. We find this syntax problem in the 
production environment. At present, there is a difference between hive and hive 
syntax, which leads to Hive SQL failure.

> Flink Table Parsr Hive Drop Partitions Syntax unparse is Error
> --
>
> Key: FLINK-22408
> URL: https://issues.apache.org/jira/browse/FLINK-22408
> Project: Flink
>  Issue Type: New Feature
>  Components: Table SQL / API, Table SQL / Planner
>Affects Versions: 1.11.3
>Reporter: Ma Jun
>Priority: Major
>  Labels: pull-request-available
>
> Flink Table Parser is error：
> *Synopsis:*
>  
> *SQL：*
> {code:java}
> alter table tbl drop partition (p1='a',p2=1), partition(p1='b',p2=2);{code}
> *hive muit partition unparse toSqlString is :*
> {code:java}
> ALTER TABLE `TBL`\n" +
>   "DROP\n" +
>   "PARTITION (`P1` = 'a', `P2` = 1)\n" +
>   "PARTITION (`P1` = 'b', `P2` = 2)
> {code}
> Missing comma in Partition SqlNodeList 
>  Hive syntax：
> {code:java}
> ALTER TABLE table_name DROP [IF EXISTS] PARTITION (partition_spec) [, 
> PARTITION (partition_spec)];
> {code}
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Updated] (FLINK-22408) Flink Table Parsr Hive Drop Partitions Syntax unparse is Error

2021-04-22 Thread Ma Jun (Jira) 


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

Ma Jun updated FLINK-22408:
---
Description: 
Flink Table Parser is error：

*Synopsis:*

 

*SQL：*
{code:java}
alter table tbl drop partition (p1='a',p2=1), partition(p1='b',p2=2);{code}
*hive muit partition unparse toSqlString is :*
{code:java}
ALTER TABLE `TBL`\n" +
  "DROP\n" +
  "PARTITION (`P1` = 'a', `P2` = 1)\n" +
  "PARTITION (`P1` = 'b', `P2` = 2)
{code}
Missing comma in Partition SqlNodeList 

 Hive syntax：
{code:java}
ALTER TABLE table_name DROP [IF EXISTS] PARTITION (partition_spec) [, PARTITION 
(partition_spec)];
{code}
 

  was:
Flink Table Parser is error：

*Synopsis:*

 

*SQL：*
{code:java}
alter table tbl drop partition (p1='a',p2=1), partition(p1='b',p2=2);{code}
*unparse toSqlString is :*
{code:java}
ALTER TABLE `TBL`\n" +
  "DROP\n" +
  "PARTITION (`P1` = 'a', `P2` = 1)\n" +
  "PARTITION (`P1` = 'b', `P2` = 2)
{code}
Missing comma in Partition SqlNodeList 

 Hive syntax：
{code:java}
ALTER TABLE table_name DROP [IF EXISTS] PARTITION (partition_spec) [, PARTITION 
(partition_spec)];
{code}
 


> Flink Table Parsr Hive Drop Partitions Syntax unparse is Error
> --
>
> Key: FLINK-22408
> URL: https://issues.apache.org/jira/browse/FLINK-22408
> Project: Flink
>  Issue Type: Bug
>  Components: Table SQL / API, Table SQL / Planner
>Affects Versions: 1.11.3
>Reporter: Ma Jun
>Priority: Major
>
> Flink Table Parser is error：
> *Synopsis:*
>  
> *SQL：*
> {code:java}
> alter table tbl drop partition (p1='a',p2=1), partition(p1='b',p2=2);{code}
> *hive muit partition unparse toSqlString is :*
> {code:java}
> ALTER TABLE `TBL`\n" +
>   "DROP\n" +
>   "PARTITION (`P1` = 'a', `P2` = 1)\n" +
>   "PARTITION (`P1` = 'b', `P2` = 2)
> {code}
> Missing comma in Partition SqlNodeList 
>  Hive syntax：
> {code:java}
> ALTER TABLE table_name DROP [IF EXISTS] PARTITION (partition_spec) [, 
> PARTITION (partition_spec)];
> {code}
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Created] (FLINK-22408) Flink Table Parsr Hive Drop Partitions Syntax unparse is Error

2021-04-22 Thread Ma Jun (Jira) 
Ma Jun created FLINK-22408:
--

 Summary: Flink Table Parsr Hive Drop Partitions Syntax unparse is 
Error
 Key: FLINK-22408
 URL: https://issues.apache.org/jira/browse/FLINK-22408
 Project: Flink
  Issue Type: Bug
  Components: Table SQL / API, Table SQL / Planner
Affects Versions: 1.11.3
Reporter: Ma Jun


Flink Table Parser is error：

*Synopsis:*

 

*SQL：*
{code:java}
alter table tbl drop partition (p1='a',p2=1), partition(p1='b',p2=2);{code}
*unparse toSqlString is :*
{code:java}
ALTER TABLE `TBL`\n" +
  "DROP\n" +
  "PARTITION (`P1` = 'a', `P2` = 1)\n" +
  "PARTITION (`P1` = 'b', `P2` = 2)
{code}
Missing comma in Partition SqlNodeList 

 Hive syntax：
{code:java}
ALTER TABLE table_name DROP [IF EXISTS] PARTITION (partition_spec) [, PARTITION 
(partition_spec)];
{code}
 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)