[jira] [Commented] (SAMZA-842) Job does not quit when task shutdown is requested (when using ThreadJobFactory)

["Artur Biesiadowski (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/SAMZA-842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15346087#comment-15346087 ] 

Artur Biesiadowski commented on SAMZA-842:
------------------------------------------

I have same issue (samza-0.10). Culprit seems to be RMI Reaper thread (it is only non-deamon thread in application left after shutdown). 

"RMI Reaper" #37 prio=5 os_prio=0 tid=0x000000001fef9800 nid=0xf2c in Object.wait() [0x000000002816e000]
   java.lang.Thread.State: WAITING (on object monitor)
	at java.lang.Object.wait(Native Method)
	- waiting on <0x00000006c2347f38> (a java.lang.ref.ReferenceQueue$Lock)
	at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:143)
	- locked <0x00000006c2347f38> (a java.lang.ref.ReferenceQueue$Lock)
	at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:164)
	at sun.rmi.transport.ObjectTable$Reaper.run(ObjectTable.java:351)
	at java.lang.Thread.run(Thread.java:745)



> Job does not quit when task shutdown is requested (when using ThreadJobFactory)
> -------------------------------------------------------------------------------
>
>                 Key: SAMZA-842
>                 URL: https://issues.apache.org/jira/browse/SAMZA-842
>             Project: Samza
>          Issue Type: Bug
>    Affects Versions: 0.10.0
>            Reporter: Kishore Nallan
>
> I have just started to try out Samza 0.10 by using the SNAPSHOT version on Apache repository and I'm running into a shutdown issue for a job which works fine on 0.9.1. 
> This is the job: https://gist.github.com/kishorenc/89eb18276c51b1478a18
> I have not tried it yet on YARN, but when thread factory is used (for local development), this job just hangs without quitting even when a `taskCoordinator.shutdown(RequestScope.CURRENT_TASK)` is issued.
> I have also included the jstack dump on the gist.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)