You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2017/06/25 06:44:52 UTC
[09/21] flink git commit: [hotfix] Improve readability in
SPV2#convertToOperatorStateSavepointV2
[hotfix] Improve readability in SPV2#convertToOperatorStateSavepointV2
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7b97371a
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7b97371a
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/7b97371a
Branch: refs/heads/master
Commit: 7b97371a091d1a096145b373f20e35b7de18483b
Parents: a0b7814
Author: zentol <ch...@apache.org>
Authored: Wed Jun 7 12:03:57 2017 +0200
Committer: zentol <ch...@apache.org>
Committed: Fri Jun 23 14:14:29 2017 +0200
----------------------------------------------------------------------
.../flink/runtime/checkpoint/savepoint/SavepointV2.java | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/7b97371a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/savepoint/SavepointV2.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/savepoint/SavepointV2.java b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/savepoint/SavepointV2.java
index 6a3b57f..1b2963d 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/savepoint/SavepointV2.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/savepoint/SavepointV2.java
@@ -188,8 +188,8 @@ public class SavepointV2 implements Savepoint {
for (int chainIndex = 0; chainIndex < taskState.getChainLength(); chainIndex++) {
// task consists of multiple operators so we have to break the state apart
- for (int o = 0; o < operatorIDs.size(); o++) {
- OperatorID operatorID = operatorIDs.get(o);
+ for (int operatorIndex = 0; operatorIndex < operatorIDs.size(); operatorIndex++) {
+ OperatorID operatorID = operatorIDs.get(operatorIndex);
OperatorState operatorState = operatorStates.get(operatorID);
if (operatorState == null) {
@@ -204,15 +204,15 @@ public class SavepointV2 implements Savepoint {
KeyedStateHandle rawKeyedState = null;
// only the head operator retains the keyed state
- if (o == operatorIDs.size() - 1) {
+ if (operatorIndex == operatorIDs.size() - 1) {
managedKeyedState = subtaskState.getManagedKeyedState();
rawKeyedState = subtaskState.getRawKeyedState();
}
OperatorSubtaskState operatorSubtaskState = new OperatorSubtaskState(
- nonPartitionedState != null ? nonPartitionedState.get(o) : null,
- partitioneableState != null ? partitioneableState.get(o) : null,
- rawOperatorState != null ? rawOperatorState.get(o) : null,
+ nonPartitionedState != null ? nonPartitionedState.get(operatorIndex) : null,
+ partitioneableState != null ? partitioneableState.get(operatorIndex) : null,
+ rawOperatorState != null ? rawOperatorState.get(operatorIndex) : null,
managedKeyedState,
rawKeyedState);