Commits

Commits on May 26, 2022

[hotfix][tests] Raise logging level in TestJobExecutor
rkhachatryan
committedMay 26, 2022
[FLINK-27169][tests] Set timeout for operator lifecycle tests
rkhachatryan
committedMay 26, 2022
[FLINK-27169][tests] Increase changelog upload timeout in tests
rkhachatryan
committedMay 26, 2022

Commits on Apr 29, 2022

[FLINK-26154][tests] Improve logging in SavepointFormatITCase
rkhachatryan
committedApr 29, 2022

Commits on Apr 28, 2022

[FLINK-25511][state/changelog] Discard pre-emptively uploaded state changes not included into any checkpoint
rkhachatryan
committedApr 28, 2022
[FLINK-25511][state] Introduce StreamStateHandle ID
rkhachatryan
committedApr 28, 2022

Commits on Apr 11, 2022

fixup: use width 'auto'

rkhachatryan
authored and
Airblader
committedApr 11, 2022
[FLINK-xxxxx][runtime-web] Improve error message rendering

rkhachatryan
authored and
Airblader
committedApr 11, 2022

Commits on Apr 8, 2022

[FLINK-26985][runtime] Don't discard shared state of restored checkpoints
rkhachatryan
committedApr 8, 2022

Commits on Mar 30, 2022

[hotfix][tests] Remove Deadlines from CommonTestUtils added in new methods
rkhachatryan
committedMar 30, 2022

Commits on Mar 29, 2022

[FLINK-26794][tests] Use API to access job checkpoints in IT cases
rkhachatryan
committedMar 29, 2022

Commits on Mar 27, 2022

[FLINK-26615][tests] Fix timings in BatchingStateChangeUploadSchedulerTest.testUploadTimeout
rkhachatryan
committedMar 27, 2022

Commits on Mar 25, 2022

[FLINK-26809][tests] Assert histogram state after stopping the uploader
rkhachatryan
committedMar 25, 2022

Commits on Mar 21, 2022

[FLINK-26592][state/changelog] Use mailbox in FsStateChangelogWriter instead of a lock
rkhachatryan
committedMar 21, 2022

Commits on Mar 15, 2022

[FLINK-26063][runtime] Set current key before polling next PQ element
rkhachatryan
committedMar 15, 2022

Commits on Mar 10, 2022

[FLINK-26306][state/changelog] Randomly offset materialization
rkhachatryan
committedMar 10, 2022

Commits on Mar 9, 2022

Commits on Mar 7, 2022

[FLINK-26396][state/changelog] Fail upload if last attempt times out
rkhachatryan
committedMar 7, 2022
[hotfix][state/changelog] Schedule timeouts on a separate thread
rkhachatryan
committedMar 7, 2022
[FLINK-26455][state/changelog] Don't fail on materialization cancellation
rkhachatryan
committedMar 7, 2022

Commits on Feb 24, 2022

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

rkhachatryan
authored and
gaoyunhaii
committedFeb 24, 2022

Commits on Feb 18, 2022

[FLINK-26231][state/changelog] Fix ChangelogStateBackendHandle constructor
rkhachatryan
committedFeb 18, 2022

Commits on Feb 17, 2022

[FLINK-26165][tests] Don't test NATIVE savepoints with Changelog enabled
rkhachatryan
committedFeb 17, 2022
[hotfix][state] Explicitly validate native savepoints support
rkhachatryan
committedFeb 17, 2022

Commits on Feb 16, 2022

[FLINK-26079][state/changelog] Disallow recovery from non-changelog checkpoints
rkhachatryan
committedFeb 16, 2022
[hotfix][tests] Explicitly disable changelog in migration tests
rkhachatryan
committedFeb 16, 2022
[FLINK-26177][tests] Disable PulsarSourceITCase rescaling tests temporarily
rkhachatryan
committedFeb 16, 2022

Commits on Feb 14, 2022

Commits on Feb 12, 2022

[FLINK-25987][state/changelog] Replace lastSqn with nextSqn()
rkhachatryan
committedFeb 12, 2022