java.lang.IllegalStateException: This stub is not part of an iteration step function.

flink-user | Maximilian Alber | 2 years ago
tip
Click on the to mark the solution that helps you, Samebug will learn from it.
As a community member, you’ll be rewarded for you help.
  1. 0

    Re: Forced to use Solution Set in Step Function

    flink-user | 2 years ago | Maximilian Alber
    java.lang.IllegalStateException: This stub is not part of an iteration step function.
  2. 0

    Re: Forced to use Solution Set in Step Function

    flink-user | 2 years ago | Fabian Hueske
    java.lang.IllegalStateException: This stub is not part of an iteration step function.
  3. 0

    Re: Forced to use Solution Set in Step Function

    flink-user | 2 years ago | Aljoscha Krettek
    java.lang.IllegalStateException: This stub is not part of an iteration step function.
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    Re: Forced to use Solution Set in Step Function

    flink-user | 2 years ago | Aljoscha Krettek
    java.lang.IllegalStateException: This stub is not part of an iteration step function.
  6. 0

    java.lang.IllegalStateException: This stub is not part of an iteration step function.

    flink-user | 2 years ago | Maximilian Alber
    java.lang.IllegalStateException: This stub is not part of an iteration step function.

    Root Cause Analysis

    1. java.lang.IllegalStateException

      This stub is not part of an iteration step function.

      at org.apache.flink.api.common.functions.AbstractRichFunction.getIterationRuntimeContext()
    2. flink-core
      AbstractRichFunction.getIterationRuntimeContext
      1. org.apache.flink.api.common.functions.AbstractRichFunction.getIterationRuntimeContext(AbstractRichFunction.java:59)
      1 frame
    3. bumpboost
      BumpBoost$$anonfun$8$$anon$1.filter
      1. bumpboost.BumpBoost$$anonfun$8$$anon$1.filter(BumpBoost.scala:40)
      2. bumpboost.BumpBoost$$anonfun$8$$anon$1.filter(BumpBoost.scala:39)
      2 frames
    4. flink-java
      PlanFilterOperator$FlatMapFilter.flatMap
      1. org.apache.flink.api.java.operators.translation.PlanFilterOperator$FlatMapFilter.flatMap(PlanFilterOperator.java:47)
      1 frame
    5. flink-runtime
      ChainedMapDriver.collect
      1. org.apache.flink.runtime.operators.chaining.ChainedFlatMapDriver.collect(ChainedFlatMapDriver.java:79)
      2. org.apache.flink.runtime.operators.chaining.ChainedMapDriver.collect(ChainedMapDriver.java:78)
      2 frames
    6. org.apache.flink
      UnfinishedJoinOperation$$anon$5.join
      1. org.apache.flink.api.scala.UnfinishedJoinOperation$$anon$5.join(joinDataSet.scala:184)
      1 frame
    7. flink-runtime
      RuntimeEnvironment.run
      1. org.apache.flink.runtime.operators.hash.BuildFirstHashMatchIterator.callWithNextKey(BuildFirstHashMatchIterator.java:140)
      2. org.apache.flink.runtime.operators.MatchDriver.run(MatchDriver.java:148)
      3. org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:484)
      4. org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:359)
      5. org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:235)
      5 frames
    8. Java RT
      Thread.run
      1. java.lang.Thread.run(Thread.java:745)
      1 frame