This is an automated email from the ASF dual-hosted git repository.
1996fanrui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 32afcef2ec3 [FLINK-40160][table] Fix casting `NaN` to `FLOAT` or
`DOUBLE`
new 44c041eafff [FLINK-39522] Restructure StreamTask channel-state
recovery into an async future chain
new 2f21971b7d5 [FLINK-39522][network] Remove recovery flags and the
filtering-complete future from the gate API
new 98ab58c023e [FLINK-39522] Defer task finish until recovery completes
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../channel/RecoveredChannelStateHandler.java | 33 ++--
.../partition/consumer/IndexedInputGate.java | 6 -
.../io/network/partition/consumer/InputGate.java | 7 -
.../partition/consumer/RecoveredInputChannel.java | 42 ++---
.../partition/consumer/SingleInputGate.java | 27 ---
.../network/partition/consumer/UnionInputGate.java | 9 -
.../runtime/taskmanager/InputGateWithMetrics.java | 15 --
.../flink/streaming/runtime/tasks/StreamTask.java | 181 ++++++++++++++++-----
.../SequentialChannelStateReaderImplTest.java | 6 +
.../partition/consumer/SingleInputGateBuilder.java | 8 -
.../partition/consumer/SingleInputGateTest.java | 30 ----
.../partition/consumer/UnionInputGateTest.java | 56 -------
.../streaming/runtime/io/MockIndexedInputGate.java | 13 --
.../flink/streaming/runtime/io/MockInputGate.java | 13 --
.../AlignedCheckpointsMassiveRandomTest.java | 13 --
.../tasks/TaskCheckpointingBehaviourTest.java | 2 +
16 files changed, 176 insertions(+), 285 deletions(-)
