search

onyx-platform / onyx

Distributed, masterless, high performance, fault tolerant data processing
http://www.onyxplatform.org
Eclipse Public License 1.0
2.05k stars 204 forks source link

function/reduce/output read-batch should use built in state machine idle #841

Open lbradstreet opened 6 years ago

lbradstreet commented 6 years ago

This line should return the state without advancing: https://github.com/onyx-platform/onyx/blob/master/src/onyx/peer/read_batch.clj#L34 allowing the normal state machine idle cycle to take place.