[BEAM-931] Findbugs doesn't pass in Flink runner

• Type: Bug
• Status: Triage Needed
• Priority: P2
• Resolution: Fixed
• Fix Version/s: 0.4.0
• Component/s: runner-flink
• Assignee: Aljoscha Krettek
• Reporter: Dan Halperin
• Created: 07/Nov/16 17:26
• Updated: 19/Sep/24 06:32
• Resolved: 10/Nov/16 10:21

Description

[INFO] --- findbugs-maven-plugin:3.0.1:check (default) @ beam-runners-flink_2.10 ---
[INFO] BugInstance size is 9
[INFO] Error size is 0
[INFO] Total bugs: 9
[INFO] Class org.apache.beam.runners.flink.FlinkRunner$StreamingViewAsMap defines non-transient non-serializable instance field runner [org.apache.beam.runners.flink.FlinkRunner$StreamingViewAsMap] In FlinkRunner.java
[INFO] Class org.apache.beam.runners.flink.FlinkRunner$StreamingViewAsMultimap defines non-transient non-serializable instance field runner [org.apache.beam.runners.flink.FlinkRunner$StreamingViewAsMultimap] In FlinkRunner.java
[INFO] Return value of org.apache.beam.sdk.io.Read$Bounded.getSource() ignored, but method has no side effect [org.apache.beam.runners.flink.translation.FlinkStreamingTransformTranslators$BoundedReadSourceTranslator] At FlinkStreamingTransformTranslators.java:[line 282]
[INFO] Return value of org.apache.beam.sdk.io.Read$Unbounded.getSource() ignored, but method has no side effect [org.apache.beam.runners.flink.translation.FlinkStreamingTransformTranslators$UnboundedReadSourceTranslator] At FlinkStreamingTransformTranslators.java:[line 252]
[INFO] org.apache.beam.runners.flink.translation.wrappers.SerializableFnAggregatorWrapper.clone() does not call super.clone() [org.apache.beam.runners.flink.translation.wrappers.SerializableFnAggregatorWrapper] At SerializableFnAggregatorWrapper.java:[lines 84-89]
[INFO] Class org.apache.beam.runners.flink.translation.wrappers.streaming.WindowDoFnOperator defines non-transient non-serializable instance field stateInternals [org.apache.beam.runners.flink.translation.wrappers.streaming.WindowDoFnOperator] In WindowDoFnOperator.java
[INFO] Class org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSocketSource$UnboundedSocketReader defines non-transient non-serializable instance field reader [org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSocketSource$UnboundedSocketReader] In UnboundedSocketSource.java
[INFO] Class org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSocketSource$UnboundedSocketReader defines non-transient non-serializable instance field socket [org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSocketSource$UnboundedSocketReader] In UnboundedSocketSource.java
[INFO] Unconditional wait in org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper.run(SourceFunction$SourceContext) [org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper] At UnboundedSourceWrapper.java:[line 243]
[INFO]   

Issue Links

• is cloned by: BEAM-932 Findbugs doesn't pass in Spark runner
• links to: GitHub Pull Request #1311