I have check the method `process` of class `Inbox`. If the message is not null ,will continue treat next message. If the message is null,will exit the process. This logic looks right.
在 2019-01-23 11:35:59，"大啊" <belie...@163.com> 写道： Could you show how you hit this error? At 2019-01-23 09:50:16, "kaishen" <kill4...@163.com> wrote: >Inbox.scala, line 158: > message = messages.poll() >if the message is not null, then it will be lost and never be executed. >Please help to verify this bug! > > > > >-- >Sent from: http://apache-spark-user-list.1001560.n3.nabble.com/ > >--------------------------------------------------------------------- >To unsubscribe e-mail: user-unsubscr...@spark.apache.org 【网易自营|30天无忧退货】真性价比：网易员工用纸“无添加谷风一木软抽面巾纸”，限时仅16.9元一提>>
