Commits

Branch selector

 master

User selector

rkhachatryan

Datepicker

All time

Commit History

Commits on Nov 8, 2022

• [FLINK-29095][state] Improve logging in SharedStateRegistry

  

  rkhachatryan

  authored and

  klion26

  committed
  9a4250d

  Copy full SHA for 9a4250d

Commits on Aug 26, 2022

• [FLINK-28976][state] Don't add extra delay to the 1st materialization

  rkhachatryan

  committed
  91e1291

  Copy full SHA for 91e1291

• [hotfix][state] Fix logging in Materializer and make FLINK-28976 more explicit

  rkhachatryan

  committed
  0e083c1

  Copy full SHA for 0e083c1

• [hotfix][tests] Use negative changelog materialization interval in tests

  Show description for aaa3560
  rkhachatryan

  committed
  aaa3560

  Copy full SHA for aaa3560

• [hotfix][state] Extract PeriodicMaterializationManager into state-backend-common

  Show description for a38b852
  rkhachatryan

  committed
  a38b852

  Copy full SHA for a38b852

Commits on Aug 5, 2022

• Revert "[FLINK-25745] Do not log exception if CompletedCheckpointStorageLocation#disposeStorageLocation failed in CLAIM mode"

  Show description for 17a782c
  rkhachatryan

  committed
  17a782c

  Copy full SHA for 17a782c

• [hotfix][docs] Remove limitation about CLAIM mode and RocksDB native savepoints

  rkhachatryan

  committed
  9e6d552

  Copy full SHA for 9e6d552

Commits on Aug 3, 2022

• [FLINK-28597][state] Discard initial checkpoints without a delay in common cases

  rkhachatryan

  committed
  d8a4304

  Copy full SHA for d8a4304

Commits on Jul 8, 2022

• [FLINK-27556][state] Inline state handle id generation

  Show description for 231e96b
  rkhachatryan

  committed
  231e96b

  Copy full SHA for 231e96b

Commits on May 26, 2022

• [hotfix][tests] Raise logging level in TestJobExecutor

  rkhachatryan

  committed
  0b139a1

  Copy full SHA for 0b139a1

• [FLINK-27169][tests] Set timeout for operator lifecycle tests

  rkhachatryan

  committed
  9bf10eb

  Copy full SHA for 9bf10eb

• [FLINK-27169][tests] Increase changelog upload timeout in tests

  rkhachatryan

  committed
  f0ec84a

  Copy full SHA for f0ec84a

Commits on Apr 29, 2022

• [FLINK-26154][tests] Improve logging in SavepointFormatITCase

  rkhachatryan

  committed
  3fe2abe

  Copy full SHA for 3fe2abe

Commits on Apr 28, 2022

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

  rkhachatryan

  committed
  c5430e2

  Copy full SHA for c5430e2

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

  Show description for 5b58ef6
  rkhachatryan

  committed
  5b58ef6

  Copy full SHA for 5b58ef6

Commits on Apr 11, 2022

• fixup: use width 'auto'

  

  rkhachatryan

  authored and

  Airblader

  committed
  87dd6fb

  Copy full SHA for 87dd6fb

• [FLINK-xxxxx][runtime-web] Improve error message rendering

  Show description for b36e32f
  

  rkhachatryan

  authored and

  Airblader

  committed
  b36e32f

  Copy full SHA for b36e32f

Commits on Apr 8, 2022

• [FLINK-26985][runtime] Don't discard shared state of restored checkpoints

  Show description for c0936de
  rkhachatryan

  committed
  c0936de

  Copy full SHA for c0936de

Commits on Mar 30, 2022

• [hotfix][tests] Remove Deadlines from CommonTestUtils added in new methods

  rkhachatryan

  committed
  0516262

  Copy full SHA for 0516262

Commits on Mar 29, 2022

• [FLINK-26794][tests] Use API to access job checkpoints in IT cases

  Show description for 69665e4
  rkhachatryan

  committed
  69665e4

  Copy full SHA for 69665e4

Commits on Mar 27, 2022

• [FLINK-26615][tests] Fix timings in BatchingStateChangeUploadSchedulerTest.testUploadTimeout

  rkhachatryan

  committed
  9da51e1

  Copy full SHA for 9da51e1

Commits on Mar 25, 2022

• [FLINK-26809][tests] Assert histogram state after stopping the uploader

  Show description for 7e909ff
  rkhachatryan

  committed
  7e909ff

  Copy full SHA for 7e909ff

Commits on Mar 21, 2022

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

  Show description for db4d05a
  rkhachatryan

  committed
  db4d05a

  Copy full SHA for db4d05a

Commits on Mar 15, 2022

• [FLINK-26063][runtime] Set current key before polling next PQ element

  Show description for 092647c
  rkhachatryan

  committed
  092647c

  Copy full SHA for 092647c

Commits on Mar 10, 2022

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

  rkhachatryan

  committed
  ed5e614

  Copy full SHA for ed5e614

Commits on Mar 9, 2022

• [hotfix][state/changelog] Fix UploadTask.getSize

  rkhachatryan

  committed
  3fb1703

  Copy full SHA for 3fb1703

• [FLINK-26485][state/changelog] Discard unnecessarily uploaded state

  rkhachatryan

  committed
  acd2238

  Copy full SHA for acd2238

• [refactor][state/changelog] Complete upload tasks in StateChangeUploadScheduler

  Show description for 1f1480a
  rkhachatryan

  committed
  1f1480a

  Copy full SHA for 1f1480a

• [refactor][state/changelog] Extract StateChangeUploadScheduler interface from StateChangeUploader

  Show description for a3080ee
  rkhachatryan

  committed
  a3080ee

  Copy full SHA for a3080ee

Commits on Mar 7, 2022

• [FLINK-26396][state/changelog] Fail upload if last attempt times out

  rkhachatryan

  committed
  2292c19

  Copy full SHA for 2292c19

• [hotfix][state/changelog] Schedule timeouts on a separate thread

  rkhachatryan

  committed
  276a40a

  Copy full SHA for 276a40a

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

  rkhachatryan

  committed
  b68da57

  Copy full SHA for b68da57

Commits on Feb 24, 2022

• [FLINK-26318][tests] Recover from the latest checkpoint in ChangelogCompatibilityITCase

  Show description for f8ac2bf
  

  rkhachatryan

  authored and

  gaoyunhaii

  committed
  f8ac2bf

  Copy full SHA for f8ac2bf

Commits on Feb 18, 2022

• [FLINK-26231][state/changelog] Fix ChangelogStateBackendHandle constructor

  rkhachatryan

  committed
  8d4d109

  Copy full SHA for 8d4d109

Commits on Feb 17, 2022

• [FLINK-26165][tests] Don't test NATIVE savepoints with Changelog enabled

  rkhachatryan

  committed
  10abe7c

  Copy full SHA for 10abe7c

Pagination

Previous

Next