Commits

Breadcrumbs

History for

on046872c

User selector

All users

Datepicker

All time

Commit History

Commits on May 9, 2024

• [FLINK-32084][checkpoint] Migrate current file merging of channel state snapshot into the unify file merging framework

  fredia

  committed
  4fe66e0

  Copy full SHA for 4fe66e0

Commits on May 8, 2024

• [FLINK-35158][runtime] Error handling in StateFuture's callback

  fredia

  committed
  bb0f442

  Copy full SHA for bb0f442

• [FLINK-35262][state] Bridge between AsyncKeyedStateBackend and AsyncExecutionController

  masteryhx

  committed
  3e68422

  Copy full SHA for 3e68422

Commits on May 7, 2024

• [FLINK-35161][state] Implement StateExecutor for ForStStateBackend

  Show description for ea4112a
  

  ljz2051

  authored and

  Zakelly

  committed
  ea4112a

  Copy full SHA for ea4112a

• [FLINK-25537] [JUnit5 Migration] Migrate the api package of flink-core module to JUnit5

  GOODBOY008

  authored
  ffa3869

  Copy full SHA for ffa3869

• [FLINK-32080][FLIP-306][checkpoint] Restoration of FileMergingSnapshotManager

  Show description for afe4c79
  

  ljz2051

  authored and

  Zakelly

  committed
  afe4c79

  Copy full SHA for afe4c79

• [FLINK-32852][JUnit5 Migration] Migrate the scheduler package of flink-runtime module to JUnit5 (apache#24732)

  RocMarshal

  authored
  ca441b8

  Copy full SHA for ca441b8

Commits on May 6, 2024

• [FLINK-32843][JUnit5 Migration] Migrate the jobmaster package of flink-runtime module to JUnit5

  RocMarshal

  authored
  beb0b16

  Copy full SHA for beb0b16

Commits on Apr 29, 2024

• [FLINK-35223][rest] Add jobType in JobDetailsInfo related rest api

  1996fanrui

  committed
  917352e

  Copy full SHA for 917352e

• [FLINK-35222][rest] Add getJobType for AccessExecutionGraph

  1996fanrui

  committed
  5263f9c

  Copy full SHA for 5263f9c

Commits on Apr 26, 2024

• [FLINK-35026][runtime] Implement buffer timeout of AEC

  fredia

  committed
  3ff2ba4

  Copy full SHA for 3ff2ba4

• [FLINK-35026][runtime][config] Introduce async execution configurations

  fredia

  committed
  713c30f

  Copy full SHA for 713c30f

• [FLINK-35162][state] Attach the keyGroup and payload into RecordContext

  

  ljz2051

  authored and

  masteryhx

  committed
  fb58380

  Copy full SHA for fb58380

• [FLINK-35125][state] Implement ValueState for ForStStateBackend

  

  ljz2051

  authored and

  masteryhx

  committed
  e057010

  Copy full SHA for e057010

Commits on Apr 25, 2024

• [hotfix][runtime] Make sure run RecordContext#release() in Task thread. (apache#24705)

  zoltar9264

  authored
  797cb9c

  Copy full SHA for 797cb9c

Commits on Apr 24, 2024

• [FLINK-35166][runtime] Make the SortBufferAccumulator use more buffers when the parallelism is small

  

  jiangxin369

  authored and

  reswqa

  committed
  712d980

  Copy full SHA for 712d980

Commits on Apr 23, 2024

• [FLINK-34444] Initial implementation of JM operator metric rest api (apache#24564)

  Show description for d453baf
  mas-chen

  authored
  d453baf

  Copy full SHA for d453baf

• [FLINK-35214][runtime] Update result partition id for remote input channel when unknown input channel is updated

  

  TanYuxin-tyx

  authored and

  reswqa

  committed
  ea2eabe

  Copy full SHA for ea2eabe

Commits on Apr 22, 2024

• [FLINK-35028][runtime] Timer firing under async execution model

  fredia

  committed
  0b2e988

  Copy full SHA for 0b2e988

• [FLINK-35169][runtime] Recycle buffers to freeSegments before releasing data buffer for sort accumulator

  

  TanYuxin-tyx

  authored and

  reswqa

  committed
  68a84fd

  Copy full SHA for 68a84fd

• [FLINK-35027][runtime/checkpoint] Implement checkpoint drain in AsyncExecutionController

  fredia

  committed
  9336760

  Copy full SHA for 9336760

Commits on Apr 19, 2024

• [FLINK-35159] Transition ExecutionGraph to RUNNING after slot assignment

  zentol

  committed
  131358b

  Copy full SHA for 131358b

• [hotfix] Delete pointless test

  Show description for 10c84df
  zentol

  committed
  10c84df

  Copy full SHA for 10c84df

Commits on Apr 17, 2024

• [FLINK-34987][state] Implement Async Value State (apache#24651)

  masteryhx

  committed
  2c5078b

  Copy full SHA for 2c5078b

• [FLINK-34987][state] Introduce InternalKeyedState for Async State API

  masteryhx

  committed
  1445ea8

  Copy full SHA for 1445ea8

• [FLINK-34987][state] Introduce new StateDescriptor for Async State API

  masteryhx

  committed
  7699a0d

  Copy full SHA for 7699a0d

• [FLINK-35025][Runtime/State] Introduce element order for async state processing

  

  Zakelly

  authored and

  fredia

  committed
  fe8dde4

  Copy full SHA for fe8dde4

• [FLINK-35025][Runtime/State] Erase the type parameter of record within AEC and related components.

  

  Zakelly

  authored and

  fredia

  committed
  c7be45d

  Copy full SHA for c7be45d

• [FLINK-34936][Checkpointing] Register reused shared state handle to FileMergingSnapshotManager

  

  Zakelly

  authored and

  fredia

  committed
  31ea1a9

  Copy full SHA for 31ea1a9

• [FLINK-35046][state] Introduce AsyncKeyedStateBackend supporting to create StateExecutor (apache#24663)

  masteryhx

  committed
  691cc67

  Copy full SHA for 691cc67

Commits on Apr 16, 2024

• [FLINK-30081][runtime] Reset unused options like jvm-overhead.min/max for local executor

  Show description for 9cc5ab9
  

  liuml07

  authored and

  xintongsong

  committed
  9cc5ab9

  Copy full SHA for 9cc5ab9

• [hotfix][runtime]Fix the missing methed parameter annotation problem

  

  chenyu0513

  authored and

  reswqa

  committed
  9ae9c14

  Copy full SHA for 9ae9c14

Commits on Apr 15, 2024

• [FLINK-32440][checkpoint] Introduce file merging configuration (apache#22973)

  fredia

  authored
  c601c70

  Copy full SHA for c601c70

• [FLINK-35024][Runtime/State] Implement the record buffer of AsyncExecutionController (apache#24633)

  fredia

  authored
  6d139a1

  Copy full SHA for 6d139a1

Commits on Apr 11, 2024

• [FLINK-34986][Runtime/State] More tests for reference counting of ContextStateFutureImpl

  

  Zakelly

  authored and

  fredia

  committed
  ec2a140

  Copy full SHA for ec2a140

Pagination

Previous

Next