You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by uc...@apache.org on 2014/09/10 01:42:23 UTC
[6/9] git commit: [FLINK-1078] PrintingOutputFormat uses same
partition indexing as FileOutputFormat.
[FLINK-1078] PrintingOutputFormat uses same partition indexing as FileOutputFormat.
Project: http://git-wip-us.apache.org/repos/asf/incubator-flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-flink/commit/3bcf6999
Tree: http://git-wip-us.apache.org/repos/asf/incubator-flink/tree/3bcf6999
Diff: http://git-wip-us.apache.org/repos/asf/incubator-flink/diff/3bcf6999
Branch: refs/heads/release-0.6.1
Commit: 3bcf699955bae85145fe33a4099587636d3c4ef3
Parents: 64510b6
Author: Stephan Ewen <se...@apache.org>
Authored: Mon Sep 1 19:03:04 2014 +0200
Committer: uce <u....@fu-berlin.de>
Committed: Wed Sep 10 00:49:50 2014 +0200
----------------------------------------------------------------------
.../java/org/apache/flink/api/java/io/PrintingOutputFormat.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/3bcf6999/flink-java/src/main/java/org/apache/flink/api/java/io/PrintingOutputFormat.java
----------------------------------------------------------------------
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/io/PrintingOutputFormat.java b/flink-java/src/main/java/org/apache/flink/api/java/io/PrintingOutputFormat.java
index 435057f..42e0b46 100644
--- a/flink-java/src/main/java/org/apache/flink/api/java/io/PrintingOutputFormat.java
+++ b/flink-java/src/main/java/org/apache/flink/api/java/io/PrintingOutputFormat.java
@@ -74,7 +74,7 @@ public class PrintingOutputFormat<T> implements OutputFormat<T> {
this.stream = this.target == STD_OUT ? System.out : System.err;
// set the prefix if we have a >1 DOP
- this.prefix = (numTasks > 1) ? (taskNumber + "> ") : null;
+ this.prefix = (numTasks > 1) ? ((taskNumber+1) + "> ") : null;
}
@Override