Commits

Branch selector

 master

User selector

wuchong

Datepicker

All time

Commit History

Commits on Nov 25, 2020

• [FLINK-19795][table-blink] Fix Flink SQL throws exception when changelog source contains duplicate change events

  Show description for 6e1b842
  wuchong

  committed
  6e1b842

  Copy full SHA for 6e1b842

• [hotfix][table-planner-blink] Enable idle state cleanup for ChangelogNormalize operator

  wuchong

  committed
  62657de

  Copy full SHA for 62657de

• [hotfix][docs] Update YARN config docs

  wuchong

  committed
  bd5bc76

  Copy full SHA for bd5bc76

• [FLINK-20306][table-planner-blink] Throw a meaningful exception when accessing temporal table as of constant timestamp

  Show description for c41051f
  wuchong

  authored
  c41051f

  Copy full SHA for c41051f

• [FLINK-20291][table][filesystem] Optimize the exception message of FileSystemTableSink when missing format dependencies

  Show description for 264f2e9
  wuchong

  authored
  264f2e9

  Copy full SHA for 264f2e9

Commits on Nov 24, 2020

• [FLINK-20272][table-runtime-blink] Fix wrong result for TopN when removing records out of TopN

  Show description for 2fd73c1
  wuchong

  committed
  2fd73c1

  Copy full SHA for 2fd73c1

• [FLINK-20271][table-runtime-blink] Fix ArrayIndexOutOfBounds for RetractableTopNFunction

  Show description for ebf5e08
  wuchong

  committed
  ebf5e08

  Copy full SHA for ebf5e08

Commits on Nov 23, 2020

• [FLINK-19878][table-planner-blink] Fix WatermarkAssigner shouldn't be after ChangelogNormalize

  Show description for 75a584c
  wuchong

  committed
  75a584c

  Copy full SHA for 75a584c

• [hotfix][FLINK-20059][table-common] Update Javadoc for "merge" method of TableAggregateFunction

  wuchong

  committed
  d6a1fd0

  Copy full SHA for d6a1fd0

• [FLINK-18452][table-runtime-blink] Fix StateMigrationException because RetractableTopNFunction#ComparatorWrapper might be incompatible

  Show description for 49029a0
  wuchong

  authored
  49029a0

  Copy full SHA for 49029a0

• [FLINK-20150][debezium-avro] Add documentation for the debezium-avro-confluent format

  Show description for 0c962c3
  wuchong

  authored
  0c962c3

  Copy full SHA for 0c962c3

Commits on Nov 20, 2020

• [FLINK-20059][table-common] Update Javadoc for "merge" method of AggregateFunction

  Show description for 3a066d6
  wuchong

  authored
  3a066d6

  Copy full SHA for 3a066d6

• [hotfix][table-blink] Improve state cleanup harness tests for group aggregation

  wuchong

  committed
  df8de4a

  Copy full SHA for df8de4a

Commits on Nov 19, 2020

• [FLINK-20187][table-common] Fix factory discovering is failed when source and sink factories are not implemented in one class

  Show description for b4d885d
  wuchong

  authored
  b4d885d

  Copy full SHA for b4d885d

• [hotfix][csv] Improve CSV format tests and docs

  wuchong

  committed
  8b2d0ac

  Copy full SHA for 8b2d0ac

Commits on Nov 12, 2020

• [hotfix][table-planner-blink] Fix UpdateKindTrait inference of Join operator

  wuchong

  committed
  ae1fda5

  Copy full SHA for ae1fda5

• [FLINK-20074][table-planner-blink] Fix can't generate plan when joining on changelog source without updates

  Show description for 8f43e2a
  wuchong

  committed
  8f43e2a

  Copy full SHA for 8f43e2a

Commits on Nov 8, 2020

• [FLINK-18774][debezium-avro] Improve debezium-avro format implementation

  wuchong

  committed
  bff7da1

  Copy full SHA for bff7da1

Commits on Nov 7, 2020

• [FLINK-14356][table][formats] Refactor and rename "single-value" to "raw" format

  Show description for d230058
  wuchong

  committed
  d230058

  Copy full SHA for d230058

Commits on Nov 5, 2020

• [hotfix][upsert-kafka] Support sink parallelism on upsert-kafka sink

  wuchong

  committed
  f504bf5

  Copy full SHA for f504bf5

• [hotfix][kafka] Disallow primary key on insert-only kafka table

  wuchong

  committed
  37fe824

  Copy full SHA for 37fe824

Commits on Nov 4, 2020

• [FLINK-19948][table-planner-blink] Fix calling NOW() function throws compile exception

  Show description for 6c1b3b6
  wuchong

  authored
  6c1b3b6

  Copy full SHA for 6c1b3b6

Commits on Oct 30, 2020

• [FLINK-19824][table-api] Refactor and merge SupportsComputedColumnPushDown and SupportsWatermarkPushDown interfaces

  Show description for 3bf5786
  wuchong

  authored
  3bf5786

  Copy full SHA for 3bf5786

Commits on Oct 27, 2020

• [FLINK-19694][table-runtime-blink] Support upsert ChangelogMode for ScanTableSource in runtime

  Show description for 436a4c2
  wuchong

  committed
  436a4c2

  Copy full SHA for 436a4c2

• [FLINK-19694][table-planner-blink] Update MetadataHandlers for the new introduced StreamExecUpsertMaterialize node

  Show description for 92a2648
  wuchong

  committed
  92a2648

  Copy full SHA for 92a2648

• [FLINK-19694][table-planner-blink] Support upsert ChangelogMode for ScanTableSource in planner

  Show description for 3c67cce
  wuchong

  committed
  3c67cce

  Copy full SHA for 3c67cce

• [FLINK-19777][table-runtime-blink] Fix NullPointException for WindowOperator.close()

  Show description for 1bdac23
  wuchong

  authored
  1bdac23

  Copy full SHA for 1bdac23

Commits on Oct 22, 2020

• [FLINK-17528][table] Remove ArrayData#get() API and use ElementGetter instead

  Show description for 3b9e20a
  wuchong

  committed
  3b9e20a

  Copy full SHA for 3b9e20a

• [FLINK-17528][table] Remove RowData#get() API and use FieldGetter instead

  Show description for debbdc6
  wuchong

  committed
  debbdc6

  Copy full SHA for debbdc6

• [FLINK-19734][table-planner-blink] Replace 'collection' connector by 'values' connector for temporal join plan tests

  Show description for fc91b08
  wuchong

  authored
  fc91b08

  Copy full SHA for fc91b08

Commits on Oct 21, 2020

• [FLINK-19605][table-runtime-blink] Implement cumulative windowing for window aggregate operator

  Show description for 9423cf1
  wuchong

  authored
  9423cf1

  Copy full SHA for 9423cf1

Commits on Oct 20, 2020

• [FLINK-19695][table-runtime-blink] Fix ClassCastException when writing table with rowtime attribute

  Show description for 16f97fb
  wuchong

  authored
  16f97fb

  Copy full SHA for 16f97fb

Commits on Sep 18, 2020

• [FLINK-19002][canal][json] Support to only read changelogs of specific database and table for canal-json format

  Show description for a3b4c93
  wuchong

  authored
  a3b4c93

  Copy full SHA for a3b4c93

• [FLINK-19246][table-planner] Fix TableSourceITCase.testStreamScanParallelism fails on Azure

  Show description for b930423
  wuchong

  authored
  b930423

  Copy full SHA for b930423

Commits on Aug 18, 2020

• [FLINK-18212][table-planner-blink] Fix Lookup Join failed when there is a UDF equal condition on the column of temporal table

  Show description for a2f0199
  wuchong

  authored
  a2f0199

  Copy full SHA for a2f0199

Pagination

Previous

Next