cascading.tuple.TupleException: unable to read from input identifier: file:/home/cs/workspace/workspace-hadoop/hadoop-cascading-lingual-hello-world/output.tsv

Google Groups | Christian Schuhegger | 3 years ago
  1. 0

    Lingual in Java with Cascading works with CSV files but not with TSV files?

    Google Groups | 3 years ago | Christian Schuhegger
    cascading.tuple.TupleException: unable to read from input identifier: file:/home/cs/workspace/workspace-hadoop/hadoop-cascading-lingual-hello-world/output.tsv
  2. 0

    Issues with DCFIF and LZO

    Google Groups | 2 years ago | Unknown author
    cascading.tuple.TupleException: unable to read from input identifier: 'unknown'
  3. Speed up your debug routine!

    Automated exception search integrated into your IDE

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

      did not parse correct number of values from input data, expected: 2, got: 1:A 152

      at cascading.scheme.util.DelimitedParser.onlyParseLine()
    2. cascading.scheme.util
      DelimitedParser.parseLine
      1. cascading.scheme.util.DelimitedParser.onlyParseLine(DelimitedParser.java:404)
      2. cascading.scheme.util.DelimitedParser.parseLine(DelimitedParser.java:341)
      2 frames
    3. cascading.scheme.hadoop
      TextDelimited.source
      1. cascading.scheme.hadoop.TextDelimited.source(TextDelimited.java:1006)
      1 frame
    4. cascading.tuple
      TupleEntrySchemeIterator.hasNext
      1. cascading.tuple.TupleEntrySchemeIterator.getNext(TupleEntrySchemeIterator.java:140)
      2. cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:120)
      2 frames
    5. cascading.flow.stream
      SourceStage.run
      1. cascading.flow.stream.SourceStage.map(SourceStage.java:76)
      2. cascading.flow.stream.SourceStage.run(SourceStage.java:58)
      2 frames
    6. cascading.flow.hadoop
      FlowMapper.run
      1. cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
      1 frame
    7. Hadoop
      LocalJobRunner$Job$MapTaskRunnable.run
      1. org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:429)
      2. org.apache.hadoop.mapred.MapTask.run(MapTask.java:341)
      3. org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:235)
      3 frames
    8. Java RT
      Thread.run
      1. java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
      2. java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:334)
      3. java.util.concurrent.FutureTask.run(FutureTask.java:166)
      4. java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
      5. java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
      6. java.lang.Thread.run(Thread.java:724)
      6 frames