[FLINK-5448] [checkpoints] Fix typo in StateAssignmentOperation Exception This closes #3097
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fa67ef40 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fa67ef40 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/fa67ef40 Branch: refs/heads/master Commit: fa67ef409c9d0d152d22c74e3ace4d56bc8aa7da Parents: 475c0b1 Author: mtunique <oatg...@gmail.com> Authored: Thu Jan 12 11:55:57 2017 +0800 Committer: Stephan Ewen <se...@apache.org> Committed: Mon Jan 16 20:18:47 2017 +0100 ---------------------------------------------------------------------- .../flink/runtime/checkpoint/StateAssignmentOperation.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/fa67ef40/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StateAssignmentOperation.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StateAssignmentOperation.java b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StateAssignmentOperation.java index f11f69b..6c23f02 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StateAssignmentOperation.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StateAssignmentOperation.java @@ -109,8 +109,8 @@ public class StateAssignmentOperation { if (hasNonPartitionedState && parallelismChanged) { throw new IllegalStateException("Cannot restore the latest checkpoint because " + "the operator " + executionJobVertex.getJobVertexId() + " has non-partitioned " + - "state and its parallelism changed. The operator" + executionJobVertex.getJobVertexId() + - " has parallelism " + newParallelism + " whereas the corresponding" + + "state and its parallelism changed. The operator " + executionJobVertex.getJobVertexId() + + " has parallelism " + newParallelism + " whereas the corresponding " + "state object has a parallelism of " + oldParallelism); }
