The way I plan on working around it is by first running the ContinuousQuery and then the SqlFieldsQuery, wait for the results from the SqlFieldsQuery (while caching any updates from the ContinuousQuery).
When the SqlFieldsQuery results arrive deal with any duplicates and them proceed with streaming out the snapshot followed by the updates. Or let the downstream system deal with the duplicates since each message has a unique ID and timestamp. -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/
