Has anyone ever faced similar or related issue ?
2014-06-03 19:33 GMT+09:00 Romain Leroux leroux@gmail.com:
I have a simple trident transactional topology that does something like
the following:
kafka transactional spout (~3000 rec/sec, 6 partitions thus paraHint=6)
--
aggregate with
I have a simple trident transactional topology that does something like the
following:
kafka transactional spout (~3000 rec/sec, 6 partitions thus paraHint=6) --
aggregate with reducerAggregator (paraHint=20) --
transactional state (I tried MemoryMapState, MemcachedMapState and
CassandraMapState)
