Commits

Branch selector

 master

User selector

fredia

Datepicker

All time

Commit History

Commits on May 17, 2024

• [FLINK-35030][runtime] Introduce Epoch Manager for under async execution (#24748)

  fredia

  authored
  f1ecb9e

  Copy full SHA for f1ecb9e

Commits on May 16, 2024

• [FLINK-32082][docs] Documentation of checkpoint file-merging (#24766)

  fredia

  authored
  a8cf2ba

  Copy full SHA for a8cf2ba

• [FLINK-32092][tests] Integrate snapshot file-merging with existing IT cases (#24789)

  fredia

  authored
  b87ead7

  Copy full SHA for b87ead7

Commits on May 14, 2024

• [FLINK-32087][checkpoint] Introduce space amplification statistics of file merging (#24762)

  fredia

  authored
  9a5a99b

  Copy full SHA for 9a5a99b

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

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

Commits on Apr 22, 2024

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

  fredia

  committed
  0b2e988

  Copy full SHA for 0b2e988

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

  fredia

  committed
  9336760

  Copy full SHA for 9336760

Commits on Apr 15, 2024

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

  fredia

  authored
  c601c70

  Copy full SHA for c601c70

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

  fredia

  authored
  6d139a1

  Copy full SHA for 6d139a1

Commits on Apr 11, 2024

• [FLINK-34986][Runtime/State] Introduce element-control component

  fredia

  committed
  60c771b

  Copy full SHA for 60c771b

Commits on Apr 10, 2024

• [FLINK-28440][State/changelog] Increase the materialization Interval of ChangelogRecoveryITCase#testMaterialization

  fredia

  committed
  10522ff

  Copy full SHA for 10522ff

Commits on Mar 26, 2024

• [FLINK-34668][checkpoint] Report operator state handle of file merging directory to JM

  fredia

  committed
  05b27be

  Copy full SHA for 05b27be

Commits on Mar 20, 2024

• [FLINK-34667][state/changelog] Changelog state backend support local rescaling

  fredia

  committed
  501de48

  Copy full SHA for 501de48

Commits on Mar 12, 2024

• [FLINK-34624][state/changelog] Enable local recovery in ChangelogRescalingITCase (#24470)

  fredia

  authored
  94b55d1

  Copy full SHA for 94b55d1

Commits on Mar 8, 2024

• [FLINK-34483][docs] Improve the documentation of 'state.checkpoints.dir' and 'state.checkpoint-storage' (#24401)

  fredia

  authored
  1d8cbe9

  Copy full SHA for 1d8cbe9

Commits on Feb 21, 2024

• [FLINK-32443][docs-zh] Translate "State Processor API" page into Chinese (#23496)

  fredia

  authored
  2681709

  Copy full SHA for 2681709

Commits on Sep 19, 2023

• [FLINK-32072][checkpoint] Create and wire FileMergingSnapshotManager with TaskManagerServices (#22890)

  fredia

  authored
  1112582

  Copy full SHA for 1112582

Commits on Aug 29, 2023

• [FLINK-30863][state/changelog] Register local recovery files of changelog before notifyCheckpointComplete()

  Show description for c23a300
  fredia

  authored
  c23a300

  Copy full SHA for c23a300

Commits on May 12, 2023

• [FLINK-31876][QS] Migrate flink-queryable-state-runtime tests to JUnit5

  

  fredia

  authored and

  reswqa

  committed
  7f4e834

  Copy full SHA for 7f4e834

Commits on Apr 27, 2023

• [FLINK-31876][QS] Migrate flink-queryable-state-client tests to JUnit5

  Show description for 8be25d1
  fredia

  authored
  8be25d1

  Copy full SHA for 8be25d1

Commits on Apr 24, 2023

• [FLINK-30729][state/changelog] Refactor checkState() to WARN of StateChangelogWriter to avoid confusing IllegalException

  

  fredia

  authored and

  curcur

  committed
  4ca3604

  Copy full SHA for 4ca3604

Commits on Jan 28, 2023

• [FLINK-24932][state] Bump frocksdbjni to 6.20.3-ververica-2.0

  

  fredia

  authored and

  Myasuka

  committed
  e1c11ad

  Copy full SHA for e1c11ad

Commits on Dec 16, 2022

• [FLINK-23035][state/changelog] Add explicit append() to StateChangelogWriter to write metadata

  

  fredia

  authored and

  curcur

  committed
  6b357b4

  Copy full SHA for 6b357b4

Commits on Oct 26, 2022

• [FLINK-29157][docs] Clarify the contract between CompletedCheckpointStore and SharedStateRegistry

  

  fredia

  authored and

  klion26

  committed
  63767c5

  Copy full SHA for 63767c5

Commits on Sep 14, 2022

• [FLINK-29102] Fix unstable ChangelogLocalRecoveryITCase

  Show description for 545ce28
  

  fredia

  authored and

  HuangXingBo

  committed
  545ce28

  Copy full SHA for 545ce28

Commits on Aug 12, 2022

• [FLINK-28626][tests] Fix unstable RescaleCheckpointManuallyITCase when unaligned checkpoint is enabled

  

  fredia

  authored and

  Myasuka

  committed
  7cf7158

  Copy full SHA for 7cf7158

Commits on Aug 9, 2022

• [refactor][state/changelog] Rename ChangelogPeriodicMaterialization* to ChangelogRecovery*

  

  fredia

  authored and

  rkhachatryan

  committed
  c5a8b0f

  Copy full SHA for c5a8b0f

• [FLINK-28529][state/changelog] Fix unstable ChangelogPeriodicMaterializationSwitchStateBackendITCase#testSwitchFromDisablingToEnablingInClaimMode

  

  fredia

  authored and

  rkhachatryan

  committed
  6b725d1

  Copy full SHA for 6b725d1

• [FLINK-27693][docs] Remove local recovery from the Limitations of changelog

  

  fredia

  authored and

  rkhachatryan

  committed
  52eb7e7

  Copy full SHA for 52eb7e7

• [FLINK-27693][changelog] Support local recovery for non-materialized part

  

  fredia

  authored and

  rkhachatryan

  committed
  1f9632a

  Copy full SHA for 1f9632a

Commits on Jul 26, 2022

• [FLINK-27692][changelog] Support local recovery for materialized part

  

  fredia

  authored and

  rkhachatryan

  committed
  aef75be

  Copy full SHA for aef75be

• [FLINK-27692][changelog] Refactor ChangelogSnapshotState

  

  fredia

  authored and

  rkhachatryan

  committed
  52519a8

  Copy full SHA for 52519a8

Pagination

Previous

Next