Hi
I have launched 2 task managers each with 2 slots. I have set parallelism 2
for one operator.
This operator should launch in both task managers with 1 slot each.
But it is launching on only 1 task manager.
Is this intended behavior?
Thanks
Pushpendra Jaiswal.
On querying to Queryable State it throws Exception,
Exception
org.apache.flink.runtime.query.UnknownKvStateLocation: No
KvStateLocation found for KvState instance with name 'queryStore'.
at
org.apache.flink.runtime.jobmanager.JobManager.org$apache$flink$runtime$jobmanager$JobManager$$handleKvS
-- Forwarded message --
From: Pushpendra Jaiswal
Date: Wed, Aug 31, 2016 at 3:52 PM
Subject: Not able to query : Queryable State
To: user@flink.apache.org
Hi
I have been trying to use QueryableState with my project.
It's always failing the query saying.