The current StreamExecutionEngine implementation uses a lock-based architecture that creates deadlocks and limits scalability. When processing batches, the SimpleProcessor locks the engine for every ...