Added assertion
@@ -270,6 +270,8 @@ public class GridCacheDistributedQueryFuture<K, V, R> extends GridCacheQueryFutu
/** {@inheritDoc} */
@Override void clear() {
+ assert isDone() : this;
+
GridCacheDistributedQueryManager<K, V> qryMgr = (GridCacheDistributedQueryManager<K, V>)cctx.queries();
if (qryMgr != null)
