Commits

Branch selector

 master

User selector

StefanRRichter

Datepicker

All time

Commit History

Commits on Sep 10, 2024

• [FLINK-35580] Improve logging for IngestDB to make key range checks more observable.

  StefanRRichter

  committed
  95ef07b

  Copy full SHA for 95ef07b

• [FLINK-35580] Ensure RocksDB working directory is created before opening DB.

  StefanRRichter

  committed
  830a171

  Copy full SHA for 830a171

• [FLINK-35580] Improve logging and problem analysis in RockDBHandle.

  StefanRRichter

  committed
  deeb42e

  Copy full SHA for deeb42e

• [FLINK-35580] Introduce artificial map key for RegisteredStateMetaInfoBase for safe deduplication in RocksDBIncrementalRestoreOperation.

  StefanRRichter

  committed
  9b2b922

  Copy full SHA for 9b2b922

• [FLINK-35580] Register async compact task with the backend's lifecycle instead of the restore lifecycle.

  StefanRRichter

  committed
  a0ace61

  Copy full SHA for a0ace61

• [FLINK-35580] Prevent potential JVM crashes from async compaction when RocksDB is already closed.

  StefanRRichter

  committed
  c116326

  Copy full SHA for c116326

Commits on Aug 26, 2024

• [FLINK-35770][s3] Make s5cmd copyFiles interruptable through CloseableRegistry to improve job cancellation behavior during restore.

  

  StefanRRichter

  authored and

  pnowojski

  committed
  9b67415

  Copy full SHA for 9b67415

Commits on Apr 30, 2024

• [FLINK-35217] Add missing fsync to #closeForCommit in some subclasses of RecoverableFsDataOutputStream. (apache#24722)

  StefanRRichter

  authored
  80af4d5

  Copy full SHA for 80af4d5

Commits on Mar 15, 2024

• [FLINK-34546] Emit span with failure labels on failure in AdaptiveScheduler. (apache#24498)

  StefanRRichter

  authored
  10bff3d

  Copy full SHA for 10bff3d

Commits on Mar 1, 2024

• [FLINK-34546] Emit span with failure labels on failure.

  StefanRRichter

  committed
  7c8e3f5

  Copy full SHA for 7c8e3f5

Commits on Feb 28, 2024

• [hotfix] Reduce code duplication and add logging in RocksDBIncrementalCheckpointUtils#deleteRangeData.

  StefanRRichter

  committed
  e2b6588

  Copy full SHA for e2b6588

• [hotfix] Fix configuration through TernaryBoolean in EmbeddedRocksDBStateBackend.

  StefanRRichter

  committed
  5be8b3e

  Copy full SHA for 5be8b3e

Commits on Feb 20, 2024

• [hotfix] Remove redundant call to remove().

  StefanRRichter

  committed
  049de66

  Copy full SHA for 049de66

Commits on Feb 13, 2024

• [FLINK-34199] Add documentation.

  StefanRRichter

  committed
  6bf9767

  Copy full SHA for 6bf9767

• [FLINK-34199] Add tracing for durations of rescaling/restoring (from local and downloaded remote state).

  StefanRRichter

  committed
  16eae41

  Copy full SHA for 16eae41

• [FLINK-31238] Deactivate parts of the code until new FRocksDB release is available.

  Show description for 268a308
  StefanRRichter

  committed
  268a308

  Copy full SHA for 268a308

• [FLINK-31238] Use IngestDB to speed up Rocksdb rescaling recovery (part 2)

  StefanRRichter

  committed
  5495a96

  Copy full SHA for 5495a96

Commits on Jan 18, 2024

• [FLINK-34134] Add documentation.

  StefanRRichter

  committed
  bdf3132

  Copy full SHA for bdf3132

• [FLINK-34134] Collect and report size/location statistics during task restore.

  StefanRRichter

  committed
  9dc0f6f

  Copy full SHA for 9dc0f6f

• [FLINK-34134] Implement handle-specific size/location reporting methods.

  StefanRRichter

  committed
  8e0e2ca

  Copy full SHA for 8e0e2ca

• [FLINK-34134] Add methods to determine local directory sizes to FileUtils.

  StefanRRichter

  committed
  210ab63

  Copy full SHA for 210ab63

• [FLINK-34134] Introduce size/location statistics reporting to StateObject interface.

  StefanRRichter

  committed
  2224108

  Copy full SHA for 2224108

• [FLINK-34134] Minor cleanup of unused parameters in RocksDB backend.

  StefanRRichter

  committed
  f1e3554

  Copy full SHA for f1e3554

Commits on Oct 27, 2023

• [FLINK-33341][state] Add support for rescaling from local keyed state to PrioritizedOperatorSubtaskState.

  StefanRRichter

  committed
  a4ad86f

  Copy full SHA for a4ad86f

• [FLINK-33341][state] Add support for rescaling from local keyed state to RockDBIncrementalRestoreOperation.

  StefanRRichter

  committed
  05cdb29

  Copy full SHA for 05cdb29

• [FLINK-33341][state] Refactoring: consolidate equals/hashCode/toString for incremental state handle classes.

  StefanRRichter

  committed
  0be2319

  Copy full SHA for 0be2319

• [FLINK-33341][state] Refactoring: introduce common superclass for all IncrementalKeyedStateHandle.

  StefanRRichter

  committed
  2d74ee3

  Copy full SHA for 2d74ee3

• [FLINK-33246][tests] Add AutoRescalingITCase.

  StefanRRichter

  committed
  98e4610

  Copy full SHA for 98e4610

Commits on Aug 1, 2023

• [FLINK-32681] Wait for RocksDBStateDownloader threads on failure to ensure proper cleanup.

  StefanRRichter

  committed
  d11cc32

  Copy full SHA for d11cc32

Commits on Jun 30, 2023

• [FLINK-32410] Replace new LinkedHashMap<>(size) with CollectionUtil.newLinkedHashMapWithExpectedSize(size)

  StefanRRichter

  committed
  1ef9973

  Copy full SHA for 1ef9973

• [FLINK-32410] Replace new LinkedHashSet<>(size) with CollectionUtil.newLinkedHashSetWithExpectedSize(size)

  StefanRRichter

  committed
  4c5bca0

  Copy full SHA for 4c5bca0

• [FLINK-32410] Replace new HashSet<>(size) with CollectionUtil.newHashSetWithExpectedSize(size)

  StefanRRichter

  committed
  4532e41

  Copy full SHA for 4532e41

• [FLINK-32410] Replace new HashMap<>(size) with CollectionUtil.newHashMapWithExpectedSize(size)

  StefanRRichter

  committed
  ab9445a

  Copy full SHA for ab9445a

Commits on Jun 27, 2023

• [FLINK-32441] Fix DefaultSchedulerTest#testTriggerCheckpointAndCompletedAfterStore (apache#22879)

  StefanRRichter

  authored
  0c787f5

  Copy full SHA for 0c787f5

Commits on Jun 26, 2023

• [FLINK-32347][checkpoint] Exceptions from the CompletedCheckpointStore are not registered by the CheckpointFailureManager. (apache#22793)

  Show description for 6022616
  StefanRRichter

  authored
  6022616

  Copy full SHA for 6022616

Pagination

Previous

Next