Windowed aggregation issue - Batch