Extended WorkerApi timeout
Fixed TopK aggregator
Updated to Scala 2.10
Workaround for aggregation bug when using futures.