samza-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Lukáš Havrlant <lu...@havrlant.cz>
Subject Window method is called twice
Date Thu, 27 Nov 2014 08:23:19 GMT
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?

Mime
  • Unnamed multipart/mixed (inline, None, 0 bytes)
View raw message