Commits

Commits on Jun 5, 2019

[hotfix][operator] Remove unused field in StreamInputProcessor
pnowojski
committedJun 5, 2019
[hotfix][operator] Reorder if conditions in StreamInputProcessor
pnowojski
committedJun 5, 2019
[FLINK-12490][network] Implement NetworkInput and use it in StreamInputProcessor
pnowojski
committedJun 5, 2019
[hotfix][network] Fix InputGate#isAvailable not completed while InputGate#isFinished is true
pnowojski
committedJun 5, 2019
[hotfix][network] Simplify UnionInputGate#isFinished
pnowojski
committedJun 5, 2019
[FLINK-12535][test] Drop deprecated blocking CheckpointBarrierHandler#getNext method
pnowojski
committedJun 5, 2019
[FLINK-12535][network] Make CheckpointBarrierHandler non-blocking
pnowojski
committedJun 5, 2019
[hotfix][test] Deduplicate code in BarrierBufferTestBase
pnowojski
committedJun 5, 2019
[hotfix][test] Deduplicate code in BarrerTrackerTest
pnowojski
committedJun 5, 2019
[hotfix][test] Do not hide original exception in BarrierTrackerTest
pnowojski
committedJun 5, 2019
[hotfix][network] Define AsyncDataInput interface
pnowojski
committedJun 5, 2019
[hotfix][network] Simplify SingleInputGate#isFinished
pnowojski
committedJun 5, 2019
[hotfix][network] Fix JavaDoc of the InputGate
pnowojski
committedJun 5, 2019

Commits on Jun 4, 2019

Commits on May 15, 2019

[hotfix][network] Extract getInputGate and getChannel methods
pnowojski
committedMay 15, 2019
[FLINK-12510][network] Fix deadlock in InputGates
pnowojski
committedMay 15, 2019

Commits on May 10, 2019

Commits on May 7, 2019

Commits on Apr 29, 2019

[hotfix][runtime,tests] Add test coverage for BlockingCallMonitoringThreadPool
pnowojski
committedApr 29, 2019

Commits on Feb 4, 2019

[FLINK-11042][kafka,tests] Drop invalid kafka producer tests
pnowojski
committedFeb 4, 2019
[hotfix][test] Extract TestProcessBuilder utility class
pnowojski
committedFeb 4, 2019