[jira] [Created] (FLINK-29090) Fix the code gen for ColumnarMapData and ColumnarArrayData

2022-08-23 Thread Danny Chen (Jira)
Danny Chen created FLINK-29090: -- Summary: Fix the code gen for ColumnarMapData and ColumnarArrayData Key: FLINK-29090 URL: https://issues.apache.org/jira/browse/FLINK-29090 Project: Flink Issue

[jira] [Created] (FLINK-22370) ParquetColumnarRowSplitReader#reachedEnd() returns false after it returns true

2021-04-20 Thread Danny Chen (Jira)
Danny Chen created FLINK-22370: -- Summary: ParquetColumnarRowSplitReader#reachedEnd() returns false after it returns true Key: FLINK-22370 URL: https://issues.apache.org/jira/browse/FLINK-22370 Project:

[jira] [Created] (FLINK-20785) MapRelDataType for legacy planner has wrong digest

2020-12-28 Thread Danny Chen (Jira)
Danny Chen created FLINK-20785: -- Summary: MapRelDataType for legacy planner has wrong digest Key: FLINK-20785 URL: https://issues.apache.org/jira/browse/FLINK-20785 Project: Flink Issue Type:

[jira] [Created] (FLINK-20704) Some rel data type does not implement the digest correctly

2020-12-21 Thread Danny Chen (Jira)
Danny Chen created FLINK-20704: -- Summary: Some rel data type does not implement the digest correctly Key: FLINK-20704 URL: https://issues.apache.org/jira/browse/FLINK-20704 Project: Flink Issue

[jira] [Created] (FLINK-20368) Supports custom operator name for Flink SQL

2020-11-26 Thread Danny Chen (Jira)
Danny Chen created FLINK-20368: -- Summary: Supports custom operator name for Flink SQL Key: FLINK-20368 URL: https://issues.apache.org/jira/browse/FLINK-20368 Project: Flink Issue Type:

[jira] [Created] (FLINK-20234) Json format supports SE/DE null elements of ARRAY type field

2020-11-19 Thread Danny Chen (Jira)
Danny Chen created FLINK-20234: -- Summary: Json format supports SE/DE null elements of ARRAY type field Key: FLINK-20234 URL: https://issues.apache.org/jira/browse/FLINK-20234 Project: Flink

[jira] [Created] (FLINK-20142) Update the document for CREATE TABLE LIKE that source table from different catalog is supported

2020-11-13 Thread Danny Chen (Jira)
Danny Chen created FLINK-20142: -- Summary: Update the document for CREATE TABLE LIKE that source table from different catalog is supported Key: FLINK-20142 URL: https://issues.apache.org/jira/browse/FLINK-20142

[jira] [Created] (FLINK-20017) Promote the error message for join two windowed stream with time attributes

2020-11-06 Thread Danny Chen (Jira)
Danny Chen created FLINK-20017: -- Summary: Promote the error message for join two windowed stream with time attributes Key: FLINK-20017 URL: https://issues.apache.org/jira/browse/FLINK-20017 Project:

[jira] [Created] (FLINK-19949) Unescape CSV format line delimiter character

2020-11-03 Thread Danny Chen (Jira)
Danny Chen created FLINK-19949: -- Summary: Unescape CSV format line delimiter character Key: FLINK-19949 URL: https://issues.apache.org/jira/browse/FLINK-19949 Project: Flink Issue Type:

[jira] [Created] (FLINK-19779) Remove the "record_" field name prefix for Confluent Avro format deserialization

2020-10-23 Thread Danny Chen (Jira)
Danny Chen created FLINK-19779: -- Summary: Remove the "record_" field name prefix for Confluent Avro format deserialization Key: FLINK-19779 URL: https://issues.apache.org/jira/browse/FLINK-19779

[jira] [Created] (FLINK-19668) Fix the plan regression by Calcite upgrade to 1.26

2020-10-15 Thread Danny Chen (Jira)
Danny Chen created FLINK-19668: -- Summary: Fix the plan regression by Calcite upgrade to 1.26 Key: FLINK-19668 URL: https://issues.apache.org/jira/browse/FLINK-19668 Project: Flink Issue Type:

[jira] [Created] (FLINK-19567) JoinITCase.testInnerJoinOutputWithPk is unstable for POJO type inference

2020-10-11 Thread Danny Chen (Jira)
Danny Chen created FLINK-19567: -- Summary: JoinITCase.testInnerJoinOutputWithPk is unstable for POJO type inference Key: FLINK-19567 URL: https://issues.apache.org/jira/browse/FLINK-19567 Project: Flink

[jira] [Created] (FLINK-19108) Stop expanding the identifiers with scope aliased by the system with 'EXPR$' prefix

2020-09-01 Thread Danny Chen (Jira)
Danny Chen created FLINK-19108: -- Summary: Stop expanding the identifiers with scope aliased by the system with 'EXPR$' prefix Key: FLINK-19108 URL: https://issues.apache.org/jira/browse/FLINK-19108

[jira] [Created] (FLINK-18777) Supports schema registry catalog

2020-07-30 Thread Danny Chen (Jira)
Danny Chen created FLINK-18777: -- Summary: Supports schema registry catalog Key: FLINK-18777 URL: https://issues.apache.org/jira/browse/FLINK-18777 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-18500) Make the legacy planner exception more clear when resolving computed columns types for schema

2020-07-06 Thread Danny Chen (Jira)
Danny Chen created FLINK-18500: -- Summary: Make the legacy planner exception more clear when resolving computed columns types for schema Key: FLINK-18500 URL: https://issues.apache.org/jira/browse/FLINK-18500

[jira] [Created] (FLINK-18315) Insert into partitioned table can fail with values

2020-06-15 Thread Danny Chen (Jira)
Danny Chen created FLINK-18315: -- Summary: Insert into partitioned table can fail with values Key: FLINK-18315 URL: https://issues.apache.org/jira/browse/FLINK-18315 Project: Flink Issue Type:

[jira] [Created] (FLINK-18029) Add more ITCases for Kafka with new formats

2020-05-29 Thread Danny Chen (Jira)
Danny Chen created FLINK-18029: -- Summary: Add more ITCases for Kafka with new formats Key: FLINK-18029 URL: https://issues.apache.org/jira/browse/FLINK-18029 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-18028) E2E tests manually for Kafka 2 all kinds of other connectors

2020-05-29 Thread Danny Chen (Jira)
Danny Chen created FLINK-18028: -- Summary: E2E tests manually for Kafka 2 all kinds of other connectors Key: FLINK-18028 URL: https://issues.apache.org/jira/browse/FLINK-18028 Project: Flink

[jira] [Created] (FLINK-18026) E2E tests manually for new SQL connectors and formats

2020-05-29 Thread Danny Chen (Jira)
Danny Chen created FLINK-18026: -- Summary: E2E tests manually for new SQL connectors and formats Key: FLINK-18026 URL: https://issues.apache.org/jira/browse/FLINK-18026 Project: Flink Issue

[jira] [Created] (FLINK-18025) E2E tests manually for Hive integrate streaming

2020-05-29 Thread Danny Chen (Jira)
Danny Chen created FLINK-18025: -- Summary: E2E tests manually for Hive integrate streaming Key: FLINK-18025 URL: https://issues.apache.org/jira/browse/FLINK-18025 Project: Flink Issue Type:

[jira] [Created] (FLINK-18024) E2E tests manually for new Hive dependency jars

2020-05-29 Thread Danny Chen (Jira)
Danny Chen created FLINK-18024: -- Summary: E2E tests manually for new Hive dependency jars Key: FLINK-18024 URL: https://issues.apache.org/jira/browse/FLINK-18024 Project: Flink Issue Type:

[jira] [Created] (FLINK-18023) E2E tests manually for new filesystem connector

2020-05-29 Thread Danny Chen (Jira)
Danny Chen created FLINK-18023: -- Summary: E2E tests manually for new filesystem connector Key: FLINK-18023 URL: https://issues.apache.org/jira/browse/FLINK-18023 Project: Flink Issue Type:

[jira] [Created] (FLINK-18022) Add e2e test for new streaming file sink

2020-05-29 Thread Danny Chen (Jira)
Danny Chen created FLINK-18022: -- Summary: Add e2e test for new streaming file sink Key: FLINK-18022 URL: https://issues.apache.org/jira/browse/FLINK-18022 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-18021) Complement tests for 1.11 SQL

2020-05-29 Thread Danny Chen (Jira)
Danny Chen created FLINK-18021: -- Summary: Complement tests for 1.11 SQL Key: FLINK-18021 URL: https://issues.apache.org/jira/browse/FLINK-18021 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-17957) Forbidden syntax "CREATE SYSTEM FUNCTION" for sql parser

2020-05-27 Thread Danny Chen (Jira)
Danny Chen created FLINK-17957: -- Summary: Forbidden syntax "CREATE SYSTEM FUNCTION" for sql parser Key: FLINK-17957 URL: https://issues.apache.org/jira/browse/FLINK-17957 Project: Flink Issue

[jira] [Created] (FLINK-17864) Update document about removing #registerTableSource

2020-05-21 Thread Danny Chen (Jira)
Danny Chen created FLINK-17864: -- Summary: Update document about removing #registerTableSource Key: FLINK-17864 URL: https://issues.apache.org/jira/browse/FLINK-17864 Project: Flink Issue Type:

[jira] [Created] (FLINK-17841) Add document for new ElasticSearch connector

2020-05-20 Thread Danny Chen (Jira)
Danny Chen created FLINK-17841: -- Summary: Add document for new ElasticSearch connector Key: FLINK-17841 URL: https://issues.apache.org/jira/browse/FLINK-17841 Project: Flink Issue Type:

[jira] [Created] (FLINK-17840) Add document for new Kafka connector

2020-05-20 Thread Danny Chen (Jira)
Danny Chen created FLINK-17840: -- Summary: Add document for new Kafka connector Key: FLINK-17840 URL: https://issues.apache.org/jira/browse/FLINK-17840 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17839) Add document for new Hbase connector

2020-05-20 Thread Danny Chen (Jira)
Danny Chen created FLINK-17839: -- Summary: Add document for new Hbase connector Key: FLINK-17839 URL: https://issues.apache.org/jira/browse/FLINK-17839 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17838) Add document for new JDBC connector

2020-05-20 Thread Danny Chen (Jira)
Danny Chen created FLINK-17838: -- Summary: Add document for new JDBC connector Key: FLINK-17838 URL: https://issues.apache.org/jira/browse/FLINK-17838 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17835) Add document for Hive streaming sink

2020-05-20 Thread Danny Chen (Jira)
Danny Chen created FLINK-17835: -- Summary: Add document for Hive streaming sink Key: FLINK-17835 URL: https://issues.apache.org/jira/browse/FLINK-17835 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17836) Add document for Hive dim join

2020-05-20 Thread Danny Chen (Jira)
Danny Chen created FLINK-17836: -- Summary: Add document for Hive dim join Key: FLINK-17836 URL: https://issues.apache.org/jira/browse/FLINK-17836 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17837) Add document for Hive DDL and DML

2020-05-20 Thread Danny Chen (Jira)
Danny Chen created FLINK-17837: -- Summary: Add document for Hive DDL and DML Key: FLINK-17837 URL: https://issues.apache.org/jira/browse/FLINK-17837 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17834) Add document for Hive streaming source

2020-05-20 Thread Danny Chen (Jira)
Danny Chen created FLINK-17834: -- Summary: Add document for Hive streaming source Key: FLINK-17834 URL: https://issues.apache.org/jira/browse/FLINK-17834 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17833) Add document for 1.11 SQL

2020-05-20 Thread Danny Chen (Jira)
Danny Chen created FLINK-17833: -- Summary: Add document for 1.11 SQL Key: FLINK-17833 URL: https://issues.apache.org/jira/browse/FLINK-17833 Project: Flink Issue Type: Task Components:

[jira] [Created] (FLINK-17757) Implement format factory for Avro serialization and deseriazation schema of RowData type

2020-05-16 Thread Danny Chen (Jira)
Danny Chen created FLINK-17757: -- Summary: Implement format factory for Avro serialization and deseriazation schema of RowData type Key: FLINK-17757 URL: https://issues.apache.org/jira/browse/FLINK-17757

[jira] [Created] (FLINK-17717) Throws for DDL create system temporary function with composite table path

2020-05-15 Thread Danny Chen (Jira)
Danny Chen created FLINK-17717: -- Summary: Throws for DDL create system temporary function with composite table path Key: FLINK-17717 URL: https://issues.apache.org/jira/browse/FLINK-17717 Project: Flink

[jira] [Created] (FLINK-17715) Supports create function in SQL-CLI

2020-05-14 Thread Danny Chen (Jira)
Danny Chen created FLINK-17715: -- Summary: Supports create function in SQL-CLI Key: FLINK-17715 URL: https://issues.apache.org/jira/browse/FLINK-17715 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-17631) Supports char type for ConfigOption

2020-05-12 Thread Danny Chen (Jira)
Danny Chen created FLINK-17631: -- Summary: Supports char type for ConfigOption Key: FLINK-17631 URL: https://issues.apache.org/jira/browse/FLINK-17631 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-17604) Implement format factory for CSV serialization and deseriazation schema of RowData type

2020-05-10 Thread Danny Chen (Jira)
Danny Chen created FLINK-17604: -- Summary: Implement format factory for CSV serialization and deseriazation schema of RowData type Key: FLINK-17604 URL: https://issues.apache.org/jira/browse/FLINK-17604

[jira] [Created] (FLINK-17577) SinkFormat#createSinkFormat should use DynamicTableSink.Context as the first parameter

2020-05-08 Thread Danny Chen (Jira)
Danny Chen created FLINK-17577: -- Summary: SinkFormat#createSinkFormat should use DynamicTableSink.Context as the first parameter Key: FLINK-17577 URL: https://issues.apache.org/jira/browse/FLINK-17577

[jira] [Created] (FLINK-17173) Supports query hint to config "IdleStateRetentionTime" per query in SQL

2020-04-15 Thread Danny Chen (Jira)
Danny Chen created FLINK-17173: -- Summary: Supports query hint to config "IdleStateRetentionTime" per query in SQL Key: FLINK-17173 URL: https://issues.apache.org/jira/browse/FLINK-17173 Project: Flink

[jira] [Created] (FLINK-17147) Remove dynamic table options from table source table digest

2020-04-14 Thread Danny Chen (Jira)
Danny Chen created FLINK-17147: -- Summary: Remove dynamic table options from table source table digest Key: FLINK-17147 URL: https://issues.apache.org/jira/browse/FLINK-17147 Project: Flink

[jira] [Created] (FLINK-17103) Supports dynamic table options for Blink planner

2020-04-12 Thread Danny Chen (Jira)
Danny Chen created FLINK-17103: -- Summary: Supports dynamic table options for Blink planner Key: FLINK-17103 URL: https://issues.apache.org/jira/browse/FLINK-17103 Project: Flink Issue Type:

[jira] [Created] (FLINK-17101) Supports dynamic table options for Flink SQL

2020-04-12 Thread Danny Chen (Jira)
Danny Chen created FLINK-17101: -- Summary: Supports dynamic table options for Flink SQL Key: FLINK-17101 URL: https://issues.apache.org/jira/browse/FLINK-17101 Project: Flink Issue Type: New

[jira] [Created] (FLINK-17042) Jackson version conflict for Flink 1.9

2020-04-07 Thread Danny Chen (Jira)
Danny Chen created FLINK-17042: -- Summary: Jackson version conflict for Flink 1.9 Key: FLINK-17042 URL: https://issues.apache.org/jira/browse/FLINK-17042 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-16609) Promotes the column name representation of SQL-CLI

2020-03-15 Thread Danny Chen (Jira)
Danny Chen created FLINK-16609: -- Summary: Promotes the column name representation of SQL-CLI Key: FLINK-16609 URL: https://issues.apache.org/jira/browse/FLINK-16609 Project: Flink Issue Type:

[jira] [Created] (FLINK-15277) Update SQL DDL document to add syntax and example of computed column

2019-12-16 Thread Danny Chen (Jira)
Danny Chen created FLINK-15277: -- Summary: Update SQL DDL document to add syntax and example of computed column Key: FLINK-15277 URL: https://issues.apache.org/jira/browse/FLINK-15277 Project: Flink

[jira] [Created] (FLINK-15210) Move java files in flink-sql-parser module package org.apache.calcite.sql to org.apache.flink.sql.parser.type

2019-12-11 Thread Danny Chen (Jira)
Danny Chen created FLINK-15210: -- Summary: Move java files in flink-sql-parser module package org.apache.calcite.sql to org.apache.flink.sql.parser.type Key: FLINK-15210 URL:

[jira] [Created] (FLINK-15209) DDL with computed column didn't work for some of the connectors

2019-12-11 Thread Danny Chen (Jira)
Danny Chen created FLINK-15209: -- Summary: DDL with computed column didn't work for some of the connectors Key: FLINK-15209 URL: https://issues.apache.org/jira/browse/FLINK-15209 Project: Flink

[jira] [Created] (FLINK-15108) SQL-CLI can not execute same query multiple times

2019-12-06 Thread Danny Chen (Jira)
Danny Chen created FLINK-15108: -- Summary: SQL-CLI can not execute same query multiple times Key: FLINK-15108 URL: https://issues.apache.org/jira/browse/FLINK-15108 Project: Flink Issue Type:

[jira] [Created] (FLINK-15107) SQL-CLI can not execute insert into statement with lowercase "INSERT INTO" keyword

2019-12-06 Thread Danny Chen (Jira)
Danny Chen created FLINK-15107: -- Summary: SQL-CLI can not execute insert into statement with lowercase "INSERT INTO" keyword Key: FLINK-15107 URL: https://issues.apache.org/jira/browse/FLINK-15107

[jira] [Created] (FLINK-15075) Can not run "create table" in IT Case with expressions in TableSchema because the copied ParameterScope can not been seen

2019-12-05 Thread Danny Chen (Jira)
Danny Chen created FLINK-15075: -- Summary: Can not run "create table" in IT Case with expressions in TableSchema because the copied ParameterScope can not been seen Key: FLINK-15075 URL:

[jira] [Created] (FLINK-15027) Support alter table DDLs in SQL CLI

2019-12-02 Thread Danny Chen (Jira)
Danny Chen created FLINK-15027: -- Summary: Support alter table DDLs in SQL CLI Key: FLINK-15027 URL: https://issues.apache.org/jira/browse/FLINK-15027 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-15026) Support database DDLs in SQL CLI

2019-12-02 Thread Danny Chen (Jira)
Danny Chen created FLINK-15026: -- Summary: Support database DDLs in SQL CLI Key: FLINK-15026 URL: https://issues.apache.org/jira/browse/FLINK-15026 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-14844) ConnectorCatalogTable should not patch the row type with TimeAttributes for batch mode

2019-11-18 Thread Danny Chen (Jira)
Danny Chen created FLINK-14844: -- Summary: ConnectorCatalogTable should not patch the row type with TimeAttributes for batch mode Key: FLINK-14844 URL: https://issues.apache.org/jira/browse/FLINK-14844

[jira] [Created] (FLINK-14705) Remove nullables argument of BatchTestBase.registerCollection in blink planner

2019-11-11 Thread Danny Chen (Jira)
Danny Chen created FLINK-14705: -- Summary: Remove nullables argument of BatchTestBase.registerCollection in blink planner Key: FLINK-14705 URL: https://issues.apache.org/jira/browse/FLINK-14705 Project:

[jira] [Created] (FLINK-14698) Refactor the SQL CLI parser to reuse flink-sql-parser

2019-11-10 Thread Danny Chen (Jira)
Danny Chen created FLINK-14698: -- Summary: Refactor the SQL CLI parser to reuse flink-sql-parser Key: FLINK-14698 URL: https://issues.apache.org/jira/browse/FLINK-14698 Project: Flink Issue

[jira] [Created] (FLINK-14670) Refactor out FlinkTable sub-classes in blink planner

2019-11-08 Thread Danny Chen (Jira)
Danny Chen created FLINK-14670: -- Summary: Refactor out FlinkTable sub-classes in blink planner Key: FLINK-14670 URL: https://issues.apache.org/jira/browse/FLINK-14670 Project: Flink Issue Type:

[jira] [Created] (FLINK-14665) Support computed column for create table statement in blink-planner

2019-11-07 Thread Danny Chen (Jira)
Danny Chen created FLINK-14665: -- Summary: Support computed column for create table statement in blink-planner Key: FLINK-14665 URL: https://issues.apache.org/jira/browse/FLINK-14665 Project: Flink

[jira] [Created] (FLINK-14664) Support to reference user defined functions of external catalog in computed columns

2019-11-07 Thread Danny Chen (Jira)
Danny Chen created FLINK-14664: -- Summary: Support to reference user defined functions of external catalog in computed columns Key: FLINK-14664 URL: https://issues.apache.org/jira/browse/FLINK-14664

[jira] [Created] (FLINK-14623) Add computed column information into TableSchema

2019-11-05 Thread Danny Chen (Jira)
Danny Chen created FLINK-14623: -- Summary: Add computed column information into TableSchema Key: FLINK-14623 URL: https://issues.apache.org/jira/browse/FLINK-14623 Project: Flink Issue Type:

[jira] [Created] (FLINK-14609) Add doc for Flink SQL computed columns

2019-11-04 Thread Danny Chen (Jira)
Danny Chen created FLINK-14609: -- Summary: Add doc for Flink SQL computed columns Key: FLINK-14609 URL: https://issues.apache.org/jira/browse/FLINK-14609 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-14386) Support computed column for create table statement

2019-10-13 Thread Danny Chen (Jira)
Danny Chen created FLINK-14386: -- Summary: Support computed column for create table statement Key: FLINK-14386 URL: https://issues.apache.org/jira/browse/FLINK-14386 Project: Flink Issue Type:

[jira] [Created] (FLINK-14338) Upgrade Calcite version to 1.22 for Flink SQL

2019-10-07 Thread Danny Chen (Jira)
Danny Chen created FLINK-14338: -- Summary: Upgrade Calcite version to 1.22 for Flink SQL Key: FLINK-14338 URL: https://issues.apache.org/jira/browse/FLINK-14338 Project: Flink Issue Type: