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

flink-user | Fabian Hueske | 2 years ago
  1. 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.
  2. 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.
  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 | Maximilian Alber
    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.

    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.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