flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From uce <...@git.apache.org>
Subject [GitHub] flink pull request: [FLINK-2026] add a flag to indicate previous e...
Date Tue, 19 May 2015 12:16:44 GMT
Github user uce commented on a diff in the pull request:

    --- Diff: flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java
    @@ -914,7 +917,15 @@ public JavaPlan createProgramPlan(String jobName) {
     	public JavaPlan createProgramPlan(String jobName, boolean clearSinks) {
     		if (this.sinks.isEmpty()) {
    -			throw new RuntimeException("No data sinks have been created yet. A program needs at
least one sink that consumes data. Examples are writing the data set or printing it.");
    +			if (wasExecuted) {
    +				throw new RuntimeException("No new data sinks have been defined since the " +
    +						"last execution. The last execution refers to the latest call to " +
    +						"'execute()', 'count()' 'collect()' or 'print()'.");
    --- End diff --
    missing commas

If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.

View raw message