AHeise commented on a change in pull request #13735:
URL: https://github.com/apache/flink/pull/13735#discussion_r518555888
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/OperatorSubtaskState.java
##########
@@ -64,81 +61,64 @@
/**
* Snapshot from the {@link
org.apache.flink.runtime.state.OperatorStateBackend}.
*/
- @Nonnull
private final StateObjectCollection<OperatorStateHandle>
managedOperatorState;
/**
* Snapshot written using {@link
org.apache.flink.runtime.state.OperatorStateCheckpointOutputStream}.
*/
- @Nonnull
private final StateObjectCollection<OperatorStateHandle>
rawOperatorState;
/**
* Snapshot from {@link
org.apache.flink.runtime.state.KeyedStateBackend}.
*/
- @Nonnull
private final StateObjectCollection<KeyedStateHandle> managedKeyedState;
/**
* Snapshot written using {@link
org.apache.flink.runtime.state.KeyedStateCheckpointOutputStream}.
*/
- @Nonnull
private final StateObjectCollection<KeyedStateHandle> rawKeyedState;
- @Nonnull
private final StateObjectCollection<InputChannelStateHandle>
inputChannelState;
- @Nonnull
private final StateObjectCollection<ResultSubpartitionStateHandle>
resultSubpartitionState;
/**
- * The state size. This is also part of the deserialized state handle.
- * We store it here in order to not deserialize the state handle when
- * gathering stats.
+ * The subpartitions mappings per partition set when the output
operator for a partition was rescaled. The key is
+ * the partition id and the value contains all subtask indexes of the
output operator before rescaling.
*/
- private final long stateSize;
+ private final InflightDataRescalingDescriptor inputRescalingDescriptor;
Review comment:
Added a comment.
```
Note that this field is only set by {@link StateAssignmentOperation} and
will not be persisted in the checkpoint itself as it can only be calculated if
the the post-recovery scale factor is known.
```
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
