Commits

Commits on Mar 4, 2020

[FLINK-11193][State] Fix Rockdb timer service factory configuration option to be settable per job

Aitozi
authored and
azagrebin
committedMar 4, 2020

Commits on Oct 29, 2019

[FLINK-12492][cep] Minor optimize the cep operator by avoiding unnecessary copy

Aitozi
authored and
dawidwys
committedOct 29, 2019

Commits on Aug 5, 2019

[FLINK-12576][Network, Metrics] Take LocalInputChannel into account when compute inputQueueLength (apache#8559 )

Aitozi
authored and
zhijiangW
committedAug 5, 2019

Commits on Jul 10, 2019

[hotfix][runtime] Remove unused DependencyVisitor

Aitozi
authored and
StephanEwen
committedJul 10, 2019

Commits on Jul 3, 2019

[FLINK-12284][Network,Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode

Aitozi
authored and
pnowojski
committedJul 3, 2019

Commits on Jun 15, 2019

[FLINK-12297] Make Java ClosureCleaner recursive to handle nested functions

Aitozi
authored and
aljoscha
committedJun 15, 2019

Commits on May 16, 2019

[hotfix][tests] Use TemporaryFolder in TextInputFormatTest

Aitozi
authored and
zentol
committedMay 16, 2019

Commits on Oct 16, 2018

[FLINK-9443][streaming] Remove unused parameter in StreamGraphHasherV2#generateNodeLocalHash

Aitozi
authored and
zentol
committedOct 16, 2018

Commits on Sep 6, 2018

[FLINK-10254][backend]Fix inappropriate checkNotNull in stateBackend

Aitozi
authored and
dawidwys
committedSep 6, 2018

Commits on Aug 29, 2018

[FLINK-9642][cep] Added caching layer to SharedBuffer(apache#6205 )

Aitozi
authored and
dawidwys
committedAug 29, 2018