3b73ce3112
This PR removes the blocking call to insert ingest documents into a queue in the coordinator. It replaces it with an offer call which will throw a rejection exception in the event that the queue is full. This prevents deadlocks of the write threads when the queue fills to capacity and there are more than one enrich processors in a pipeline. |
||
---|---|---|
.. | ||
qa | ||
src | ||
build.gradle |