I found what the problem is: I'm attempting to run a ThreadJobFactory for
local testing, and looking at the config for the
wikipedia-application-local-runner sample application and then the Samza
config documentation, I found a footnote stating that "For non-cluster
applications (ones using
Hi Bharath,
I've been looking around in the logs trying to figure out which bits you're
asking for. At the risk of spamming the list, here are some excerpts that I
_think_ meet the criteria:
2020-12-17 17:04:11.455 [main] ZkUtils [INFO] Current version for zk root
node:
Hi Malcolm,
Based on the following log
INFO [org.apache.samza.zk.ZkJobCoordinator] New JobModel does not contain
> pid=a3e86ddf-8d18-40c9-8063-1efd588cec56. Stopping this processor. New
> JobModel: JobModel [..]
>
I'd have to guess that the processor isn't part of the quorum (list of
Hey all,
We have an app that's been running on v0.14.1 for the last few years, and
we're trying to drag it forward into the present with v1.5.1. I've tried a
few different approaches at updating it, including creating a
TaskApplication via the low-level API and also following the "Legacy
