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?
