Hi, Shekar, Could you attach the complete config file here? It would be hard just to debug through snippets from your configure file.
Thanks! -Yi On Wed, Jul 1, 2015 at 5:59 PM, Shekar Tippur <ctip...@gmail.com> wrote: > Sorry, after re-reading the docs, > > https://samza.apache.org/learn/documentation/0.8/jobs/configuration-table.html#stores-key-serde > > I have changed it to > > # Define serde > > > stores.store.factory=org.apache.samza.storage.kv.RocksDbKeyValueStorageEngineFactory > > stores.store.key.serde=byte > > stores.store.msg.serde=string > > stores.store.changelog=kafka.argos-parser > > Is this correct? I am still getting the same exception. > > - Shekar > > > > On Wed, Jul 1, 2015 at 5:37 PM, Shekar Tippur <ctip...@gmail.com> wrote: > > > I do have this in init as well... > > > > public void init(Config config, TaskContext context) { > > > > store = (KeyValueStore<String, Integer>) context.getStore("store"); > > > > } > > You are right. These are primitive types but I was trying to address this > > exception: > > > > Exception in thread "main" org.apache.samza.SamzaException: Must define a > > key serde when using key value storage. > > > > I have changed it to > > > > stores.store.key.serde=org.apache.samza.serializers.ByteSerdeFactory > > > > Regardless, exception is persisting. > > > > - Shekar > > >
