flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hsapu...@apache.org
Subject flink git commit: Fix typo in exception message from assiged to assigned in ExecutionJobVertex.
Date Wed, 25 Feb 2015 00:00:01 GMT
Repository: flink
Updated Branches:
  refs/heads/master bfbbbf906 -> 64c302f8f


Fix typo in exception message from assiged to assigned in ExecutionJobVertex.


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/64c302f8
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/64c302f8
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/64c302f8

Branch: refs/heads/master
Commit: 64c302f8f4d211a2cd10764e3090b4f9bdde436c
Parents: bfbbbf9
Author: Henry Saputra <henry.saputra@gmail.com>
Authored: Tue Feb 24 15:59:35 2015 -0800
Committer: Henry Saputra <henry.saputra@gmail.com>
Committed: Tue Feb 24 15:59:35 2015 -0800

----------------------------------------------------------------------
 .../apache/flink/runtime/executiongraph/ExecutionJobVertex.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/64c302f8/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionJobVertex.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionJobVertex.java
b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionJobVertex.java
index 9df9bd5..0444e5d 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionJobVertex.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionJobVertex.java
@@ -132,7 +132,7 @@ public class ExecutionJobVertex implements Serializable {
 		// sanity check for the double referencing between intermediate result partitions and execution
vertices
 		for (IntermediateResult ir : this.producedDataSets) {
 			if (ir.getNumberOfAssignedPartitions() != parallelism) {
-				throw new RuntimeException("The intermediate result's partitions were not correctly assiged.");
+				throw new RuntimeException("The intermediate result's partitions were not correctly assigned.");
 			}
 		}
 		


Mime
View raw message