a new record object from the new
process(filter) that contains the config retrieved from the broadcast
stream along with the transactions and passing that down the pipeline but
that is really not desirable.
Any ideas on what might be going on here?
Thanks!
Roger
@Override
> public long extractTimestamp(T element, long previousElementTimestamp) {
> return 0;
> }
> }
>
>
> By setting the watermark for this stream to MAX_WATERMARK, you are
> effectively removing this stream's watermarks from consideration.
>
&
Confirmed. This worked!
Thanks!
Roger
On Fri, Mar 5, 2021 at 12:41 PM Roger wrote:
> Hey David.
> Thank you very much for your response. This is making sense now. It was
> confusing because I was able to use the Broadcast stream prior to adding
> the second stream. However, now I
