[
https://issues.apache.org/jira/browse/BEAM-925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Halperin updated BEAM-925:
---------------------------------
Assignee: Davor Bonaci (was: Thomas Groh)
> Findbugs doesn't pass in Dataflow Runner
> ----------------------------------------
>
> Key: BEAM-925
> URL: https://issues.apache.org/jira/browse/BEAM-925
> Project: Beam
> Issue Type: Bug
> Components: runner-dataflow
> Reporter: Daniel Halperin
> Assignee: Davor Bonaci
>
> {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)
