Commits

Branch selector

 master

User selector

All users

Datepicker

All time

Commit History

Commits on Jan 19, 2025

• [FLINK-37021][state/forst] Forst remote dir share checkpoint dir (#26006)

  fredia

  authored
  64f686c

  Copy full SHA for 64f686c

• [FLINK-35405][runtime] Add metrics for AsyncExecutionController (#25998)

  fredia

  authored
  704b5c4

  Copy full SHA for 704b5c4

Commits on Jan 18, 2025

• [FLINK-37136][runtime] Implement Window extension for DataStream V2

  

  codenohup

  authored and

  reswqa

  committed
  f2460c8

  Copy full SHA for f2460c8

• [FLINK-37136][API] Introduce Window extension components for DataStream V2

  

  codenohup

  authored and

  reswqa

  committed
  6de1fa2

  Copy full SHA for 6de1fa2

• [FLINK-37164][Runtime] Speed up state v2 synchronous methods execution (#26005)

  Zakelly

  authored
  180d587

  Copy full SHA for 180d587

Commits on Jan 17, 2025

• [FLINK-37084][python] Fix TimerRegistration concurrency issue in PyFlink (#26004)

  suez1224

  authored
  82baf88

  Copy full SHA for 82baf88

• [FLINK-36695][Formats] Bump Parquet dependency to 1.14.4

  Show description for d8cd559
  

  MartijnVisser

  and

  snuyanzin

  authored
  d8cd559

  Copy full SHA for d8cd559

• [hotfix] Fix compile error in EventTimeWatermarkHandlerTest (#26007)

  fredia

  authored
  9b411b3

  Copy full SHA for 9b411b3

• [FLINK-36837][table] Introduce RowTimeDeduplicateFunction with Async State API

  Show description for 26d3426
  xuyangzhong

  authored
  26d3426

  Copy full SHA for 26d3426

• [FLINK-37140][runtime] Create async timer service when restore async operator (#25993)

  fredia

  authored
  33de4ea

  Copy full SHA for 33de4ea

• [FLINK-37001][table] Remove deprecated TableEnvironmentInternal#registerTableSinkInternal method and related tests

  xuyangzhong

  authored
  6b4385e

  Copy full SHA for 6b4385e

• [FLINK-37098] Fix selecting time attribute from a view

  dawidwys

  committed
  6748cd0

  Copy full SHA for 6748cd0

• [FLINK-36927][table] Introduce slicing & one stage Window Aggregate with Async State API

  Show description for 8134e33
  xuyangzhong

  authored
  8134e33

  Copy full SHA for 8134e33

• [FLINK-36293][state] make sure register is closed before verification (#25373)

  showuon

  authored
  4be6d69

  Copy full SHA for 4be6d69

• [FLINK-37112][API] Process event time extension related watermarks in EventTimeProcessFunction for DataStream V2

  

  codenohup

  authored and

  reswqa

  committed
  69e67fa

  Copy full SHA for 69e67fa

• [FLINK-37112][runtime] Process event time extension related watermarks in operator for DataStream V2

  

  codenohup

  authored and

  reswqa

  committed
  e8f2ab2

  Copy full SHA for e8f2ab2

• [FLINK-37112][API] Introduce EventTimeWatermark definition and EventTimeWatermarkGeneratorBuilder for DataStream V2

  

  codenohup

  authored and

  reswqa

  committed
  3b7038c

  Copy full SHA for 3b7038c

• [FLINK-32647][pyflink] Support create catalog in pyflink table environment (#25986)

  xuyangzhong

  authored
  9a4f289

  Copy full SHA for 9a4f289

• [hotfix] Add homepage link to .asf.yaml

  

  tisonkun

  authored and

  xintongsong

  committed
  c4bea91

  Copy full SHA for c4bea91

Commits on Jan 16, 2025

• [FLINK-37076][table-planner] Make table arguments explicit in logical plans

  Show description for 55de8d6
  twalthr

  authored
  55de8d6

  Copy full SHA for 55de8d6

• [FLINK-37092][e2e] Add adaptive skewed join optimization to e2e tpc-ds tests

  Show description for ed6de58
  

  noorall

  authored and

  JunRuiLee

  committed
  ed6de58

  Copy full SHA for ed6de58

• [FLINK-37135][runtime] Implement Join extension for DataStream V2

  Show description for b3e7f9b
  

  codenohup

  authored and

  reswqa

  committed
  b3e7f9b

  Copy full SHA for b3e7f9b

• [FLINK-37135][API] Introduce JoinFunction, JoinType and BuiltinFuncs for Join extension in DataStream V2

  

  codenohup

  authored and

  reswqa

  committed
  3d146af

  Copy full SHA for 3d146af

• [hotfix] Add missing generic type param for the use of PartitionedContext

  

  codenohup

  authored and

  reswqa

  committed
  577d5ca

  Copy full SHA for 577d5ca

• [FLINK-37139][table-planner] Improve AdaptiveSkewedJoinOptimizationStrategy to make it effective in more scenarios (#25989)

  noorall

  authored
  d774cf1

  Copy full SHA for d774cf1

• [FLINK-37090][e2e] add adaptive broadcast join to e2e tpc-ds tests. (#25954)

  SinBex

  authored
  65db14d

  Copy full SHA for 65db14d

• [FLINK-37017][Runtime] Prevent stack overflow when draining in-flight records

  Show description for 9da368d
  Zakelly

  committed
  9da368d

  Copy full SHA for 9da368d

• [FLINK-37017][Runtime] Drain in best efforts when allowing overdraft

  Zakelly

  committed
  fc57f0d

  Copy full SHA for fc57f0d

• [FLINK-37017][Runtime] Allow buffer overdraft in async state processing

  Zakelly

  committed
  e9d9cb2

  Copy full SHA for e9d9cb2

• [FLINK-35412][Runtime] Remove BatchCallbackRunner

  Zakelly

  committed
  e3c2841

  Copy full SHA for e3c2841

• [FLINK-37137][runtime] Fix unstable test testGenerateStreamGraphJson (#25990)

  yuchen-ecnu

  authored
  07ea97c

  Copy full SHA for 07ea97c

• [FLINK-37026] Fix the stale pr message formatting (#25992)

  tomncooper

  authored
  cb20e7d

  Copy full SHA for cb20e7d

Commits on Jan 15, 2025

• [hotfix][javadoc] Use correct syntax for TRIM in SqlCallSyntax javadoc

  snuyanzin

  authored
  0e9739a

  Copy full SHA for 0e9739a

• [FLINK-37130][table] Minor optimization of async state api usage in window join operator

  Zakelly

  committed
  d0165de

  Copy full SHA for d0165de

• [FLINK-37130][State] An util converting future of StateIterator to Iterable

  Zakelly

  committed
  2f2018f

  Copy full SHA for 2f2018f

Pagination

Previous

Next