You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by gr...@apache.org on 2016/09/20 14:12:42 UTC
[4/4] flink git commit: [FLINK-4638] [core] Fix exception message for
MemorySegment
[FLINK-4638] [core] Fix exception message for MemorySegment
This closes #2515
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7a25bf5c
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7a25bf5c
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/7a25bf5c
Branch: refs/heads/master
Commit: 7a25bf5cee9ab94525ed0284cbf399d2c33f70cf
Parents: 0975d9f
Author: Liwei Lin <lw...@gmail.com>
Authored: Tue Sep 20 14:35:28 2016 +0800
Committer: Greg Hogan <co...@greghogan.com>
Committed: Tue Sep 20 10:10:20 2016 -0400
----------------------------------------------------------------------
.../src/main/java/org/apache/flink/core/memory/MemorySegment.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/7a25bf5c/flink-core/src/main/java/org/apache/flink/core/memory/MemorySegment.java
----------------------------------------------------------------------
diff --git a/flink-core/src/main/java/org/apache/flink/core/memory/MemorySegment.java b/flink-core/src/main/java/org/apache/flink/core/memory/MemorySegment.java
index af3efe7..d8315c5 100644
--- a/flink-core/src/main/java/org/apache/flink/core/memory/MemorySegment.java
+++ b/flink-core/src/main/java/org/apache/flink/core/memory/MemorySegment.java
@@ -161,7 +161,7 @@ public abstract class MemorySegment {
}
if (offHeapAddress >= Long.MAX_VALUE - Integer.MAX_VALUE) {
// this is necessary to make sure the collapsed checks are safe against numeric overflows
- throw new IllegalArgumentException("Segment initialized with too large address: " + address
+ throw new IllegalArgumentException("Segment initialized with too large address: " + offHeapAddress
+ " ; Max allowed address is " + (Long.MAX_VALUE - Integer.MAX_VALUE - 1));
}