flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rmetz...@apache.org
Subject git commit: [FLINK-893] Inconsistent Iteration Step Function gives nonesense error message
Date Thu, 03 Jul 2014 10:36:59 GMT
Repository: incubator-flink
Updated Branches:
  refs/heads/master 3c8bdee86 -> 8a8060eaa


[FLINK-893] Inconsistent Iteration Step Function gives nonesense error message

I adjusted the error message.

Author: Markus Holzemer <markus.holzemer@gmx.de>

Closes #50 from markus-h/iteration_translation_exception and squashes the following commits:

34a6f87 [Markus Holzemer] adjusted error message when encountering a translation failure for
iterations


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

Branch: refs/heads/master
Commit: 8a8060eaa3a12703b594d4f4c581fa14bd846b19
Parents: 3c8bdee
Author: Markus Holzemer <markus.holzemer@gmx.de>
Authored: Thu Jul 3 12:34:52 2014 +0200
Committer: Robert Metzger <rmetzger@apache.org>
Committed: Thu Jul 3 12:34:52 2014 +0200

----------------------------------------------------------------------
 .../src/main/java/eu/stratosphere/api/java/IterativeDataSet.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/8a8060ea/stratosphere-java/src/main/java/eu/stratosphere/api/java/IterativeDataSet.java
----------------------------------------------------------------------
diff --git a/stratosphere-java/src/main/java/eu/stratosphere/api/java/IterativeDataSet.java
b/stratosphere-java/src/main/java/eu/stratosphere/api/java/IterativeDataSet.java
index bab990d..be3fdf7 100644
--- a/stratosphere-java/src/main/java/eu/stratosphere/api/java/IterativeDataSet.java
+++ b/stratosphere-java/src/main/java/eu/stratosphere/api/java/IterativeDataSet.java
@@ -137,6 +137,6 @@ public class IterativeDataSet<T> extends SingleInputOperator<T,
T, IterativeData
 	@Override
 	protected eu.stratosphere.api.common.operators.SingleInputOperator<T, T, ?> translateToDataFlow(Operator<T>
input) {
 		// All the translation magic happens when the iteration end is encountered.
-		throw new UnsupportedOperationException("This should never happen.");
+		throw new RuntimeException("Error while creating the data flow plan for an iteration: The
iteration end was not specified correctly.");
 	}
 }


Mime
View raw message