PM
To: dev@samza.apache.org
Subject: Re: Not safe to access KV stores from InitiableTask.init()
Hey Tommy,
This sounds broken. Let me have a look and see if there's an easy fix. I
*think* reordering should work, but I just want to make sure.
Could you open a JIRA and set the fixed version to 0.9.0? I&
Hey Tommy,
This sounds broken. Let me have a look and see if there's an easy fix. I
*think* reordering should work, but I just want to make sure.
Could you open a JIRA and set the fixed version to 0.9.0? I'll take a looks
today/tomorrow. If you want to test out reordering it, please share any
fin
I have need to do some initial processing of the entries in my KV store on
startup before processing messages. I put the code into my task's init()
method, and although it worked with an empty KV store/changelog once I have
entries in there it bombs with a rather obscure exception:
java.util.N
