Commits

Breadcrumbs

History for

onaae96d0

User selector

All users

Datepicker

All time

Commit History

Commits on Aug 9, 2022

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

  

  fredia

  authored and

  rkhachatryan

  committed
  1f9632a

• [FLINK-27155][changelog] Reduce multiple reads to the same Changelog file in the same taskmanager during restore

  

  zoltar9264

  authored and

  rkhachatryan

  committed
  1ec4acd

• [FLINK-28699][state] Make non-incremental rocksdb checkpoint as native format

  Show description for d9a067e
  

  Lihe-Ma

  authored and

  Myasuka

  committed
  d9a067e

Commits on Aug 8, 2022

• [refactor][state] Rename createInternalState to createOrUpdateInternalState

  

  masteryhx

  authored and

  rkhachatryan

  committed
  a267dcf

• [FLINK-23143][state/changelog] Support state migration for ChangelogStateBackend

  

  masteryhx

  authored and

  rkhachatryan

  committed
  94411a1

Commits on Jul 26, 2022

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

  

  fredia

  authored and

  rkhachatryan

  committed
  aef75be

• [FLINK-27692][changelog] Refactor ChangelogSnapshotState

  

  fredia

  authored and

  rkhachatryan

  committed
  52519a8

Commits on Jul 14, 2022

• [FLINK-24786][state] Introduce and expose RocksDB statistics as metrics

  Myasuka

  committed
  46e0014

Commits on Jul 8, 2022

• [FLINK-28172][changelog] Scatter dstl files into separate directories by job id

  

  zoltar9264

  authored and

  rkhachatryan

  committed
  1351303

Commits on Jun 30, 2022

• [FLINK-25872][state] Support restore from non-changelog checkpoint with changelog enabled in CLAIM mode

  

  fredia

  authored and

  rkhachatryan

  committed
  798d83a

Commits on Jun 14, 2022

• [FLINK-27658][runtime] SafetyNetWrapperClassLoader expose addURL method to allow registering jar dynamically

  

  lsyldliu

  authored and

  zhuzhurk

  committed
  2e37a06

Commits on May 20, 2022

• [FLINK-17295][runtime] Refine tests to ensure the consistency of jobVertexId, subtaskIndex, attemptNumber and executionAttemptId

  zhuzhurk

  committed
  014e8e0

Commits on May 17, 2022

• [FLINK-27433][tests] Store RocksDB logs in its database folder for e2e tests

  Myasuka

  authored
  f5aee6e

Commits on May 12, 2022

• [FLINK-25470][changelog] Expose more metrics of ChangelogStateBackend and materialization

  

  masteryhx

  authored and

  rkhachatryan

  committed
  7d2ca7b

Commits on May 3, 2022

• [FLINK-27470][state][tests] Migrate test to JUnit5

  zentol

  authored
  90e98ba

Commits on Apr 28, 2022

• [FLINK-25511][state/changelog] Discard pre-emptively uploaded state changes not included into any checkpoint

  rkhachatryan

  committed
  c5430e2

• [FLINK-25511][state] Introduce StreamStateHandle ID

  Show description for 5b58ef6
  rkhachatryan

  committed
  5b58ef6

Commits on Apr 26, 2022

• [FLINK-24721][build] Remove unnecessary relativePath to parent

  zentol

  committed
  fcab8a8

Commits on Apr 25, 2022

• [FLINK-23252][changelog] Introduce CheckpointBoundKeyedStateHandle#rebound

  

  masteryhx

  authored and

  Myasuka

  committed
  ece745c

• [FLINK-23252][changelog] Support recovery from checkpoint after disabling changelog backend

  

  masteryhx

  authored and

  Myasuka

  committed
  7b48eae

Commits on Apr 12, 2022

• [FLINK-26757][state] Change the default value of state.backend.rocksdb.restore-overlap-fraction-threshold to 0

  

  fredia

  authored and

  Myasuka

  committed
  4034d3c

Commits on Apr 8, 2022

• [FLINK-26852][state] Avoid RocksDBMapState#clear swallowing related exception

  

  masteryhx

  authored and

  Myasuka

  committed
  241e819

Commits on Apr 3, 2022

• [FLINK-26998][state] Activate default log-level options in RocksDB state backend

  Show description for 1ae3d34
  

  Zakelly

  authored and

  Myasuka

  committed
  1ae3d34

Commits on Apr 1, 2022

• [FLINK-23399][state] Add a benchmark for rescaling

  

  fredia

  authored and

  Myasuka

  committed
  562b182

Commits on Mar 29, 2022

• [FLINK-26673][changelog] Disable periodic materialization when periodicMaterializeDelay is negative

  

  masteryhx

  authored and

  rkhachatryan

  committed
  fc98c70

Commits on Mar 21, 2022

• [FLINK-26592][state/changelog] Use mailbox in FsStateChangelogWriter instead of a lock

  Show description for db4d05a
  rkhachatryan

  committed
  db4d05a

• [FLINK-21321][Runtime/StateBackends] Add ITCases for rescaling from checkpoint

  

  fredia

  authored and

  Myasuka

  committed
  1bf45b2

• [FLINK-21321]: change RocksDB rescale to use deleteRange

  Show description for b6822f2
  

  lgo

  authored and

  Myasuka

  committed
  b6822f2

Commits on Mar 18, 2022

• [FLINK-26560][state] Make the threshold of the overlap fraction of incremental restoring configurable

  Show description for 38fe9c0
  

  fredia

  authored and

  Myasuka

  committed
  38fe9c0

Commits on Mar 14, 2022

• Update version to 1.16-SNAPSHOT

  gaoyunhaii

  committed
  5c3bca5

Commits on Mar 10, 2022

• [FLINK-26306][state/changelog] Randomly offset materialization

  rkhachatryan

  committed
  ed5e614

Commits on Mar 7, 2022

• [FLINK-26455][state/changelog] Don't fail on materialization cancellation

  rkhachatryan

  committed
  b68da57

Commits on Feb 17, 2022

• [hotfix][state] Explicitly validate native savepoints support

  rkhachatryan

  committed
  7781188

Commits on Feb 16, 2022

• [FLINK-26079][state/changelog] Disallow recovery from non-changelog checkpoints

  Show description for 6fc4bad
  rkhachatryan

  committed
  6fc4bad

Commits on Feb 12, 2022

• [FLINK-25987][state/changelog] Replace lastSqn with nextSqn()

  Show description for 66048d1
  rkhachatryan

  committed
  66048d1

Pagination

PreviousNext