I am updating our jobs to use samza 1.3.0. I'm getting a null pointer when
manually committing via taskCoordinator.commit().
Below is the stack trace - can anyone point me in the right direction?
Thanks.
2020-01-15 10:33:35 RunLoop [ERROR] Task Partition 0 commit failed
java.lang.NullPointerE
Hi Prateek,
Thanks for the feedback, I have updated the SEP with your suggestions.
Please have a look.
Thank you
Sanil
On Mon, 6 Jan 2020 at 10:54, Sanil Jain wrote:
> Hi all,
>
> Refreshing this back to see if there is any further feedback on this SEP.
>
> Thanks
> Sanil
>
> On Thu, 5 Dec 201
Thunder,
I think setting "job.coordinator.system" or "job.default.system" to be the
name of your default system (in configs) solves the problem without code
changes.
Then again, I that its reasonable to expect the default system (set with
"withDefaultSystem(systemDescriptor)") to get picked up wh