Github user dawidwys commented on the issue:
https://github.com/apache/flink/pull/5516
Hi @BillLeecn
Thank you for the contribution!
Would you mind adding guard against null messages as well? Other than that
it looks good.---
Github user dawidwys commented on the issue:
https://github.com/apache/flink/pull/5516
Hi @BillLeecn
Thank you for the contribution!
Would you mind adding guard against null messages as well? Other than that
it looks good.---