Questions about Example_06_DataStream_Join

[liuml07]

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?

[twalthr]

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.