Commits

Branch selector

 master

User selector

wuchong

Datepicker

All time

Commit History

Commits on Mar 23, 2021

• [FLINK-21899][table] Introduce SOURCE_WATERMARK built-in function to preserve watermark from source (apache#15326)

  wuchong

  authored
  85abe70

  Copy full SHA for 85abe70

Commits on Mar 22, 2021

• [FLINK-21894][hive] Update type of HiveTablePartition#partitionSpec from Map<String, Object> to Map<String, String>

  Show description for c0cf91c
  wuchong

  authored
  c0cf91c

  Copy full SHA for c0cf91c

Commits on Mar 20, 2021

• [FLINK-21466][sql-client] Add unit tests for SqlClient

  Show description for baa2723
  wuchong

  committed
  baa2723

  Copy full SHA for baa2723

Commits on Mar 10, 2021

• [FLINK-21614][sql-client] Migrate tests to CliClientITCase and fix bugs

  Show description for c4b042f
  wuchong

  committed
  c4b042f

  Copy full SHA for c4b042f

• [FLINK-21614][sql-client] Introduce a new integration test framework for SQL Client

  Show description for d51f7d8
  wuchong

  committed
  d51f7d8

  Copy full SHA for d51f7d8

Commits on Mar 3, 2021

• Revert "[FLINK-21178][Runtime/Checkpointing] Task failure should trigger master hook's reset() (apache#14890)"

  Show description for 9588c5d
  wuchong

  committed
  9588c5d

  Copy full SHA for 9588c5d

Commits on Feb 24, 2021

• [hotfix][table-planner-blink] Fix the failed FileSystemTableSinkTest

  wuchong

  committed
  e2fe4fb

  Copy full SHA for e2fe4fb

Commits on Feb 23, 2021

• [FLINK-19608][table-planner-blink] Introduce TVF based window aggregate exec node

  Show description for 0235933
  wuchong

  committed
  0235933

  Copy full SHA for 0235933

• [FLINK-19608][table-planner-blink] Support translating into TVF based window aggreagte physical node

  Show description for d9e5649
  wuchong

  committed
  d9e5649

  Copy full SHA for d9e5649

• [FLINK-19608][table-planner-blink] Introduce SqlOperator definitions for TUMBLE, HOP, CUMULATE table-valued function

  Show description for 15260f9
  wuchong

  committed
  15260f9

  Copy full SHA for 15260f9

• [hotfix][table-planner-blink] Rename WindowAggregateTest to GroupWindowTest

  Show description for d306f17
  wuchong

  committed
  d306f17

  Copy full SHA for d306f17

• [hotfix][table-planner-blink] Merge tests of MiniBatchGroupWindowITCase into GroupWindowITCase

  Show description for e3d4056
  wuchong

  committed
  e3d4056

  Copy full SHA for e3d4056

Commits on Feb 4, 2021

• [FLINK-21261][table-planner-blink] Improve digest of physical Expand node

  Show description for 96e77d6
  wuchong

  authored
  96e77d6

  Copy full SHA for 96e77d6

Commits on Jan 25, 2021

• [FLINK-21054][table-runtime-blink] Implement mini-batch optimized slicing window aggregate operator

  Show description for c4bfa9f
  wuchong

  committed
  c4bfa9f

  Copy full SHA for c4bfa9f

• [hotfix][table-runtime-blink] Rename StateTtlConfigUtil to StateConfigUtil

  wuchong

  committed
  f3db422

  Copy full SHA for f3db422

• [hotfix][table-runtime-blink] Make MemoryManager not null in LazyMemorySegmentPool

  wuchong

  committed
  d16393f

  Copy full SHA for d16393f

• [hotfix][streaming][test] Allow AbstractStreamOperatorTestHarness to use managed memory for operator use case

  wuchong

  committed
  88dc2fc

  Copy full SHA for 88dc2fc

• [hotfix][runtime] Fix the missing arguments in error message in MemoryManager and FsCheckpointStorageAccess

  wuchong

  committed
  33c14a1

  Copy full SHA for 33c14a1

Commits on Jan 8, 2021

• [FLINK-20832][docs] Deliver bootstrap css and js ourselves

  Show description for af36844
  wuchong

  authored
  af36844

  Copy full SHA for af36844

• [FLINK-20877][table-runtime-blink] Refactor BytesHashMap and BytesMultiMap to support window key

  Show description for e79dd4e
  wuchong

  committed
  e79dd4e

  Copy full SHA for e79dd4e

• [FLINK-20877][table-runtime-blink] Move BytesMap classes to util package

  Show description for 14b4dc8
  wuchong

  committed
  14b4dc8

  Copy full SHA for 14b4dc8

Commits on Jan 6, 2021

• [FLINK-20854][table-runtime-blink] Introduce BytesMultiMap to support buffering records

  Show description for facd51f
  wuchong

  authored
  facd51f

  Copy full SHA for facd51f

Commits on Dec 24, 2020

• [hotfix][docs] Fix the broken link in Kafka SQL connector page

  wuchong

  committed
  fd8180a

  Copy full SHA for fd8180a

Commits on Dec 16, 2020

• [FLINK-20325][build] Move docs_404_check to CI stage

  Show description for 806af45
  

  wuchong

  authored and

  rmetzger

  committed
  806af45

  Copy full SHA for 806af45

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

Pagination

Previous

Next