Commits

Branch selector

 master

User selector

lincoln-lil

Datepicker

All time

Commit History

Commits on Aug 10, 2022

• [FLINK-28849][table-planner] Fix errors when enable retry on async lookup and add more tests

  Show description for c5b5d43
  

  lincoln-lil

  authored and

  godfreyhe

  committed
  c5b5d43

  Copy full SHA for c5b5d43

• [hotfix][runtime] Do last attempt without successfully canceling the retry timer to prevent unexpected incomplete element during finish phase in AsyncWaitOperator

  Show description for 3a2fc5e
  

  lincoln-lil

  authored and

  godfreyhe

  committed
  3a2fc5e

  Copy full SHA for 3a2fc5e

• [hotfix][table-planner] Use scala isInstanceOf to check lookup function type instead of one-level parent class compartion in LookupJoinCodeGenerator

  Show description for fa6d62d
  

  lincoln-lil

  authored and

  godfreyhe

  committed
  fa6d62d

  Copy full SHA for fa6d62d

• [FLINK-28848][table-planner] Introduces LOOKUP join hint to support delayed retry for lookup join (table alias unsupported in hint)

  Show description for 8b25b96
  

  lincoln-lil

  authored and

  godfreyhe

  committed
  8b25b96

  Copy full SHA for 8b25b96

Commits on Aug 9, 2022

• [FLINK-28568][table-runtime] Implements a new lookup join operator (sync mode only) with state to eliminate non-deterministic result

  Show description for 3f18caf
  

  lincoln-lil

  authored and

  godfreyhe

  committed
  3f18caf

  Copy full SHA for 3f18caf

Commits on Aug 6, 2022

• [FLINK-28570][table-planner] Introduces a StreamNonDeterministicPlanResolver to validate and try to solve (lookup join only) the non-deterministic updates problem which may cause wrong result or error

  Show description for fd6c1cc
  

  lincoln-lil

  authored and

  godfreyhe

  committed
  fd6c1cc

  Copy full SHA for fd6c1cc

• [FLINK-28570][table-planner] Optimize upsertKey inference for lookup join and fix ConnectorCatalogTable lost pk on stream source

  Show description for fa3aa8f
  

  lincoln-lil

  authored and

  godfreyhe

  committed
  fa3aa8f

  Copy full SHA for fa3aa8f

• [FLINK-28570][table-planner] Extracts common attributes into StreamPhysicalGroupAggregateBase for all sub-classes

  Show description for a418917
  

  lincoln-lil

  authored and

  godfreyhe

  committed
  a418917

  Copy full SHA for a418917

• [FLINK-28570][table-planner] Introduces a base class StreamPhysicalGroupWindowAggregateBase for all related sub-classes

  Show description for 512e4e0
  

  lincoln-lil

  authored and

  godfreyhe

  committed
  512e4e0

  Copy full SHA for 512e4e0

• [FLINK-28570][table-planner] Append upsertMaterialize info by a simpler way of overriding the explainTerms method for StreamPhysicalSink

  Show description for 5daebae
  

  lincoln-lil

  authored and

  godfreyhe

  committed
  5daebae

  Copy full SHA for 5daebae

• [FLINK-28570][table-planner] Extends FlinkRelOptUtil to support print upsertKey info

  Show description for bca8430
  

  lincoln-lil

  authored and

  godfreyhe

  committed
  bca8430

  Copy full SHA for bca8430

Commits on Jul 19, 2022

• [hotfix][table-runtime] Avoid NPE for SliceAssigner and improve error message

  Show description for 180774e
  

  lincoln-lil

  authored and

  fsk119

  committed
  180774e

  Copy full SHA for 180774e

Commits on Jul 16, 2022

• [FLINK-27878][datastream] Add Retry Support For Async I/O In DataStream API

  Show description for e85cf8c
  

  lincoln-lil

  authored and

  gaoyunhaii

  committed
  e85cf8c

  Copy full SHA for e85cf8c

Commits on Jul 15, 2022

• [FLINK-27623][table] Add 'table.exec.async-lookup.output-mode' to ExecutionConfigOptions

  Show description for c27fd8d
  

  lincoln-lil

  authored and

  godfreyhe

  committed
  c27fd8d

  Copy full SHA for c27fd8d

Commits on Jul 14, 2022

• [FLINK-28536][table-planner] Adds an internal postOptimize method for physical dag processing

  Show description for 2073bd8
  

  lincoln-lil

  authored and

  godfreyhe

  committed
  2073bd8

  Copy full SHA for 2073bd8

Commits on Jun 16, 2022

• [FLINK-28019][table] fix error when retract a staled record if state ttl enabled in RetractableTopNFunction

  Show description for c4d4bb5
  lincoln-lil

  authored
  c4d4bb5

  Copy full SHA for c4d4bb5

Commits on May 17, 2022

• [hotfix][table] Add objectReuse parameter for AsyncLookupJoinITCase. (#19728)

  lincoln-lil

  authored
  d5821eb

  Copy full SHA for d5821eb

Commits on Mar 23, 2022

• [FLINK-26819][table-runtime] Fix wrong results when AppendOnlyFirstNFunction with offset and without rank number (#19212)

  lincoln-lil

  authored
  0a24c95

  Copy full SHA for 0a24c95

Commits on Mar 14, 2022

• [FLINK-26534][table-planner] shuffle by sink's primary key should cover the case that input changelog stream has a different parallelism (#19006)

  lincoln-lil

  authored
  15d2239

  Copy full SHA for 15d2239

Commits on Dec 8, 2021

• [FLINK-20370][table] part2: introduce 'table.exec.sink.keyed-shuffle' option to auto keyby on sink's pk if parallelism are not the same for insertOnly input

  Show description for 9e76585
  lincoln-lil

  authored
  9e76585

  Copy full SHA for 9e76585

Commits on Nov 29, 2021

• [FLINK-20370][table] part1: Fix wrong results when sink primary key is not the same with query result's changelog upsert key

  Show description for f8f6935
  lincoln-lil

  authored
  f8f6935

  Copy full SHA for f8f6935

Commits on Nov 5, 2021

• [FLINK-24704][table-runtime] Fix exception when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

  Show description for 33aaabe
  lincoln-lil

  authored
  33aaabe

  Copy full SHA for 33aaabe

Commits on Oct 28, 2021

• [FLINK-24654][table] Fix NPE on RetractableTopNFunction when some records were cleared by state ttl

  Show description for 2ae9c4d
  lincoln-lil

  authored
  2ae9c4d

  Copy full SHA for 2ae9c4d

Commits on May 13, 2021

• [FLINK-22640] [datagen] Fix DataGen SQL Connector does not support defining fields min/max option of decimal type field

  Show description for e5435bb
  lincoln-lil

  authored
  e5435bb

  Copy full SHA for e5435bb

Commits on May 10, 2021

• [FLINK-22604][table-runtime-blink] Fix NPE on bundle close when task failover after a failed task open

  Show description for 6daa30f
  lincoln-lil

  authored
  6daa30f

  Copy full SHA for 6daa30f

Commits on Apr 18, 2021

• [FLINK-22303][table-planner-blink] FlinkRelMdFilteredColumnInterval should remapping the columnIndex of the inputRel otherwise may cause IllegalArgumentException or get incorrectly metadata

  Show description for 504880c
  

  lincoln-lil

  authored and

  godfreyhe

  committed
  504880c

  Copy full SHA for 504880c

Commits on Mar 26, 2021

• [FLINK-21946][table-planner-blink] FlinkRelMdUtil.numDistinctVals produces exceptional Double.NaN result when domainSize is in range(0,1)

  Show description for 754fd6b
  lincoln-lil

  authored
  754fd6b

  Copy full SHA for 754fd6b

Commits on Mar 24, 2021

• [FLINK-21655][table-planner-blink] Fix incorrect simplification for coalesce call on a groupingsets' result

  Show description for b975fda
  

  lincoln-lil

  authored and

  godfreyhe

  committed
  b975fda

  Copy full SHA for b975fda

Commits on Mar 12, 2021

• [FLINK-21733][table-planner-blink] WatermarkAssigner incorrectly recomputing the rowtime index which may cause ArrayIndexOutOfBoundsException (#15150)

  lincoln-lil

  authored
  c2d9e69

  Copy full SHA for c2d9e69

Commits on Jul 22, 2019

• [FLINK-13284][table-planner-blink] Correct some builtin functions' return type inference in Blink planner

  Show description for 6961d9b
  

  lincoln-lil

  authored and

  wuchong

  committed
  6961d9b

  Copy full SHA for 6961d9b

Commits on May 22, 2018

• [FLINK-8838] [table] Add support for UNNEST on MultiSet fields

  Show description for a273f64
  

  lincoln-lil

  authored and

  twalthr

  committed
  a273f64

  Copy full SHA for a273f64

Commits on Sep 20, 2017

• [FLINK-6442] [table] Add registration for TableSinks and INSERT INTO support for SQL and Table API.

  Show description for 2cb37cb
  

  lincoln-lil

  authored and

  fhueske

  committed
  2cb37cb

  Copy full SHA for 2cb37cb

Commits on Mar 20, 2017

• [FLINK-5883] [core] Re-adding the Exception-thrown code for ListKeyGroupedIterator when the iterator is requested the second time

  Show description for d5f2647
  

  lincoln-lil

  authored and

  StephanEwen

  committed
  d5f2647

  Copy full SHA for d5f2647

Commits on Jan 19, 2017

• [FLINK-5520] [table] Disable outer joins with non-equality predicates.

  Show description for d1301c8
  

  lincoln-lil

  authored and

  fhueske

  committed
  d1301c8

  Copy full SHA for d1301c8