Hi, Jordi,
Agree with Yan. More specifically, your class definition should be
something like:
{code}
public class testStore implements StreamTask, InitableTask {
...
}
{code}
On Mon, Aug 10, 2015 at 6:08 PM, Yan Fang yanfang...@gmail.com wrote:
Hi Jordi,
I think, you need to implement the
Hi Jordi,
I think, you need to implement the *InitableTask* interface. Otherwise, the
content in the init method will not be processed.
Thanks,
Fang, Yan
yanfang...@gmail.com
On Mon, Aug 10, 2015 at 3:24 AM, Jordi Blasi Uribarri jbl...@nextel.es
wrote:
Just for making it easier to reproduce
Hi,
I have migrated samza to the last versión and recreated the job with a new
store name so the streams were created clean. I am getting the same error:
java version 1.7.0_79
OpenJDK Runtime Environment (IcedTea 2.5.6) (7u79-2.5.6-1~deb7u1)
OpenJDK 64-Bit Server VM (build 24.79-b02, mixed
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/36163/
---
(Updated Aug. 10, 2015, 7:47 a.m.)
Review request for samza.
Repository:
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/36163/
---
(Updated Aug. 10, 2015, 7:50 a.m.)
Review request for samza.
Repository:
Just for making it easier to reproduce the problem I just reduced the code of
the job to the minimum:
package test;
import org.apache.samza.config.Config;
import org.apache.samza.storage.kv.KeyValueStore;
import org.apache.samza.system.IncomingMessageEnvelope;
import
