Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/3872#discussion_r116017704
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/SharedBuffer.java
---
@@ -96,10 +96,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 " +
--- End diff --
I think the comma is superfluous.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
