Skip to content

Commit

Permalink
[FLINK-18989][task] Remove non-sequental ChannelStateReader and the r…
Browse files Browse the repository at this point in the history
…elated code

- ChannelStateReader and supporting classes
- methods for channel state recovery in inputChannels, subpartitions, etc.
- tests for reading channel state non-sequentially
  • Loading branch information
rkhachatryan authored and AHeise committed Oct 9, 2020
1 parent de2ab7a commit 0b6c086
Show file tree
Hide file tree
Showing 30 changed files with 15 additions and 1,623 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@
import org.apache.flink.runtime.checkpoint.CheckpointMetrics;
import org.apache.flink.runtime.checkpoint.PrioritizedOperatorSubtaskState;
import org.apache.flink.runtime.checkpoint.TaskStateSnapshot;
import org.apache.flink.runtime.checkpoint.channel.ChannelStateReader;
import org.apache.flink.runtime.checkpoint.channel.SequentialChannelStateReader;
import org.apache.flink.runtime.jobgraph.OperatorID;
import org.apache.flink.runtime.state.LocalRecoveryConfig;
import org.apache.flink.runtime.state.LocalRecoveryDirectoryProvider;
Expand Down Expand Up @@ -68,8 +68,8 @@ public LocalRecoveryConfig createLocalRecoveryConfig() {
}

@Override
public ChannelStateReader getChannelStateReader() {
return ChannelStateReader.NO_OP;
public SequentialChannelStateReader getSequentialChannelStateReader() {
return SequentialChannelStateReader.NO_OP;
}

@Override
Expand Down

This file was deleted.

This file was deleted.

This file was deleted.

Loading

0 comments on commit 0b6c086

Please sign in to comment.