beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Daniel Halperin (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (BEAM-925) Findbugs doesn't pass in Dataflow Runner
Date Mon, 07 Nov 2016 17:06:58 GMT

     [ 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)

Mime
View raw message