Commits

Commits on Apr 19, 2021

[FLINK-22338][table-planner] Clear watermark output when test finished for FromElementSourceFunctionWithWatermark
fsk119
committedApr 19, 2021
[FLINK-22104][sql-client] Fix unstable SqlClientTest.testExecuteSqlFile

fsk119
authored and
wuchong
committedApr 19, 2021

Commits on Apr 17, 2021

[FLINK-22308][sql-client] Fix CliTableauResultView print results after cancel in STREAMING mode (apache#15644 )
fsk119
committedApr 17, 2021

Commits on Apr 15, 2021

[FLINK-22169][sql-client] Improve CliTableauResultView when printing batch results (apache#15603 )
fsk119
committedApr 15, 2021

Commits on Apr 14, 2021

[FLINK-22245][sql-client] Use PrintUtils.MAX_COLUMN_WIDTH as default max column width in client result views
fsk119
committedApr 14, 2021

Commits on Apr 13, 2021

[FLINK-21748][sql-client] Fix unstable LocalExecutorITCase (apache#15563 )
fsk119
committedApr 13, 2021
[FLINK-22082][table-planner-blink] Nested projection push down doesn't work for composite types, such as row(array(row))

fsk119
authored and
godfreyhe
committedApr 13, 2021

Commits on Apr 8, 2021

[FLINK-22097][sql-client] CliResultView#cleanUp should wait RefreshThread exits
fsk119
committedApr 8, 2021

Commits on Apr 1, 2021

[FLINK-20320][sql-client] Support init sql file in sql client

fsk119
authored and
KurtYoung
committedApr 1, 2021
[FLINK-21191][upsert-kafka] Support buffered sink function for upsert-kafka

fsk119
authored and
wuchong
committedApr 1, 2021

Commits on Mar 30, 2021

[FLINK-12828][sql-client] Support -f option with a sql script as input

fsk119
authored and
KurtYoung
committedMar 30, 2021

Commits on Mar 28, 2021

[FLINK-21669][table-api] Support "table.dml-sync" option to execute statement in sync mode

fsk119
authored and
wuchong
committedMar 28, 2021

Commits on Mar 27, 2021

[FLINK-21463][sql-client] Unify SQL Client parser and TableEnvironment parser

fsk119
authored and
wuchong
committedMar 27, 2021
[FLINK-21463][table-api] Support to parse 'RESET key' command

fsk119
authored and
wuchong
committedMar 27, 2021

Commits on Mar 26, 2021

[FLINK-21974][table] Support to match quoted values for SET option statement

fsk119
authored and
wuchong
committedMar 26, 2021

Commits on Mar 25, 2021

[FLINK-21836][table] Support parsing special commands by introducing ExtendedParser

fsk119
authored and
wuchong
committedMar 25, 2021

Commits on Mar 22, 2021

[FLINK-21887][sql-client] Add SHOW VIEWS test in CliClientITCase (apache#15298 )
fsk119
committedMar 22, 2021

Commits on Mar 21, 2021

[FLINK-21886][table-api] Loosen argument of TableEnvironmentInternal#executeInternal from QueryOperation to Operation (apache#15296 )
fsk119
committedMar 21, 2021

Commits on Mar 18, 2021

[FLINK-21462][sql-client] Use Configuration instead of Environment to store options and values in SQL Client (apache#15197 )
fsk119
committedMar 18, 2021

Commits on Mar 15, 2021

[FLINK-21740][sql-client] Fix unstable CliTableauResultViewTest (apache#15211 )
fsk119
committedMar 15, 2021

Commits on Mar 12, 2021

[FLINK-21485][sql-client] Simplify the ExecutionContext (apache#15006 )
fsk119
committedMar 12, 2021

Commits on Mar 8, 2021

[FLINK-21460][table-api] Support to create TableEnvironment using Configuration
fsk119
committedMar 8, 2021

Commits on Mar 4, 2021

[FLINK-18789][sql-client] Use TableEnvironment#executeSql method to execute insert statement in sql client
fsk119
committedMar 4, 2021

Commits on Feb 25, 2021

[FLINK-18550][sql-client] Use TableResult#collect to get SELECT result for sql client
fsk119
committedFeb 25, 2021

Commits on Jan 22, 2021

[FLINK-20947][planner] Fix idle source doesn't work when pushing watermark into the source
fsk119
committedJan 22, 2021

Commits on Jan 20, 2021

[FLINK-20500][upsert-kafka] Fix unstable temporal join test
fsk119
committedJan 20, 2021

Commits on Dec 27, 2020

[FLINK-19650][jdbc][table] Support limit push down for the JDBC connector
fsk119
committedDec 27, 2020

Commits on Dec 9, 2020

[FLINK-20500][upsert-kafka] Fix unstable UpsertKafkaTableITCase.testTemporalJoin
fsk119
committedDec 9, 2020

Commits on Dec 8, 2020

[FLINK-20372][docs][kafka] Update Kafka SQL connector page to mention 'properties.*' options

fsk119
authored and
wuchong
committedDec 8, 2020

Commits on Dec 7, 2020

[FLINK-20273][table/kafka] Fix the Kafka 'round-robin' partitioner behaviour when message keys are specified
fsk119
committedDec 7, 2020
[FLINK-18897][docs] Add document for maxwell json format

fsk119
authored and
wuchong
committedDec 7, 2020

Commits on Nov 26, 2020

[FLINK-20362][docs] Fix broken link in sourceSinks.zh.md

fsk119
authored and
dianfu
committedNov 26, 2020
[FLINK-20314][table-planner] Add rule to remove empty FlinkLogicalCalc
fsk119
committedNov 26, 2020

Commits on Nov 25, 2020

[FLINK-20317][docs] Update SQL Format overview page (apache#14213 )
fsk119
committedNov 25, 2020
[FLINK-20191][docs] Add documentation for FLIP-95 ability interfaces

fsk119
authored and
twalthr
committedNov 25, 2020