Commits

Branch selector

 master

User selector

lincoln-lil

Datepicker

All time

Commit History

Commits on Nov 14, 2022

• [FLINK-29781][table-planner] Fix ChangelogNormalize uses wrong keys after transformation by WatermarkAssignerChangelogNormalizeTransposeRule

  Show description for 5463f24
  

  lincoln-lil

  authored and

  godfreyhe

  committed
  5463f24

  Copy full SHA for 5463f24

• [hotfix][docs][table] Minor improvements for versioned table example

  Show description for 7ceca18
  lincoln-lil

  authored
  7ceca18

  Copy full SHA for 7ceca18

Commits on Oct 8, 2022

• [FLINK-29406][table] Expose finish method for TableFunction

  Show description for 1f2001c
  lincoln-lil

  authored
  1f2001c

  Copy full SHA for 1f2001c

Commits on Sep 26, 2022

• [FLINK-29349][table-runtime] Use state ttl instead of timer to clean up state in proctime unbounded over aggregate

  Show description for 0f8909c
  lincoln-lil

  authored
  0f8909c

  Copy full SHA for 0f8909c

Commits on Sep 19, 2022

• [FLINK-28738][table-planner] Adds a user doc about the determinism in streaming

  Show description for a02b2c2
  

  lincoln-lil

  authored and

  godfreyhe

  committed
  a02b2c2

  Copy full SHA for a02b2c2

Commits on Sep 15, 2022

• [FLINK-28569][table-planner] Fix SinkUpsertMaterializer that should be aware of the input upsertKey if it is not empty to prevent wrong results

  Show description for bff1fc2
  

  lincoln-lil

  authored and

  godfreyhe

  committed
  bff1fc2

  Copy full SHA for bff1fc2

• [FLINK-28569][table-planner] Move non-deterministic test functions to userDefinedScalarFunctions

  Show description for 7df115c
  

  lincoln-lil

  authored and

  godfreyhe

  committed
  7df115c

  Copy full SHA for 7df115c

• [FLINK-28569][table-planner] Add projectRowType to RowTypeUtils and deprecate AggCodeGenHelper#projectRowType

  Show description for dbcd2d7
  

  lincoln-lil

  authored and

  godfreyhe

  committed
  dbcd2d7

  Copy full SHA for dbcd2d7

Commits on Sep 9, 2022

• [FLINK-28787][table-planner] Rename getUniqueKeys to getUpsertKeys in CommonPhysicalJoin

  Show description for 347316e
  

  lincoln-lil

  authored and

  godfreyhe

  committed
  347316e

  Copy full SHA for 347316e

• [hotfix][tests][table-planner] Add two more cases to verify the conflict of multiple LOOKUP hints

  Show description for 264eff6
  

  lincoln-lil

  authored and

  godfreyhe

  committed
  264eff6

  Copy full SHA for 264eff6

Commits on Sep 4, 2022

• [FLINK-29091][table-planner] Fix the determinism declaration of the rand function to be consistent with the current behavior

  Show description for 4b15bc9
  

  lincoln-lil

  authored and

  godfreyhe

  committed
  4b15bc9

  Copy full SHA for 4b15bc9

Commits on Sep 2, 2022

• [FLINK-29112][table-planner] Print the lookup join hint on the node in the original RelNode tree for easier debugging

  Show description for 6987224
  

  lincoln-lil

  authored and

  godfreyhe

  committed
  6987224

  Copy full SHA for 6987224

• [FLINK-28971][docs] Adds user documentation for the new LOOKUP hint

  Show description for bbe9690
  

  lincoln-lil

  authored and

  godfreyhe

  committed
  bbe9690

  Copy full SHA for bbe9690

Commits on Sep 1, 2022

• [FLINK-29138][table-planner] fix project can not be pushed into lookup source

  Show description for 2e2fb24
  lincoln-lil

  authored
  2e2fb24

  Copy full SHA for 2e2fb24

Commits on Aug 30, 2022

• [FLINK-29038][runtime] Fix unstable case AsyncWaitOperatorTest#testProcessingTimeRepeatedCompleteOrderedWithRetry

  Show description for a1d74c1
  

  lincoln-lil

  authored and

  HuangXingBo

  committed
  a1d74c1

  Copy full SHA for a1d74c1

Commits on Aug 19, 2022

• [FLINK-28987][table-planner] Refine description of lookup join transformation with async params and retry strategy for easier debugging

  Show description for ef97c65
  

  lincoln-lil

  authored and

  godfreyhe

  committed
  ef97c65

  Copy full SHA for ef97c65

• [FLINK-28987][table-planner] Fix incorrect async to sync lookup fallback path of LegacyTableSourceTable

  Show description for d402fe2
  

  lincoln-lil

  authored and

  godfreyhe

  committed
  d402fe2

  Copy full SHA for d402fe2

Commits on Aug 16, 2022

• [FLINK-28899][table-planner] Fix LOOKUP hint with retry option on async lookup mode

  Show description for cd173e7
  

  lincoln-lil

  authored and

  godfreyhe

  committed
  cd173e7

  Copy full SHA for cd173e7

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. (apache#19728)

  lincoln-lil

  authored
  d5821eb

  Copy full SHA for d5821eb

Pagination

Previous

Next