A Task Allocation Method for Stream Processing with Recovery Latency Guarantee