Commits

Branch selector

 master

User selector

ljz2051

Datepicker

All time

Commit History

Commits on Jun 11, 2024

• [FLINK-32081][test] Add Compatibility IT case for fileMerging

  Show description for f33808c
  

  ljz2051

  authored and

  Zakelly

  committed
  f33808c

  Copy full SHA for f33808c

• [FLINK-32081][checkpoint] Compatibility between file-merging on and off across job runs

  

  ljz2051

  authored and

  Zakelly

  committed
  4500df1

  Copy full SHA for 4500df1

Commits on May 23, 2024

• [FLINK-35047][state] Shutdown StateExecutors when ForStKeyedStateBackend is disposed (apache#24768)

  

  ljz2051

  authored and

  masteryhx

  committed
  d43aeaf

  Copy full SHA for d43aeaf

Commits on May 21, 2024

• [FLINK-35382][test] Disable snapshot-file-merging in ChangelogCompatibilityITCase (apache#24813)

  ljz2051

  authored
  26b149a

  Copy full SHA for 26b149a

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-35161][state] Refactor ForStGeneralMultiGetOperation and ForStWriteBatchOperation

  

  ljz2051

  authored and

  Zakelly

  committed
  88f6d06

  Copy full SHA for 88f6d06

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

  Show description for afe4c79
  

  ljz2051

  authored and

  Zakelly

  committed
  afe4c79

  Copy full SHA for afe4c79

Commits on Apr 26, 2024

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

  

  ljz2051

  authored and

  masteryhx

  committed
  fb58380

  Copy full SHA for fb58380

• [FLINK-35162][state]Support grouping state get and put access

  

  ljz2051

  authored and

  masteryhx

  committed
  1c4eb91

  Copy full SHA for 1c4eb91

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

  

  ljz2051

  authored and

  masteryhx

  committed
  e057010

  Copy full SHA for e057010

Commits on Apr 12, 2024

• [FLINK-35069][API/DataStream]ContinuousProcessingTimeTrigger avoids registering timers at the end of the window

  

  ljz2051

  authored and

  reswqa

  committed
  c0d889f

  Copy full SHA for c0d889f

Commits on Mar 15, 2024

• [FLINK-18255][state] Add API annotations to RocksDB user-facing classes (apache#24496)

  

  ljz2051

  authored and

  masteryhx

  committed
  8fba491

  Copy full SHA for 8fba491

Commits on Mar 14, 2024

• [FLINK-34484][tests] Add UT/IT tests to verify localBackup and localRecovery configs

  

  ljz2051

  authored and

  fredia

  committed
  649e2b4

  Copy full SHA for 649e2b4

• [FLINK-34484][state] Split 'state.backend.local-recovery' into two options for checkpointing and recovery

  

  ljz2051

  authored and

  fredia

  committed
  ed75795

  Copy full SHA for ed75795

• [FLINK-34484][state]Move LOCAL_RECOVERY config from CheckpointingOptions to StateRecoveryOption

  

  ljz2051

  authored and

  fredia

  committed
  1d1dca6

  Copy full SHA for 1d1dca6

Commits on Feb 27, 2024

• [FLINK-34050][state] Introduce parameter protection for DeleteFilesInRange

  

  ljz2051

  authored and

  StefanRRichter

  committed
  b048a9c

  Copy full SHA for b048a9c

• [FLINK-34050][state] Clean up useless files in deleted ranges during restore for RocksdbStateBackend

  

  ljz2051

  authored and

  StefanRRichter

  committed
  534ea31

  Copy full SHA for 534ea31

Commits on Jan 16, 2024

• [FLINK-34078][state]Move InternalKeyContext classes from o.a.f.runtime.state.heap to o.a.f.runtime.state package

  

  ljz2051

  authored and

  masteryhx

  committed
  6bdb4f7

  Copy full SHA for 6bdb4f7

Commits on Jan 11, 2024

• [FLINK-33881][state] Avoid copy and update value in TtlListState#getUnexpiredOrNull

  

  ljz2051

  authored and

  masteryhx

  committed
  907d0f3

  Copy full SHA for 907d0f3

Commits on Sep 15, 2023

• [FLINK-32953][docs]Add notes about changing state ttl value

  

  ljz2051

  authored and

  masteryhx

  committed
  9a891f1

  Copy full SHA for 9a891f1

Commits on Sep 13, 2023

• [FLINK-14032][state] Make the cache size of RocksDBPriorityQueueSetFactory configurable

  

  ljz2051

  authored and

  masteryhx

  committed
  3671960

  Copy full SHA for 3671960

Commits on Sep 8, 2023

• [FLINK-33055][doc]Correct the error value about 'state.backend.type' in the document (apache#23378)

  ljz2051

  authored
  53ccb93

  Copy full SHA for 53ccb93

Commits on Dec 22, 2022

• [FLINK-28863][state]Add comments about why snapshot result of RocksDB native savepoint doesn't have empty shared-state

  

  ljz2051

  authored and

  Myasuka

  committed
  287929c

  Copy full SHA for 287929c

Commits on Jan 20, 2022

• [FLINK-24210][runtime] Return the correct serialized length for window-related serializer

  Show description for 573d2b0
  

  ljz2051

  authored and

  Myasuka

  committed
  573d2b0

  Copy full SHA for 573d2b0

Commits on Dec 24, 2021

• [FLINK-25094][test] Correct the LatencyTrackingMapStateTest#verifyIterator

  Show description for d08a1d0
  

  ljz2051

  authored and

  Myasuka

  committed
  d08a1d0

  Copy full SHA for d08a1d0

Commits on Oct 29, 2021

• [FLINK-24678][runtime/metrics] Correct the metric name of map state contains latency

  

  ljz2051

  authored and

  Myasuka

  committed
  b1a409e

  Copy full SHA for b1a409e