Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-931

Findbugs doesn't pass in Flink runner

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • P2
    • Resolution: Fixed
    • None
    • 0.4.0
    • runner-flink
    • None

    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]   
      

      Attachments

        Issue Links

          Activity

            People

              aljoscha Aljoscha Krettek
              dhalperi Dan Halperin
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: