Hi Seth,
are you sure that all partitions of the broadcasted stream send a
watermark? processWatermark is only called if a minimum watermark
arrived from all partitions.
Regards,
Timo
Am 12/13/17 um 5:10 PM schrieb Seth Wiesman:
Hi,
How are watermarks propagated during a broadcast partition? I have a
TwoInputStreamTransformation that takes a broadcast stream as one of
its inputs. Both streams are assigned timestamps and watermarks before
being connected however I only ever see watermarks from my
non-broadcast stream. Is this expected behavior? Currently I have
overridden processWatermark1 to unconditionally call processWatermark
but that does not seem like an ideal solution.
Thank you,
<http://www.mediamath.com/>
*Seth Wiesman *| Software Engineer, Data
4 World Trade Center, 46th Floor, New York, NY 10007
