flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From u..@apache.org
Subject [6/9] git commit: [FLINK-1078] PrintingOutputFormat uses same partition indexing as FileOutputFormat.
Date Tue, 09 Sep 2014 23:42:23 GMT
[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 <sewen@apache.org>
Authored: Mon Sep 1 19:03:04 2014 +0200
Committer: uce <u.celebi@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


Mime
View raw message