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 these lines there's just the groupByKey and WindowedBy, are there any logics in these two that could stop the flow of data? Since I don't have any window closing mechanism or suppression shouldn't it just go through? Thank you in advance -- Alessandro Tagliapietra
