flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From u..@apache.org
Subject flink git commit: [FLINK-5169] [network] Fix String formats in spillable partition
Date Thu, 08 Dec 2016 14:23:06 GMT
Repository: flink
Updated Branches:
  refs/heads/release-1.1 b046038ae -> 671b434cf


[FLINK-5169] [network] Fix String formats in spillable partition

This closes #2967.


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

Branch: refs/heads/release-1.1
Commit: 671b434cf3e09d6edb247f6f84f38b8088fc5c5d
Parents: b046038
Author: Boris Osipov <boris_osipov@epam.com>
Authored: Thu Dec 8 16:58:21 2016 +0300
Committer: Ufuk Celebi <uce@apache.org>
Committed: Thu Dec 8 15:22:08 2016 +0100

----------------------------------------------------------------------
 .../runtime/io/network/partition/SpillableSubpartitionView.java    | 2 +-
 .../runtime/io/network/partition/SpilledSubpartitionView.java      | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/671b434c/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionView.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionView.java
b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionView.java
index 533f95b..df8de54 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionView.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionView.java
@@ -206,7 +206,7 @@ class SpillableSubpartitionView implements ResultSubpartitionView {
 	public String toString() {
 		boolean hasSpilled = spilledView != null;
 
-		return String.format("SpillableSubpartitionView(index: %d, buffers: %d, spilled? {}) of
ResultPartition %s",
+		return String.format("SpillableSubpartitionView(index: %d, buffers: %d, spilled? %b) of
ResultPartition %s",
 			parent.index,
 			numBuffers,
 			hasSpilled,

http://git-wip-us.apache.org/repos/asf/flink/blob/671b434c/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpilledSubpartitionView.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpilledSubpartitionView.java
b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpilledSubpartitionView.java
index 7488132..fec0f2a 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpilledSubpartitionView.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpilledSubpartitionView.java
@@ -166,7 +166,7 @@ class SpilledSubpartitionView implements ResultSubpartitionView, NotificationLis
 
 	@Override
 	public String toString() {
-		return String.format("SpilledSubpartitionView(index: %d, buffers: {}) of ResultPartition
%s",
+		return String.format("SpilledSubpartitionView(index: %d, buffers: %d) of ResultPartition
%s",
 			parent.index,
 			numberOfSpilledBuffers,
 			parent.parent.getPartitionId());


Mime
View raw message