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)

Reply via email to