Sam Whittle created BEAM-11727:
----------------------------------
Summary: Optimize ExecutionStateTracker
Key: BEAM-11727
URL: https://issues.apache.org/jira/browse/BEAM-11727
Project: Beam
Issue Type: Bug
Components: runner-dataflow
Reporter: Sam Whittle
Showed up as 1.5% of CPU on Nexmark 11 streaming benchmark run.
It appears to be using a ConcurrentSkipListSet and most of the cpu is relatedd
to inserts/removes in that, involving the system hash of the entries as that is
used for ordering.
The consistent ordering is unnecessary. Additionally for other reasons, removal
and iteration is already synchronized and so performance will likely be better
just using a synchronized HashMap and synchronizing in the add case.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)