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 2016/12/08 14:21:52 UTC
flink git commit: [FLINK-5169] [network] Fix String formats in
spillable partition
Repository: flink
Updated Branches:
refs/heads/master 4eb71927b -> 55d60615a
[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/55d60615
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/55d60615
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/55d60615
Branch: refs/heads/master
Commit: 55d60615a5e3f72135aad7f0ec5a2c1b4485b908
Parents: 4eb7192
Author: Boris Osipov <bo...@epam.com>
Authored: Thu Dec 8 16:58:21 2016 +0300
Committer: Ufuk Celebi <uc...@apache.org>
Committed: Thu Dec 8 15:21:24 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/55d60615/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/55d60615/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());