作者: Gaurav D. Ghare , Ying Xiong , John David Dunagan , Marvin Michael Theimer , Gregory M. Burgess
DOI:
关键词:
摘要: A control node of a multi-tenant stream processing service receives request indicating an operation to be performed on data records particular stream. Based partitioning policy, the determines initial number worker nodes used. The configures perform received records. In response determination that is in unhealthy state, replacement node.