cascading.flow.FlowException: local step failed

GitHub | prinzemathew | 2 years ago
tip
Do you know that we can give you better hits? Get more relevant results from Samebug’s stack trace search.

Root Cause Analysis

  1. java.lang.NoSuchMethodError

    org.dmg.pmml.DataField.getOptype()Lorg/dmg/pmml/OpType;

    at org.jpmml.evaluator.ArgumentUtil.isOutlier()
  2. org.jpmml.evaluator
    EvaluatorUtil.prepare
    1. org.jpmml.evaluator.ArgumentUtil.isOutlier(ArgumentUtil.java:153)
    2. org.jpmml.evaluator.ArgumentUtil.prepare(ArgumentUtil.java:69)
    3. org.jpmml.evaluator.ModelEvaluator.prepare(ModelEvaluator.java:78)
    4. org.jpmml.evaluator.EvaluatorUtil.prepare(EvaluatorUtil.java:120)
    4 frames
  3. org.jpmml.cascading
    PMMLFunction.operate
    1. org.jpmml.cascading.PMMLFunction.decodeArguments(PMMLFunction.java:88)
    2. org.jpmml.cascading.PMMLFunction.operate(PMMLFunction.java:54)
    2 frames
  4. cascading.flow.stream
    FunctionEachStage$1.collect
    1. cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
    2. cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
    3. cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
    3 frames
  5. cascading.tuple
    TupleEntryCollector.add
    1. cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
    2. cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
    2 frames
  6. cascading.operation
    Identity.operate
    1. cascading.operation.Identity$2.operate(Identity.java:137)
    2. cascading.operation.Identity.operate(Identity.java:150)
    2 frames
  7. cascading.flow.stream
    SourceStage.run
    1. cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
    2. cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
    3. cascading.flow.stream.SourceStage.map(SourceStage.java:102)
    4. cascading.flow.stream.SourceStage.run(SourceStage.java:58)
    4 frames
  8. cascading.flow.hadoop
    FlowMapper.run
    1. cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
    1 frame
  9. Hadoop
    LocalJobRunner$Job$MapTaskRunnable.run
    1. org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:450)
    2. org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
    3. org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
    3 frames
  10. Java RT
    Thread.run
    1. java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
    2. java.util.concurrent.FutureTask.run(FutureTask.java:262)
    3. java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
    4. java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
    5. java.lang.Thread.run(Thread.java:745)
    5 frames