flink-api-examples icon indicating copy to clipboard operation
flink-api-examples copied to clipboard
verified publisher icon twalthr

Questions about Example_06_DataStream_Join

Open liuml07 opened this issue 3 years ago • 1 comments

  1. The processElement1() method should check if (txs.hasNext())? See code
  2. Should we add timer (clear state, log warning etc) in the two processElement methods, in case the other stream is never ready?

liuml07 avatar Apr 18 '22 05:04 liuml07

  1. This is indeed a bug. I will fix it in my next iteration. Thanks for pointing it out!
  2. Yes, there is more code required to make this production ready.

twalthr avatar Apr 19 '22 07:04 twalthr