[jira] [Created] (FLINK-32819) flink can not parse the param `#` correctly in k8s application mode

Jun Zhang created FLINK-32819: - Summary: flink can not parse the param `#` correctly in k8s application mode Key: FLINK-32819 URL: https://issues.apache.org/jira/browse/FLINK-32819 Project: Flink

[jira] [Created] (FLINK-31459) add UPDATE COLUMN POSITION for flink table store

Jun Zhang created FLINK-31459: - Summary: add UPDATE COLUMN POSITION for flink table store Key: FLINK-31459 URL: https://issues.apache.org/jira/browse/FLINK-31459 Project: Flink Issue Type:

[jira] [Created] (FLINK-31338) support infer parallelism for flink table store

Jun Zhang created FLINK-31338: - Summary: support infer parallelism for flink table store Key: FLINK-31338 URL: https://issues.apache.org/jira/browse/FLINK-31338 Project: Flink Issue Type:

[jira] [Created] (FLINK-31258) can not get kerberos keytab in flink operator

Jun Zhang created FLINK-31258: - Summary: can not get kerberos keytab in flink operator Key: FLINK-31258 URL: https://issues.apache.org/jira/browse/FLINK-31258 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-31224) Add metrics for flink table store

Jun Zhang created FLINK-31224: - Summary: Add metrics for flink table store Key: FLINK-31224 URL: https://issues.apache.org/jira/browse/FLINK-31224 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-31128) Add Create Table As for flink table store

Jun Zhang created FLINK-31128: - Summary: Add Create Table As for flink table store Key: FLINK-31128 URL: https://issues.apache.org/jira/browse/FLINK-31128 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-31028) Provide different compression methods for per level

Jun Zhang created FLINK-31028: - Summary: Provide different compression methods for per level Key: FLINK-31028 URL: https://issues.apache.org/jira/browse/FLINK-31028 Project: Flink Issue Type:

[jira] [Created] (FLINK-31011) upgrade hiverunner version

Jun Zhang created FLINK-31011: - Summary: upgrade hiverunner version Key: FLINK-31011 URL: https://issues.apache.org/jira/browse/FLINK-31011 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-30871) add bloom filter for orc

Jun Zhang created FLINK-30871: - Summary: add bloom filter for orc Key: FLINK-30871 URL: https://issues.apache.org/jira/browse/FLINK-30871 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-30608) support rename table

Jun Zhang created FLINK-30608: - Summary: support rename table Key: FLINK-30608 URL: https://issues.apache.org/jira/browse/FLINK-30608 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-30595) support create table like

Jun Zhang created FLINK-30595: - Summary: support create table like Key: FLINK-30595 URL: https://issues.apache.org/jira/browse/FLINK-30595 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-23955) submit flink sql job error when flink HA on yarn is configured

Jun Zhang created FLINK-23955: - Summary: submit flink sql job error when flink HA on yarn is configured Key: FLINK-23955 URL: https://issues.apache.org/jira/browse/FLINK-23955 Project: Flink

[jira] [Created] (FLINK-22975) Specify port or range for k8s service

Jun Zhang created FLINK-22975: - Summary: Specify port or range for k8s service Key: FLINK-22975 URL: https://issues.apache.org/jira/browse/FLINK-22975 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-22591) add sub interface MapColumnVector for ColumnVector

Jun Zhang created FLINK-22591: - Summary: add sub interface MapColumnVector for ColumnVector Key: FLINK-22591 URL: https://issues.apache.org/jira/browse/FLINK-22591 Project: Flink Issue Type:

[jira] [Created] (FLINK-21286) Support BUCKET for flink sql CREATE TABLE

Jun Zhang created FLINK-21286: - Summary: Support BUCKET for flink sql CREATE TABLE Key: FLINK-21286 URL: https://issues.apache.org/jira/browse/FLINK-21286 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-21285) Support MERGE INTO for flink sql

Jun Zhang created FLINK-21285: - Summary: Support MERGE INTO for flink sql Key: FLINK-21285 URL: https://issues.apache.org/jira/browse/FLINK-21285 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-21283) Support sql extension for flink sql

Jun Zhang created FLINK-21283: - Summary: Support sql extension for flink sql Key: FLINK-21283 URL: https://issues.apache.org/jira/browse/FLINK-21283 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-21282) Support UPDATE for flink sql

Jun Zhang created FLINK-21282: - Summary: Support UPDATE for flink sql Key: FLINK-21282 URL: https://issues.apache.org/jira/browse/FLINK-21282 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-21281) Support DELETE FROM for flink sql

Jun Zhang created FLINK-21281: - Summary: Support DELETE FROM for flink sql Key: FLINK-21281 URL: https://issues.apache.org/jira/browse/FLINK-21281 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-21198) Add show create table command support for flink sql client

Jun Zhang created FLINK-21198: - Summary: Add show create table command support for flink sql client Key: FLINK-21198 URL: https://issues.apache.org/jira/browse/FLINK-21198 Project: Flink Issue

[jira] [Created] (FLINK-21197) DESC command in sql-client should show the column comment

Jun Zhang created FLINK-21197: - Summary: DESC command in sql-client should show the column comment Key: FLINK-21197 URL: https://issues.apache.org/jira/browse/FLINK-21197 Project: Flink Issue

[jira] [Created] (FLINK-20977) can not use `use` command to switch database

Jun Zhang created FLINK-20977: - Summary: can not use `use` command to switch database Key: FLINK-20977 URL: https://issues.apache.org/jira/browse/FLINK-20977 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20809) the limit push down invalid when use filter

Jun Zhang created FLINK-20809: - Summary: the limit push down invalid when use filter Key: FLINK-20809 URL: https://issues.apache.org/jira/browse/FLINK-20809 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20767) add nested field support for SupportsFilterPushDown

Jun Zhang created FLINK-20767: - Summary: add nested field support for SupportsFilterPushDown Key: FLINK-20767 URL: https://issues.apache.org/jira/browse/FLINK-20767 Project: Flink Issue Type:

[jira] [Created] (FLINK-19896) Support first-n-rows deduplication in the Deduplicate operator

Jun Zhang created FLINK-19896: - Summary: Support first-n-rows deduplication in the Deduplicate operator Key: FLINK-19896 URL: https://issues.apache.org/jira/browse/FLINK-19896 Project: Flink

[jira] [Created] (FLINK-19358) when submit job on application mode with HA,the jobid will be 0000000000

Jun Zhang created FLINK-19358: - Summary: when submit job on application mode with HA,the jobid will be 00 Key: FLINK-19358 URL: https://issues.apache.org/jira/browse/FLINK-19358 Project: Flink

[jira] [Created] (FLINK-19254) Invalid UTF-8 start byte exception

Jun Zhang created FLINK-19254: - Summary: Invalid UTF-8 start byte exception Key: FLINK-19254 URL: https://issues.apache.org/jira/browse/FLINK-19254 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-18691) add HiveCatalog Construction method with HiveConf

Jun Zhang created FLINK-18691: - Summary: add HiveCatalog Construction method with HiveConf Key: FLINK-18691 URL: https://issues.apache.org/jira/browse/FLINK-18691 Project: Flink Issue Type:

[jira] [Created] (FLINK-18549) flink 1.11 can not commit partition automatically

Jun Zhang created FLINK-18549: - Summary: flink 1.11 can not commit partition automatically Key: FLINK-18549 URL: https://issues.apache.org/jira/browse/FLINK-18549 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-18479) can not commit partition when set partition time

Jun Zhang created FLINK-18479: - Summary: can not commit partition when set partition time Key: FLINK-18479 URL: https://issues.apache.org/jira/browse/FLINK-18479 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-16818) Optimize data skew when flink write data to hive dynamic partition table

Jun Zhang created FLINK-16818: - Summary: Optimize data skew when flink write data to hive dynamic partition table Key: FLINK-16818 URL: https://issues.apache.org/jira/browse/FLINK-16818 Project: Flink

[jira] [Created] (FLINK-16799) add hive partition limit when read from hive

Jun Zhang created FLINK-16799: - Summary: add hive partition limit when read from hive Key: FLINK-16799 URL: https://issues.apache.org/jira/browse/FLINK-16799 Project: Flink Issue Type:

[jira] [Created] (FLINK-16731) Support show partitions table command in sql client

Jun Zhang created FLINK-16731: - Summary: Support show partitions table command in sql client Key: FLINK-16731 URL: https://issues.apache.org/jira/browse/FLINK-16731 Project: Flink Issue Type:

[jira] [Created] (FLINK-16709) add a set command to set job name when submit job on sql client

Jun Zhang created FLINK-16709: - Summary: add a set command to set job name when submit job on sql client Key: FLINK-16709 URL: https://issues.apache.org/jira/browse/FLINK-16709 Project: Flink

[jira] [Created] (FLINK-16646) flink read orc file throw a NullPointerException

Jun Zhang created FLINK-16646: - Summary: flink read orc file throw a NullPointerException Key: FLINK-16646 URL: https://issues.apache.org/jira/browse/FLINK-16646 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-16623) add the shorthand 'desc' for describe on sql client

Jun Zhang created FLINK-16623: - Summary: add the shorthand 'desc' for describe on sql client Key: FLINK-16623 URL: https://issues.apache.org/jira/browse/FLINK-16623 Project: Flink Issue Type:

[jira] [Created] (FLINK-16539) sql client set param error

Jun Zhang created FLINK-16539: - Summary: sql client set param error Key: FLINK-16539 URL: https://issues.apache.org/jira/browse/FLINK-16539 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-14739) add failOnCastException Configuration to Json FormatDescriptor

Jun Zhang created FLINK-14739: - Summary: add failOnCastException Configuration to Json FormatDescriptor Key: FLINK-14739 URL: https://issues.apache.org/jira/browse/FLINK-14739 Project: Flink

[jira] [Created] (FLINK-10170) Support map types in descriptor-based Table API

Jun Zhang created FLINK-10170: - Summary: Support map types in descriptor-based Table API Key: FLINK-10170 URL: https://issues.apache.org/jira/browse/FLINK-10170 Project: Flink Issue Type:

[jira] [Created] (FLINK-10079) Automatically resolve and register sink table name from external catalogs

Jun Zhang created FLINK-10079: - Summary: Automatically resolve and register sink table name from external catalogs Key: FLINK-10079 URL: https://issues.apache.org/jira/browse/FLINK-10079 Project: Flink

[jira] [Created] (FLINK-10064) Fixed a typo in ExternalCatalogTable

Jun Zhang created FLINK-10064: - Summary: Fixed a typo in ExternalCatalogTable Key: FLINK-10064 URL: https://issues.apache.org/jira/browse/FLINK-10064 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-10061) Fix unsupported configuration in KafkaTableSink

Jun Zhang created FLINK-10061: - Summary: Fix unsupported configuration in KafkaTableSink Key: FLINK-10061 URL: https://issues.apache.org/jira/browse/FLINK-10061 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-9444) KafkaAvroTableSource failed to work for map fields

Jun Zhang created FLINK-9444: Summary: KafkaAvroTableSource failed to work for map fields Key: FLINK-9444 URL: https://issues.apache.org/jira/browse/FLINK-9444 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-9384) KafkaAvroTableSource failed to work due to type mismatch

Jun Zhang created FLINK-9384: Summary: KafkaAvroTableSource failed to work due to type mismatch Key: FLINK-9384 URL: https://issues.apache.org/jira/browse/FLINK-9384 Project: Flink Issue Type: