cascading.cascade.CascadeException: flow failed: select data from dual into keyvalue

Google Groups | PaulON | 1 year ago
  1. 0

    Problems using HiveFlow

    Google Groups | 1 year ago | PaulON
    cascading.cascade.CascadeException: flow failed: select data from dual into keyvalue
  2. 0

    Cascading 3.0 wip 117

    Google Groups | 2 years ago | Chris K Wensel
    cascading.CascadingException: unable to compare stream elements in position: 0 at cascading.tuple.hadoop.util.DeserializerComparator.compareTuples(DeserializerComparator.java:164) at cascading.tuple.hadoop.util.TupleComparator.compare(TupleComparator.java:38) org.apache.tez.runtime.library.common.sort.impl.PipelinedSorter$SortSpan.compareKeys(PipelinedSorter.java:669) at org.apache.tez.runtime.library.common.sort.impl.PipelinedSorter$SortSpan.compare(PipelinedSorter.java:684) at org.apache.hadoop.util.QuickSort.sortInternal(QuickSort.java:99) org.apache.hadoop.util.QuickSort.sort(QuickSort.java:63) at org.apache.tez.runtime.library.common.sort.impl.PipelinedSorter$SortSpan.sort(PipelinedSorter.java:631) at org.apache.tez.runtime.library.common.sort.impl.PipelinedSorter.sort(PipelinedSorter.java:230) org.apache.tez.runtime.library.common.sort.impl.PipelinedSorter.collect(PipelinedSorter.java:311) at org.apache.tez.runtime.library.common.sort.impl.PipelinedSorter.write(PipelinedSorter.java:272) at org.apache.tez.runtime.library.output.OrderedPartitionedKVOutput$1.write(OrderedPartitionedKVOutput.java:164) cascading.flow.tez.stream.element.OldOutputCollector.collect(OldOutputCollector.java:51) at cascading.tap.hadoop.util.MeasuredOutputCollector.collect(MeasuredOutputCollector.java:69) at cascading.flow.tez.stream.element.TezCoGroupGate.wrapGroupingAndCollect(TezCoGroupGate.java:193) cascading.flow.hadoop.stream.HadoopGroupGate.receive(HadoopGroupGate.java:103) at cascading.flow.hadoop.stream.HadoopGroupGate.receive(HadoopGroupGate.java:45) at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81) cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145) at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133) at com.twitter.scalding.FlatMapFunction$$anonfun$operate$2.apply(Operations.scala:49) com.twitter.scalding.FlatMapFunction$$anonfun$operate$2.apply(Operations.scala:47) at scala.collection.Iterator$class.foreach(Iterator.scala:750) at scala.collection.AbstractIterator.foreach(Iterator.scala:1202) com.twitter.scalding.FlatMapFunction.operate(Operations.scala:47) at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100) at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40) cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81) at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145) at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133) com.twitter.scalding.MapFunction.operate(Operations.scala:60) at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100) at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40) cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81) at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145) at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133) cascading.operation.Identity$1.operate(Identity.java:124) at cascading.operation.Identity.operate(Identity.java:150) at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100) cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40) at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110) at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66) cascading.flow.tez.stream.element.TezSourceStage.run(TezSourceStage.java:95) at cascading.flow.tez.FlowProcessor.run(FlowProcessor.java:165) at org.apache.tez.runtime.LogicalIOProcessorRuntimeTask.run(LogicalIOProcessorRuntimeTask.java:337) org.apache.tez.runtime.task.TezTaskRunner$TaskRunnerCallable$1.run(TezTaskRunner.java:179) at org.apache.tez.runtime.task.TezTaskRunner$TaskRunnerCallable$1.run(TezTaskRunner.java:171) at java.security.AccessController.doPrivileged(Native Method)
  3. 0

    GitHub comment 2#71985074

    GitHub | 2 years ago | nikolovivan
    cascading.tuple.TupleException: unable to read from input identifier: 'unknown'
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    Staying Sane While Working With Avro In Scalding | Jana Technology

    jana.com | 9 months ago
    java.lang.Exception: cascading.CascadingException: unable to compare stream elements in position: 0
  6. 0

    Cascading 3.0 wip 117

    Google Groups | 2 years ago | Chris K Wensel
    cascading.CascadingException: java.io.EOFException at cascading.tuple.hadoop.util.TupleComparator.compare(TupleComparator.java:42) at org.apache.tez.runtime.library.common.sort.impl.PipelinedSorter$SortSpan.compareKeys(PipelinedSorter.java:669) org.apache.tez.runtime.library.common.sort.impl.PipelinedSorter$SortSpan.compare(PipelinedSorter.java:684) at org.apache.hadoop.util.QuickSort.sortInternal(QuickSort.java:99)

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

      hive error 'FAILED: Execution Error, return code 2 from org.apache.hadoop.hive.ql.exec.mr.MapRedTask' while running query insert overwrite table keyvalue select 'Hello' as key, 'hive!' as value from dual

      at cascading.flow.hive.HiveQueryRunner.run()
    2. cascading.flow.hive
      HiveQueryRunner.call
      1. cascading.flow.hive.HiveQueryRunner.run(HiveQueryRunner.java:131)
      2. cascading.flow.hive.HiveQueryRunner.call(HiveQueryRunner.java:167)
      3. cascading.flow.hive.HiveQueryRunner.call(HiveQueryRunner.java:41)
      3 frames
    3. Java RT
      Thread.run
      1. java.util.concurrent.FutureTask.run(FutureTask.java:262)
      2. java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
      3. java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
      4. java.lang.Thread.run(Thread.java:745)
      4 frames