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
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:
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:
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
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:
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
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
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:
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:
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
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:
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
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
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
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
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:
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
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
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
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:
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:
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:
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
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
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
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:
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:
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
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
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
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
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
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
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
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:
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
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
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
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
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
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
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
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
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:
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
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
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:
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
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:
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
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:
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
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:
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
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
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
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:
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
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:
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
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
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:
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
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:
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:
65 matches
Mail list logo