Examine performance impact of batch writing #1658
Labels
kind/toil
Categorizes an issue or PR as general maintenance, i.e. cleanup, refactoring, etc.
scope/broker
Marks an issue or PR to appear in the broker section of the changelog
With #1645 we introduced batch writing on each record write, which means events are copied to an internal buffer and on
#tryWrite
they are written to the dispatcher. On writing single events the performance degrades, because before the change we do not copied the events and write directly to the dispatcher. See as an example theLogStreamWriterImpl
.We should examine if this is on average a real problem.
If so we could fix this with writing to the internal buffer only on second
event()
call and using the references like inLogStreamWriterImpl
for single records.There parts in the code base where this might not work for example
ParallelSplitHandler
orJobBatchActivateProcessor
, which are writing in a loop records with the same reference. They would overwrite each other.The text was updated successfully, but these errors were encountered: