Parallelism vs task manager allocation

2016-09-20 Thread Pushpendra Jaiswal
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.

Unable to find KvState flink Queryablestate

2016-09-07 Thread 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

Fwd: Not able to query : Queryable State

2016-08-31 Thread Pushpendra Jaiswal
-- 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.