Hi, I've developed a distributed scheduler which adds adaptation capabilities to the system. I'm able to define new assignments in a distributed manner and the system automatically synchronize itself, launching or terminating worker processes as defined by the assignments.
I'm having some troubles since, sometimes, the reassigned bolts (maybe even spouts) seem not to emit tuples, even if on the destination node the supervisor has read new assignments and had launched the new worker process. Can someone give me any hint? Thanks in advance
