8000 Commits · crazyshark/flink · GitHub

More Web Proxy on the site http://driver.im/

Commits

Commits on Sep 23, 2021

[FLINK-24344][runtime] Calling the CheckpointFailureManager even if the exception happens during the checkpoint initialization

akalash
authored and
pnowojski
committed
[FLINK-24344][runtime] testTriggerCheckpointAfterIoException throws exception from initializeLocationForCheckpoint rather than from getAndIncrement

akalash
authored and
pnowojski
committed

Commits on Sep 17, 2021

[FLINK-24233][runtime] Ignore message about new buffer size if the reader doesn't ready yet

akalash
authored and
pnowojski
committed
[FLINK-11250][runtime] Added method init for RecordWriter for initialization resources(OutputFlusher) outside of constructor (#17187)
akalash
authored

Commits on Sep 16, 2021

[FLINK-24133][core] Network failure test replaced by comment in the code due to high expense of stabilizing such low important test

akalash
authored and
pnowojski
committed

Commits on Sep 13, 2021

[FLINK-23458][docs] Added the network buffer documentation along with the buffer debloat doc

akalash
authored and
pnowojski
committed

Commits on Sep 7, 2021

Commits on Sep 1, 2021

[FLINK-23797][tests] Wait for all task running before savepoint for all tests in SavepointITCase

akalash
authored and
pnowojski
committed

Commits on Aug 17, 2021

[FLINK-23680][streaming] Wait until all expected threads would be triggered in testOpenCloseAndTimestamps (#16797)
akalash
authored

Commits on Aug 16, 2021

[FLINK-23560][runtime] Calculate absoluteTimeMillis only once for idle metric and throughput calculation. (#16772)
akalash
authored

Commits on Aug 11, 2021

Commits on Aug 5, 2021

Commits on Aug 4, 2021

[hotfix][streaming] Removed useless calculateThroughput in the test

akalash
authored and
pnowojski
committed
[FLINK-23590][streaming] Replace System.currentTimeMillis with SystemClock.relativeTimeMillis() in the test

akalash
authored and
pnowojski
committed

Commits on Jul 29, 2021

[FLINK-23452][streaming] Integration ThroughputCalculator in StreamTask for the calculation of the subtask level throughput

akalash
authored and
pnowojski
committed

0