Commits

Commits on Feb 2, 2021

[FLINK-20942][table] Digest of FLOAT literals throws UnsupportedOperationException

danny0405
authored and
twalthr
committedFeb 2, 2021

Commits on Dec 31, 2020

[FLINK-20704][table-planner] Some rel data type does not implement the digest correctly
danny0405
committedDec 31, 2020

Commits on Nov 24, 2020

[FLINK-18988][table] Continuous query with LATERAL and LIMIT produces wrong result

danny0405
authored and
twalthr
committedNov 24, 2020
[FLINK-20307][doc] Strength the document about temporal table join syntax

danny0405
authored and
dawidwys
committedNov 24, 2020
[FLINK-19175][table-planner] Tests in JoinITCase do not test BroadcastHashJoin
danny0405
committedNov 24, 2020

Commits on Nov 19, 2020

[FLINK-19949][csv] Unescape CSV format field delimiter character

danny0405
authored and
wuchong
committedNov 19, 2020

Commits on Nov 18, 2020

[FLINK-20200][table-planner] Fix SQL Hints is not allowed in CREATE VIEW syntax

danny0405
authored and
wuchong
committedNov 18, 2020
[FLINK-18500][table] Make the legacy planner exception more clear when resolving computed columns types for schema
danny0405
committedNov 18, 2020

Commits on Nov 17, 2020

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

danny0405
authored and
dawidwys
committedNov 17, 2020
[FLINK-18500][table] Make the legacy planner exception more clear when resolving computed columns types for schema
danny0405
committedNov 17, 2020

Commits on Oct 29, 2020

[FLINK-19786][avro] Fix the nullability and precision for Avro format deserialization

danny0405
authored and
dawidwys
committedOct 29, 2020
[FLINK-19779][avro] Remove the "record_" field name prefix for Avro format deserialization

danny0405
authored and
dawidwys
committedOct 29, 2020

Commits on Oct 20, 2020

[FLINK-16579][table] Upgrade Calcite version to 1.26 for Flink SQL (apache#13577 )
danny0405
committedOct 20, 2020

Commits on Sep 4, 2020

[FLINK-19108][table] Stop expanding the identifiers with scope aliased by the system with 'EXPR$' prefix
danny0405
committedSep 4, 2020

Commits on Aug 25, 2020

[FLINK-18750][table] SqlValidatorException thrown when select from a view which contains a UDTF call

danny0405
authored and
dawidwys
committedAug 25, 2020

Commits on Jul 30, 2020

[FLINK-16048][avro] Support read/write confluent schema registry avro data from Kafka
danny0405
committedJul 30, 2020

Commits on Jul 14, 2020

[FLINK-18440][table-planner-blink] ROW_NUMBER function: ROW/RANGE not allowed with RANK, DENSE_RANK or ROW_NUMBER functions

danny0405
authored and
wuchong
committedJul 14, 2020

Commits on Jun 22, 2020

[FLINK-18315][table-planner-blink] Fix INSERT INTO partitioned table with VALUES doesn't work correctly

danny0405
authored and
wuchong
committedJun 22, 2020

Commits on Jun 20, 2020

[FLINK-18254][docs][table] Add documentation for primary key syntax

danny0405
authored and
wuchong
committedJun 20, 2020

Commits on Jun 16, 2020

[FLINK-17666][table-planner-blink] Insert into partitioned table can fail with select *
danny0405
committedJun 16, 2020

Commits on Jun 11, 2020

[FLINK-17831][docs] Add documentation for the new Kafka connector

danny0405
authored and
wuchong
committedJun 11, 2020
[FLINK-15849][doc] Update SQL-CLIENT document from type to data-type
danny0405
committedJun 11, 2020
[FLINK-18132][docs] Add documentation for the new CSV format
danny0405
committedJun 11, 2020
[FLINK-17113][sql-cli] Use executeSql to execute view statements and fix nullability loss problem

danny0405
authored and
wuchong
committedJun 11, 2020
[FLINK-18131][docs] Add documentation for the new JSON format
danny0405
committedJun 11, 2020

Commits on Jun 8, 2020

[FLINK-17406][doc] Add documentation about dynamic table options
danny0405
committedJun 8, 2020

Commits on Jun 5, 2020

[FLINK-17717][sql-parser] Throws for DDL create temporary system func with composite identifier
danny0405
committedJun 5, 2020

Commits on May 28, 2020

[FLINK-16021][table-common] Fix DescriptorProperties.putTableSchema does not include PRIMARY KEY
danny0405
committedMay 28, 2020

Commits on May 27, 2020

[FLINK-17756][table] Drop table/view shouldn't take effect on each other
danny0405
committedMay 27, 2020

Commits on May 18, 2020

[FLINK-17715][sql-client] Align function DDL support with TableEnvironment in SQL client
danny0405
committedMay 18, 2020

Commits on May 17, 2020

[FLINK-17757][avro] Implement format factory for Avro serialization and deserialization schema of RowData type

danny0405
authored and
wuchong
committedMay 17, 2020
[FLINK-17026][kafka] Introduce a new Kafka connect or with new property keys

danny0405
authored and
wuchong
committedMay 17, 2020

Commits on May 15, 2020

[FLINK-17629][json] Implement format factory for JSON serialization and deserialization schema
danny0405
committedMay 15, 2020

Commits on May 14, 2020

[FLINK-17604][csv] Implement format factory for CSV serialization and deseriazation schema of RowData type

danny0405
authored and
wuchong
committedMay 14, 2020

Commits on May 12, 2020

[FLINK-17577][table-common] SinkFormat#createSinkFormat should use DynamicTableSink.Context as parameter

danny0405
authored and
wuchong
committedMay 12, 2020