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 wrote:
> Hi Jordi,
>
> I think, you need to implement the *InitableTask* inter
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
wrote:
> Just for making it easier to reproduce the problem I ju
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/36006/
---
(Updated Aug. 10, 2015, 6:35 p.m.)
Review request for samza, Yi Pan (Data Infra
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 org.apache.samza.task.Messag
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 mod
---
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: samz
---
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: samz
