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 committed Oct 6, 2020
1 parent 5962a2d commit ec6d68e
Show file tree
Hide file tree
Showing 30 changed files with 9 additions and 1,639 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,6 @@
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;
Expand Down Expand Up @@ -68,11 +67,6 @@ public LocalRecoveryConfig createLocalRecoveryConfig() {
return new LocalRecoveryConfig(false, provider);
}

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

@Override
public SequentialChannelStateReader getSequentialChannelStateReader() {
return SequentialChannelStateReader.NO_OP;
Expand Down

This file was deleted.

This file was deleted.

This file was deleted.

Loading

0 comments on commit ec6d68e

Please sign in to comment.