Github user asfgit closed the pull request at:
https://github.com/apache/samza/pull/449
---
Github user asfgit closed the pull request at:
https://github.com/apache/samza/pull/442
---
Well I have my stand-alone application in docker and running in kubernetes. I
think something isn't wired up all the way though, because my task never
actually gets invoked. I see no errors, however I'm not getting the usual
startup logs (checking existing offsets, "entering run loop"...) My log
So, my investigation starts at StreamProcessor.java. Line 294 in method
onNewJobModel() logs an INFO message that it's starting a container. This
message never appears.
I see that ZkJobCoordinator calls onNewJobModel from its onNewJobModelConfirmed
method which also logs an info message stati
It appears it IS hung while serializing the JobModel... very strange! I added
some debug statements around the calls:
LOG.debug("Getting object mapper to serialize job model"); // this IS
printed
ObjectMapper mmapper = SamzaObjectMapper.getObjectMapper();
LOG.debug("Serializin
Hi Thunder,
Can you please take and attach a thread dump with this?
Thanks,
Prateek
On Fri, Mar 16, 2018 at 4:47 PM, Thunder Stumpges
wrote:
> It appears it IS hung while serializing the JobModel... very strange! I
> added some debug statements around the calls:
>
> LOG.debug("Getting ob
Attached. I don't see any threads actually running this code which is odd.
There's my main thread that's waiting for the whole thing to finish, the
"debounce-thread-0" (which logged the other surrounding messages below) has
this:
"debounce-thread-0" #18 daemon prio=5 os_prio=0 tid=0x7fa0fd
please unsubscribe me from this samza list -thx
Also - your advice - please. I am using the instructions:
REQUEST ADDRESSES FOR [UN]SUBSCRIBING
To get off a list, send a message to:
list-unsubscr...@apache.org
so, I send it to samza-unsubscr...@apache.org
and I get a bounce back that it does not
