Hi Matthias, Please find the answers below.
I would recommend to double check the following: > > - can you confirm that the filter does not remove all data for those > time periods? > Filter does not remove all data. There is a lot of data coming in even after the filter stage. > - I would also check input for your AggregatorFunction() -- does it > receive everything? > Yes. Aggregate function seems to be receiving everything. > - same for .mapValues() > I am not sure how to check this.
