Commits

Commits on Nov 28, 2019

[FLINK-10377] Support checkpoint overtaking a savepoint in TwoPhaseCommitSink

StefanRRichter
authored and
pnowojski
committedNov 28, 2019

Commits on Jul 18, 2019

[FLINK-13249][runtime] Fix handling of partition producer responses b… (apache#9138 )
StefanRRichter
committedJul 18, 2019

Commits on Jul 12, 2019

[FLINK-12804] Change mailbox implementation from bounded to unbounded
StefanRRichter
committedJul 12, 2019
[FLINK-12804] Introduce mailbox-based ExecutorService
StefanRRichter
committedJul 12, 2019
[hotfix] Remove dangerous waiting methods from mailbox
StefanRRichter
committedJul 12, 2019

Commits on Jul 9, 2019

[FLINK-13063] Temporary fix for AsyncWaitOperator consistency problems
StefanRRichter
committedJul 9, 2019

Commits on May 22, 2019

Commits on Apr 15, 2019

[hotfix] Delete empty TaskManager.scala file
StefanRRichter
committedApr 15, 2019
[hotfix] Remove unused method ExecutionGraph#restoreLatestCheckpointedState
StefanRRichter
committedApr 15, 2019
[hotfix] Use TemporaryClassLoaderContext in other appropriate places in the codebase
StefanRRichter
committedApr 15, 2019
[FLINK-11952][4/4] Integrate plugin mechanism with FileSystem initialization in process entry points
StefanRRichter
committedApr 15, 2019
[FLINK-11952][3/4] Integrate plugin mechanism with FileSystem
StefanRRichter
committedApr 15, 2019
[FLINK-11952][2/4] Introduce basic plugin mechanism for Flink
StefanRRichter
committedApr 15, 2019
[FLINK-11952][1/3] Make ChildFirstClassLoader a top-level class in flink-core
StefanRRichter
committedApr 15, 2019
[hotfix] Remove unused exception from FileSystem#initialize
StefanRRichter
committedApr 15, 2019

Commits on Mar 20, 2019

[hotfix] Remove unused method in AbstractKeyedStateBackend
StefanRRichter
committedMar 20, 2019
[FLINK-11980] Improve efficiency of iterating KeySelectionListener on notification
StefanRRichter
committedMar 20, 2019
[hotfix] Fix inactive branch in TtlStateTestBase
StefanRRichter
committedMar 20, 2019

Commits on Feb 27, 2019

Commits on Feb 26, 2019

[hotfix] Revert overriding toString-method in AllocationID
StefanRRichter
committedFeb 26, 2019
[FLINK-11744][core]Provide stable/final toHexString-method in AbstractID
StefanRRichter
committedFeb 26, 2019

Commits on Feb 25, 2019

[hotfix] Repair ineffective LocalRecoveryITCase
StefanRRichter
committedFeb 25, 2019

Commits on Feb 22, 2019

[FLINK-11541] Run submitTask call in future executor
StefanRRichter
committedFeb 22, 2019

Commits on Feb 21, 2019

[FLINK-11041][tests] Fix ReinterpretDataStreamAsKeyedStreamITCase
StefanRRichter
committedFeb 21, 2019

Commits on Feb 18, 2019

[FLINK-11121][license] Check and update licensing notes for Aliyun FS
StefanRRichter
committedFeb 18, 2019

Commits on Feb 15, 2019

[FLINK-10431] Extract scheduling-related code from SlotPool
StefanRRichter
committedFeb 15, 2019

Commits on Feb 5, 2019

[FLINK-11417] Make access to ExecutionGraph single threaded from JobMaster main thread
StefanRRichter
committedFeb 5, 2019

Commits on Jan 7, 2019

Commits on Dec 11, 2018

[FLINK-11041][test] ReinterpretDataStreamAsKeyedStreamITCase source should hold checkpointing lock

StefanRRichter
authored and
tillrohrmann
committedDec 11, 2018