Commits

Commits on Feb 21, 2020

[hotfix][test] Clean up the codes in StreamTaskTestHarness, StreamTaskTimerTest and TestProcessingTimeServiceTest

sunhaibotb
authored and
pnowojski
committedFeb 21, 2020
[FLINK-14231][task] Change StreamTask to close operators with StreamOperatorWrapper to make the endInput semantics on the chain strict

sunhaibotb
authored and
pnowojski
committedFeb 21, 2020
[FLINK-14231][task] Add StreamOperatorWrapper that handles the close, endInput and other related logic of an operator

sunhaibotb
authored and
pnowojski
committedFeb 21, 2020
[FLINK-14231][runtime] Introduce and use ProcessingTimeServiceAware to pass ProcessingTimeService to operator

sunhaibotb
authored and
pnowojski
committedFeb 21, 2020
[FLINK-14231][task] Add the quiesce() method to ProcessingTimeService and remove TimerService::awaitPendingAfterQuiesce method

sunhaibotb
authored and
pnowojski
committedFeb 21, 2020

Commits on Nov 14, 2019

[hotfix][test] Fix some code styles in StreamSourceOperatorWatermarksTest and StreamSourceOperatorLatencyMetricsTest

sunhaibotb
authored and
aljoscha
committedNov 14, 2019
[FLINK-14239] Fix the max watermark in StreamSource may arrive the downstream operator early

sunhaibotb
authored and
aljoscha
committedNov 14, 2019

Commits on Oct 28, 2019

[hotfix][test] Clean up the test code in SourceStreamTaskTest and OneInputStreamTaskTest

sunhaibotb
authored and
zhijiangW
committedOct 28, 2019
[FLINK-14230][datastream] Remove the BoundedOneInput implementation of AsyncWaitOperator and ContinuousFileReaderOperator

sunhaibotb
authored and
zhijiangW
committedOct 28, 2019
[FLINK-14230][task] Change the endInput call of the downstream operator to after the upstream operator closes

sunhaibotb
authored and
zhijiangW
committedOct 28, 2019

Commits on Oct 2, 2019

[hotfix][test] Clean up unnecessary type argument declarations in ClassLoaderITCase

sunhaibotb
authored and
zentol
committedOct 2, 2019
[FLINK-13515][test] Fix ClassLoaderITCase fails on Java 11

sunhaibotb
authored and
zentol
committedOct 2, 2019
[FLINK-13516][test] Bump MiniKdc to 3.2.0

sunhaibotb
authored and
zentol
committedOct 2, 2019

Commits on Aug 30, 2019

[FLINK-13051][runtime] Rename TwoInputSelectableStreamTask and StreamTwoInputSelectableProcessor

sunhaibotb
authored and
pnowojski
committedAug 30, 2019
[FLINK-13051][runtime] Drop the non-selectable StreamTask and InputProcessor

sunhaibotb
authored and
pnowojski
committedAug 30, 2019
[hotfix][runtime] Clean up unused member variables in StreamTwoInputSelectableProcessor

sunhaibotb
authored and
pnowojski
committedAug 30, 2019
[hotfix][runtime] Clean up unnecessary type argument declarations in TwoInputStreamTaskTest and TwoInputStreamTaskTestHarness

sunhaibotb
authored and
pnowojski
committedAug 30, 2019
[hotfix][runtime] Remove the unused StreamOperatorFactory#isOperatorSelectiveReading method

sunhaibotb
authored and
pnowojski
committedAug 30, 2019
[FLINK-13051][runtime] Replace the non-selectable stream task with the input-selectable one

sunhaibotb
authored and
pnowojski
committedAug 30, 2019

Commits on Aug 19, 2019

[FLINK-11879][runtime] Add validators for the uses of InputSelectable

sunhaibotb
authored and
pnowojski
committedAug 19, 2019
[hotfix][test] Separate some shared inner classes from test classes into the separate files

sunhaibotb
authored and
pnowojski
committedAug 19, 2019
[FLINK-11879][runtime] Add getStreamOperatorClass() to the StreamOperatorFactory interface

sunhaibotb
authored and
pnowojski
committedAug 19, 2019

Commits on Aug 16, 2019

[FLINK-12529][runtime] Release record-deserializer buffers timely to improve the usage efficiency of heap on taskmanager (apache#8471 )

sunhaibotb
authored and
pnowojski
committedAug 16, 2019

Commits on Jun 25, 2019

[FLINK-12967][runtime] Change the processing that the input reaches the end to comply with the InputSelectable contract

sunhaibotb
authored and
pnowojski
committedJun 25, 2019

Commits on Jun 24, 2019

[FLINK-11878][runtime] Implement the runtime handling of BoundedOneInput and BoundedMultiInput

sunhaibotb
authored and
pnowojski
committedJun 24, 2019

Commits on Jun 17, 2019

FLINK-1722][datastream] Enable the InitializeOnMaster and FinalizeOnMaster interfaces on datastream

sunhaibotb
authored and
aljoscha
committedJun 17, 2019

Commits on Jun 12, 2019

[FLINK-11877][runtime] Implement the runtime handling of the InputSelectable interface

sunhaibotb
authored and
pnowojski
committedJun 12, 2019
[FLINK-11877][runtime] Abstract AbstractTwoInputStreamTask from TwoInputStreamTask

sunhaibotb
authored and
pnowojski
committedJun 12, 2019
[FLINK-11877][runtime] Introduce new BarrierDiscarder class

sunhaibotb
authored and
pnowojski
committedJun 12, 2019
[FLINK-11876] Introduce new InputSelectable, BoundedOneInput and BoundedMultiInput interfaces for stream operators

sunhaibotb
authored and
pnowojski
committedJun 12, 2019

Commits on Jun 5, 2019

[FLINK-12490][network] Introduce Input interface

sunhaibotb
authored and
pnowojski
committedJun 5, 2019

Commits on Jun 3, 2019

[FLINK-12547][blob] Add connection and socket timeouts for the blob client

sunhaibotb
authored and
tillrohrmann
committedJun 3, 2019

Commits on May 10, 2019

[hotfix][network] Implement UnionInputGate#pollNextBufferOrEvent method

sunhaibotb
authored and
pnowojski
committedMay 10, 2019

Commits on Mar 1, 2019

[FLINK-11379][core] Fix OutOfMemoryError caused by Files.readAllBytes() when TM loads a large size TDD

sunhaibotb
authored and
sunjincheng121
committedMar 1, 2019

Commits on Jan 19, 2019

[FLINK-11256][Streaming] Improve StreamEdge to reduce the sizes of JobGraph

sunhaibotb
authored and
sunjincheng121
committedJan 19, 2019