Netflix / suro

Netflix's distributed Data Pipeline
Apache License 2.0
794 stars 170 forks source link

QueuedSink checkPause() is blocking SuroInput too long #176

Closed metacret closed 9 years ago

metacret commented 9 years ago

The purpose of checkPause(), setPause() are preventing internal queue growing too long. We observed SuroInput waited too long even though there was no pending messages in the queue. We need adjust this behavior not to block too long.

metacret commented 9 years ago

178