Repository: incubator-beam Updated Branches: refs/heads/master f1935d5d1 -> 9b4a464a3
ByteKeyRangeTracker: synchronize toString It's the only unsynchronized function, and it could potentially produce bad data. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b7c9a7bf Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b7c9a7bf Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/b7c9a7bf Branch: refs/heads/master Commit: b7c9a7bf4711a404f206abfe9480312525fe4a46 Parents: f1935d5 Author: Daniel Halperin <[email protected]> Authored: Tue Aug 16 13:11:16 2016 -0700 Committer: GitHub <[email protected]> Committed: Tue Aug 16 13:11:16 2016 -0700 ---------------------------------------------------------------------- .../java/org/apache/beam/sdk/io/range/ByteKeyRangeTracker.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b7c9a7bf/sdks/java/core/src/main/java/org/apache/beam/sdk/io/range/ByteKeyRangeTracker.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/io/range/ByteKeyRangeTracker.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/io/range/ByteKeyRangeTracker.java index 7dd9a2c..24bf6e4 100644 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/io/range/ByteKeyRangeTracker.java +++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/io/range/ByteKeyRangeTracker.java @@ -176,7 +176,7 @@ public final class ByteKeyRangeTracker implements RangeTracker<ByteKey> { } @Override - public String toString() { + public synchronized String toString() { return toStringHelper(ByteKeyRangeTracker.class) .add("range", range) .add("position", position)
