异常挂起后手工解挂2次，channel pipeline状态都显示正常，但实际上channel已经假

调试发现不是EventStore的回滚的问题，是ExtractMemoryArbitrateEvent.java里面发现channel是PAUSE态直接把信号包丢弃掉，没有remove掉MemoryStageController里面相关的processId,

ExtractMemoryArbitrateEvent里面的代码修改如下：

if (status.isStart()) {// 即时查询一下当前的状态，状态随时可能会变 ...... } else { logger.warn("pipelineId[{}] select ignore processId[{}] by status[{}]", new Object[] { pipelineId, processId, status }); // 释放下processId，因为MemoryStageController的load是等待processId最小值完成Tranform才继//续，如果这里不释放，会一直卡死等待 stageController.clearProgress(processId); return await(pipelineId);// 递归调用 } 仅仅stageController.clearProgress(processId); 移除掉processId还是有问题，一是select stage信号量会丢掉1个，二是eventStore里面的get值没有回置。 测试发现把pipeline里面的并发度改成1，卡死的问题会稳定出现。

f512a3f 这个里面，做了一些修改， SelectTask.java里面增加sleep,等待channel变成start态，尽量避免走丢信号量流程。

****MemoryArbitrateEvent.java里面把stageController.clearProgress(processId)调用改成stageController.termin(TerminType.ROLLBACK);

        // 进行ROLLBACK，触发释放下processId，信号量及EventStore里面的读位置点。
        // 1)因为MemoryStageController的load是等待processId最小值完成Tranform才继续，如果这里不释放，会一直卡死等待
        // 2)SELECT信号量消耗完selectTask任务会停止3)EventStore里面的读位置点不回置，如果正好队列已经满并且读取了最后，BINLOG新的数据进不来
        stageController.termin(TerminType.ROLLBACK);

原回答者GitHub用户funnyAnt