Skip to content

Instantly share code, notes, and snippets.

@robinkraft
Created April 23, 2013 23:49
Show Gist options
  • Save robinkraft/5448436 to your computer and use it in GitHub Desktop.
Save robinkraft/5448436 to your computer and use it in GitHub Desktop.
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?pubdate', '?url', '?eml', '?dwca', '?title', '?icode', '?description', '?contact', '?orgname', '?email', '?rights-extra', '?icode-extra', '?count', '?id', '?associatedmedia', '?associatedoccurrences', '?associatedreferences', '?associatedsequences', '?associatedtaxa', '?basisofrecord', '?bed', '?behavior', '?catalognumber', '?collectioncode', '?collectionid', '?continent', '?coordinateprecision', '?coordinateuncertaintyinmeters', '?country', '?countrycode', '?county', '?datageneralizations', '?dateidentified', '?day', '?decimallatitude', '?decimallongitude', '?disposition', '?earliestageorloweststage', '?earliesteonorlowesteonothem', '?earliestepochorlowestseries', '?earliesteraorlowesterathem', '?earliestperiodorlowestsystem', '?enddayofyear', '?establishmentmeans', '?eventattributes', '?eventdate', '?eventid', '?eventremarks', '?eventtime', '?fieldnotes', '?fieldnumber', '?footprintspatialfit', '?footprintwkt', '?formation', '?geodeticdatum', '?geologicalcontextid', '?georeferenceprotocol', '?georeferenceremarks', '?georeferencesources', '?georeferenceverificationstatus', '?georeferencedby', '?group', '?habitat', '?highergeography', '?highergeographyid', '?highestbiostratigraphiczone', '?identificationattributes', '?identificationid', '?identificationqualifier', '?identificationreferences', '?identificationremarks', '?identifiedby', '?individualcount', '?individualid', '?informationwithheld', '?institutioncode', '?island', '?islandgroup', '?latestageorhigheststage', '?latesteonorhighesteonothem', '?latestepochorhighestseries', '?latesteraorhighesterathem', '?latestperiodorhighestsystem', '?lifestage', '?lithostratigraphicterms', '?locality', '?locationattributes', '?locationid', '?locationremarks', '?lowestbiostratigraphiczone', '?maximumdepthinmeters', '?maximumdistanceabovesurfaceinmeters', '?maximumelevationinmeters', '?measurementaccuracy', '?measurementdeterminedby', '?measurementdetermineddate', '?measurementid', '?measurementmethod', '?measurementremarks', '?measurementtype', '?measurementunit', '?measurementvalue', '?member', '?minimumdepthinmeters', '?minimumdistanceabovesurfaceinmeters', '?minimumelevationinmeters', '?month', '?occurrenceattributes', '?occurrencedetails', '?occurrenceid', '?occurrenceremarks', '?othercatalognumbers', '?pointradiusspatialfit', '?preparations', '?previousidentifications', '?recordnumber', '?recordedby', '?relatedresourceid', '?relationshipaccordingto', '?relationshipestablisheddate', '?relationshipofresource', '?relationshipremarks', '?reproductivecondition', '?resourceid', '?resourcerelationshipid', '?samplingprotocol', '?sex', '?startdayofyear', '?stateprovince', '?taxonattributes', '?typestatus', '?verbatimcoordinatesystem', '?verbatimcoordinates', '?verbatimdepth', '?verbatimelevation', '?verbatimeventdate', '?verbatimlatitude', '?verbatimlocality', '?verbatimlongitude', '?waterbody', '?year', '?footprintsrs', '?georeferenceddate', '?identificationverificationstatus', '?institutionid', '?locationaccordingto', '?municipality', '?occurrencestatus', '?ownerinstitutioncode', '?samplingeffort', '?verbatimsrs', '?locationaccordingto7', '?taxonid', '?taxonconceptid', '?datasetid', '?datasetname', '?source', '?modified', '?accessrights', '?rights', '?rightsholder', '?language', '?higherclassification', '?kingdom', '?phylum', '?classs', '?order', '?family', '?genus', '?subgenus', '?specificepithet', '?infraspecificepithet', '?scientificname', '?scientificnameid', '?vernacularname', '?taxonrank', '?verbatimtaxonrank', '?infraspecificmarker', '?scientificnameauthorship', '?nomenclaturalcode', '?namepublishedin', '?namepublishedinid', '?taxonomicstatus', '?nomenclaturalstatus', '?nameaccordingto', '?nameaccordingtoid', '?parentnameusageid', '?parentnameusage', '?originalnameusageid', '?originalnameusage', '?acceptednameusageid', '?acceptednameusage', '?taxonremarks', '?dynamicproperties', '?namepublishedinyear', '?dummy'], got result size: 7
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82)
at cascalog.ClojureMap.operate(Unknown Source)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:73)
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:34)
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86)
at cascading.operation.Identity$2.operate(Identity.java:131)
at cascading.operation.Identity.operate(Identity.java:144)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:441)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:377)
at org.apache.hadoop.mapred.Child$4.run(Child.java:255)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.Subject.doAs(Subject.java:396)
at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1059)
at org.apache.hadoop.mapred.Child.main(Child.java:249)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment