Daniel Halperin created BEAM-924:
------------------------------------
Summary: Findbugs doesn't pass in Direct Runner
Key: BEAM-924
URL: https://issues.apache.org/jira/browse/BEAM-924
Project: Beam
Issue Type: Bug
Components: runner-direct
Reporter: Daniel Halperin
Assignee: Thomas Groh
{code}
[INFO] AggregatorContainer$AggregatorInfo.accumulator not guarded against
concurrent access; locked 71% of time
[org.apache.beam.runners.direct.AggregatorContainer$AggregatorInfo,
org.apache.beam.runners.direct.AggregatorContainer$AggregatorInfo,
org.apache.beam.runners.direct.AggregatorContainer$AggregatorInfo,
org.apache.beam.runners.direct.AggregatorContainer$AggregatorInfo,
org.apache.beam.runners.direct.AggregatorContainer$AggregatorInfo,
org.apache.beam.runners.direct.AggregatorContainer$AggregatorInfo,
org.apache.beam.runners.direct.AggregatorContainer$AggregatorInfo,
org.apache.beam.runners.direct.AggregatorContainer$AggregatorInfo,
org.apache.beam.runners.direct.AggregatorContainer$AggregatorInfo,
org.apache.beam.runners.direct.AggregatorContainer$AggregatorInfo,
org.apache.beam.runners.direct.AggregatorContainer$AggregatorInfo,
org.apache.beam.runners.direct.AggregatorContainer$AggregatorInfo,
org.apache.beam.runners.direct.AggregatorContainer$AggregatorInfo]
Unsynchronized access at AggregatorContainer.java:[line 80]Unsynchronized
access at AggregatorContainer.java:[line 79]Unsynchronized access at
AggregatorContainer.java:[line 81]Synchronized access at
AggregatorContainer.java:[line 78]Synchronized access at
AggregatorContainer.java:[line 79]Synchronized access at
AggregatorContainer.java:[line 81]Synchronized access at
AggregatorContainer.java:[line 81]Synchronized access at
AggregatorContainer.java:[line 59]Synchronized access at
AggregatorContainer.java:[line 62]Synchronized access at
AggregatorContainer.java:[line 62]Synchronized access at
AggregatorContainer.java:[line 60]Synchronized access at
AggregatorContainer.java:[line 66]Synchronized access at
AggregatorContainer.java:[line 66]
[INFO] bundle must be non-null but is marked as nullable
[org.apache.beam.runners.direct.ExecutorServiceParallelExecutor] At
ExecutorServiceParallelExecutor.java:[lines 185-186]
[INFO] Exceptional return value of
java.util.concurrent.BlockingQueue.offer(Object) ignored in
org.apache.beam.runners.direct.ExecutorServiceParallelExecutor$MonitorRunnable.run()
[org.apache.beam.runners.direct.ExecutorServiceParallelExecutor$MonitorRunnable]
At ExecutorServiceParallelExecutor.java:[line 412]
[INFO]
org.apache.beam.runners.direct.WatermarkCallbackExecutor$CallbackOrdering
implements Comparator but not Serializable
[org.apache.beam.runners.direct.WatermarkCallbackExecutor$CallbackOrdering] At
WatermarkCallbackExecutor.java:[lines 132-138]
[INFO]
org.apache.beam.runners.direct.WatermarkManager$WindowedValueByTimestampComparator
implements Comparator but not Serializable
[org.apache.beam.runners.direct.WatermarkManager$WindowedValueByTimestampComparator]
At WatermarkManager.java:[lines 1380-1385]
[INFO]
{code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
