Trident State Query Problem
2013-12-18 19:41:45 GMT
I have an in memory, Java database that I want to use for my Trident State. My testing consists of running a limited set of data through the topology, and then querying the results through a DRPC stream that performs a Trident state query. When the trident state is in a single executor, the same state query returns the same data every time. When the trident state is in a bolt with multiple executors, I get X different results for the same state query where X is the number of executors containing the trident state. Is there a way to specify which trident state is used for a DRPC query? Is there a way to get the results (and aggregate) from the all of the different trident state instances? I'm going to put together a simple example to run and post it here, soon. -- -- You received this message because you are subscribed to the Google Groups "storm-user" group. To unsubscribe from this group and stop receiving emails from it, send an email to storm-user+unsubscribe@... For more options, visit https://groups.google.com/groups/opt_out.