Spark Core InBox.scala has error

classic Classic list List threaded Threaded
3 messages Options
Reply | Threaded
Open this post in threaded view
|

Spark Core InBox.scala has error

kaishen
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: [hidden email]

Reply | Threaded
Open this post in threaded view
|

Re:Spark Core InBox.scala has error

Jiaan Geng
Could you show how you hit this error?






At 2019-01-23 09:50:16, "kaishen" <[hidden email]> 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: [hidden email]


Reply | Threaded
Open this post in threaded view
|

Re:Re:Spark Core InBox.scala has error

Jiaan Geng
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,"大啊" <[hidden email]> 写道:
Could you show how you hit this error?






At 2019-01-23 09:50:16, "kaishen" <[hidden email]> 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: [hidden email]