Hi,
Which version of flink do you use? I would recommend upgrading to 1.6.2
for which we reworked internal structures and such problem should not occur.
Best,
Dawid
On 19/11/2018 08:30, Chesnay Schepler wrote:
> @klou @dawid What is the most likely cause if this is not caused by an
> improper
@klou @dawid What is the most likely cause if this is not caused by an
improper equals()/hashCode() implementation?
On 16.11.2018 19:39, Steve Bistline wrote:
Implemented hashcode() on both the DEVICE_ID and the MOTION_DIRECTION
( the pattern is built around this one ). Still giving me the
Implemented hashcode() on both the DEVICE_ID and the MOTION_DIRECTION ( the
pattern is built around this one ). Still giving me the following error:
java.lang.RuntimeException: Exception occurred while processing valve
output watermark:
at
Can you provide us with the implementation of your Event and IoTEvent
classes?
On 15.11.2018 06:10, Steve Bistline wrote:
Any thoughts on where to start with this error would be appreciated.
Caused by: java.lang.IllegalStateException: Could not find previous entry with key: first event,
