Hi, we are working in a funded project on adaptive data stream processing where we use Storm as a basis. Among other runtime changes to the data processing, we faced the problem that we cannot modify the parallelization of Bolts/Spouts or their execution location at runtime. As the rebalance command of Storm is too slow for our purposes, we developed a proof-of-concept implementation, which allows us to perform the needed changes (less than 50 ms initial experiments).
Now, we wondered whether this could be interesting for the Storm community, and Nathan suggested to just post the current state on the dev list in order to get into contact. Looking forward to read from you. Cheers, Holger
