The window function is called for each partition so if you have two partitions of your Kafka stream, the window function will be called twice.
Lukas From: Lukáš Havrlant Sent: Thursday, November 27, 2014 12:23 AM To: [email protected] Subject: Window method is called twice Hi! We are using Samza 0.7.0 and we've encountered a bug. We have a WindowableTask and the window method is called twice every time (every task.window.ms interval). Code: @Override public void window(MessageCollector collector, TaskCoordinator coordinator) throws Exception { logger.info("tick"); } Log (task.window.ms=1000): 2014-11-27 07:47:27,503 INFO [main] bids.AllBidTask - tick 2014-11-27 07:47:27,503 INFO [main] bids.AllBidTask - tick 2014-11-27 07:47:28,510 INFO [main] bids.AllBidTask - tick 2014-11-27 07:47:28,510 INFO [main] bids.AllBidTask - tick 2014-11-27 07:47:29,517 INFO [main] bids.AllBidTask - tick 2014-11-27 07:47:29,517 INFO [main] bids.AllBidTask - tick 2014-11-27 07:47:30,523 INFO [main] bids.AllBidTask - tick 2014-11-27 07:47:30,524 INFO [main] bids.AllBidTask - tick Property file in attach. Do you please have any idea why this is happening? What can cause it?
