Commits

Commits on Jul 1, 2021

[FLINK-23142][table] UpdatableTopNFunction output wrong order in the same unique key
JingsongLi
committedJul 1, 2021

Commits on Jun 29, 2021

Commits on Jun 21, 2021

[FLINK-22901][table] Introduce getUpsertKeys in FlinkRelMetadataQuery
JingsongLi
committedJun 21, 2021

Commits on Jun 17, 2021

[FLINK-22899][table] ValuesUpsertSinkFunction needs to use global upsert
JingsongLi
committedJun 17, 2021

Commits on Jun 15, 2021

[FLINK-22957][table-runtime] Rank TTL should use enableTimeToLive of state instead of timer
JingsongLi
committedJun 15, 2021

Commits on May 18, 2021

[FLINK-12295][table] Fix comments in MinAggFunction and MaxAggFunction
JingsongLi
committedMay 18, 2021

Commits on Apr 26, 2021

Commits on Apr 22, 2021

[FLINK-22168][table] Partition insert can not work with union all
JingsongLi
committedApr 22, 2021

Commits on Apr 14, 2021

[FLINK-22167][table-planner] Partial insert not works when complex fields reorder
JingsongLi
committedApr 14, 2021
[FLINK-21032][table] Not use ParallelFiniteTestSource in CompactionITCaseBase
JingsongLi
committedApr 14, 2021
[FLINK-17371][table-runtime] Add cases for decimal casting
JingsongLi
committedApr 14, 2021

Commits on Apr 13, 2021

[FLINK-17803][table] Should throw a readable exception when group by Map type
JingsongLi
committedApr 13, 2021
[FLINK-22202][parquet] Thread safety in ParquetColumnarRowInputFormat
JingsongLi
committedApr 13, 2021
[FLINK-22166][table] Empty values with sort willl fail
JingsongLi
committedApr 13, 2021

Commits on Apr 12, 2021

Commits on Mar 19, 2021

Commits on Dec 24, 2020

[FLINK-20745][table] Clean useless codes: Never push calcProgram to correlate
JingsongLi
committedDec 24, 2020

Commits on Dec 22, 2020

[FLINK-20703][table] HiveSinkCompactionITCase test timeout
JingsongLi
committedDec 22, 2020
[FLINK-20213][fs-connector] Partition commit is delayed when records keep coming
JingsongLi
committedDec 22, 2020

Commits on Dec 2, 2020

[FLINK-20315][doc] Optimize the compaction document to warn users about backpressure
JingsongLi
committedDec 2, 2020

Commits on Nov 25, 2020

Commits on Nov 24, 2020

[FLINK-20235][hive][parquet] Parquet lack additional dependencies after bumping
JingsongLi
committedNov 24, 2020

Commits on Nov 18, 2020

[FLINK-20028][table-planner-blink] FileCompactionITCase is unstable
JingsongLi
committedNov 18, 2020

Commits on Nov 11, 2020

[FLINK-20053][table][doc] Add document for file compaction
JingsongLi
committedNov 11, 2020