Re: Values not being aggregated

2019-09-18 Thread Alessandro Tagliapietra
Thanks a lot Bruno I'll check that! -- Alessandro Tagliapietra On Wed, Sep 18, 2019 at 4:20 PM Bruno Cadonna wrote: > Hi Alessandro, > > If you want to get each update to an aggregate, you need to disable > the cache. Otherwise, an update will only be emitted when the > aggregate is evicted or

Re: Values not being aggregated

2019-09-18 Thread Bruno Cadonna
Hi Alessandro, If you want to get each update to an aggregate, you need to disable the cache. Otherwise, an update will only be emitted when the aggregate is evicted or flushed from the cache. To disable the cache, you can: - disable it with the `Materialized` object - set cache.max.bytes.bufferi

Values not being aggregated

2019-09-16 Thread Alessandro Tagliapietra
Hello everyone, I've this code https://gist.github.com/alex88/719383f38541c5324caf8f47b7239e15 (I've omitted the store setup part) and i've this problem for a specific key. Basically I can see the logs up until the "Pair Stream data". "Aggregate stream data" line is never logger. Since between th