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_osi...@epam.com> Authored: Thu Dec 8 16:58:21 2016 +0300 Committer: Ufuk Celebi <u...@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());
