Skip to content

Commit

Permalink
[FLINK-6536] [cep] Improve error message in SharedBuffer::put().
Browse files Browse the repository at this point in the history
  • Loading branch information
kl0u committed May 17, 2017
1 parent ae9c9d0 commit 02ea418
Showing 1 changed file with 4 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -97,10 +97,11 @@ public void put(

// sanity check whether we've found the previous element
if (previousSharedBufferEntry == null && previousValue != null) {
throw new IllegalStateException("Could not find previous shared buffer entry with " +
throw new IllegalStateException("Could not find previous entry with " +
"key: " + previousKey + ", value: " + previousValue + " and timestamp: " +
previousTimestamp + ". This can indicate that the element belonging to the previous " +
"relation has been already pruned, even though you expect it to be still there.");
previousTimestamp + ". This can indicate that either you did not implement " +
"the equals() and hashCode() methods of your input elements properly or that " +
"the element belonging to that entry has been already pruned.");
}

put(key, value, timestamp, previousSharedBufferEntry, version);
Expand Down

0 comments on commit 02ea418

Please sign in to comment.