java.io.IOException: java.lang.IllegalStateException: not yet initialized: only setHandler is allowed in GraphStageLogic constructor

GitHub | halfninja | 4 months ago
  1. 0

    GitHub comment 21504#248384587

    GitHub | 4 months ago | halfninja
    java.io.IOException: java.lang.IllegalStateException: not yet initialized: only setHandler is allowed in GraphStageLogic constructor
  2. 0
    Download the winutils.exe for your Hadoop version: https://github.com/steveloughran/winutils . Save it to HADOOP_HOME/bin
  3. 0
    Bad input data (not properly separated)
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0
    If you are using maven you'd like to exclude your binaries from filtering process.
  6. 0
    Check for bad records in the input data (like '(null)')

    Not finding the right solution?
    Take a tour to get the most out of Samebug.

    Tired of useless tips?

    Automated exception search integrated into your IDE

    Root Cause Analysis

    1. java.io.IOException

      java.lang.IllegalStateException: not yet initialized: only setHandler is allowed in GraphStageLogic constructor

      at akka.stream.impl.io.OutputStreamAdapter$$anonfun$sendMessage$1.apply$mcV$sp()
    2. akka.stream.impl
      OutputStreamAdapter.flush
      1. akka.stream.impl.io.OutputStreamAdapter$$anonfun$sendMessage$1.apply$mcV$sp(OutputStreamSourceStage.scala:201)
      2. akka.stream.impl.io.OutputStreamAdapter.send(OutputStreamSourceStage.scala:172)
      3. akka.stream.impl.io.OutputStreamAdapter.sendMessage(OutputStreamSourceStage.scala:191)
      4. akka.stream.impl.io.OutputStreamAdapter.flush(OutputStreamSourceStage.scala:215)
      4 frames
    3. akka.stream.io
      OutputStreamSourceSpec$$anonfun$2$$anonfun$apply$mcV$sp$4$$anonfun$apply$4$$anonfun$10.apply
      1. akka.stream.io.OutputStreamSourceSpec$$anonfun$2$$anonfun$apply$mcV$sp$4$$anonfun$apply$4$$anonfun$10.apply(OutputStreamSourceSpec.scala:72)
      2. akka.stream.io.OutputStreamSourceSpec$$anonfun$2$$anonfun$apply$mcV$sp$4$$anonfun$apply$4$$anonfun$10.apply(OutputStreamSourceSpec.scala:68)
      2 frames
    4. akka.stream.impl
      ActorMaterializerImpl.materialize
      1. akka.stream.impl.MaterializerSession.resolveMaterialized(StreamLayout.scala:959)
      2. akka.stream.impl.MaterializerSession.resolveMaterialized(StreamLayout.scala:958)
      3. akka.stream.impl.MaterializerSession.materializeModule(StreamLayout.scala:936)
      4. akka.stream.impl.MaterializerSession.materialize(StreamLayout.scala:882)
      5. akka.stream.impl.ActorMaterializerImpl.materialize(ActorMaterializerImpl.scala:240)
      6. akka.stream.impl.ActorMaterializerImpl.materialize(ActorMaterializerImpl.scala:138)
      6 frames
    5. akka.stream.scaladsl
      Source.runReduce
      1. akka.stream.scaladsl.RunnableGraph.run(Flow.scala:350)
      2. akka.stream.scaladsl.Source.runWith(Source.scala:81)
      3. akka.stream.scaladsl.Source.runReduce(Source.scala:117)
      3 frames
    6. akka.stream.io
      OutputStreamSourceSpec$$anonfun$2$$anonfun$apply$mcV$sp$4$$anonfun$apply$4.apply
      1. akka.stream.io.OutputStreamSourceSpec$$anonfun$2$$anonfun$apply$mcV$sp$4$$anonfun$apply$4.apply(OutputStreamSourceSpec.scala:76)
      2. akka.stream.io.OutputStreamSourceSpec$$anonfun$2$$anonfun$apply$mcV$sp$4$$anonfun$apply$4.apply(OutputStreamSourceSpec.scala:67)
      2 frames
    7. akka.stream.testkit
      Utils$.assertAllStagesStopped
      1. akka.stream.testkit.Utils$.assertAllStagesStopped(Utils.scala:25)
      1 frame
    8. akka.stream.io
      OutputStreamSourceSpec$$anonfun$2$$anonfun$apply$mcV$sp$4.apply
      1. akka.stream.io.OutputStreamSourceSpec$$anonfun$2$$anonfun$apply$mcV$sp$4.apply(OutputStreamSourceSpec.scala:67)
      2. akka.stream.io.OutputStreamSourceSpec$$anonfun$2$$anonfun$apply$mcV$sp$4.apply(OutputStreamSourceSpec.scala:67)
      2 frames
    9. scalatest
      OutcomeOf$class.outcomeOf
      1. org.scalatest.OutcomeOf$class.outcomeOf(OutcomeOf.scala:85)
      1 frame