Re: Upgrading from 0.14 -> 1.5.1

2020-12-18 Thread Malcolm McFarland
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: /app-rpc-runner-1/rpc-runn

Re: Manipulating Starting Offsets for Input Streams

2020-12-18 Thread Lakshmi Manasa
Hi Paul, Similar to CheckpointTool (see Manipulating checkpoints manually) a StartpointTool can be written. The org.apache.samza.checkpoint.CheckpointTool takes in the config.properties and offset.properties as in

Re: Upgrading from 0.14 -> 1.5.1

2020-12-18 Thread Malcolm McFarland
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 coordin