Last active
December 11, 2015 18:28
-
-
Save ceteri/4641263 to your computer and use it in GitHub Desktop.
City of Palo Alto Open Data app in Cascalog
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
bash-3.2$ lein version | |
Leiningen 2.0.0-preview10 on Java 1.6.0_43 Java HotSpot(TM) 64-Bit Server VM | |
bash-3.2$ hadoop version | |
Warning: $HADOOP_HOME is deprecated. | |
Hadoop 1.0.3 | |
Subversion https://svn.apache.org/repos/asf/hadoop/common/branches/branch-1.0 -r 1335192 | |
Compiled by hortonfo on Tue May 8 20:31:25 UTC 2012 | |
From source with checksum e6b0c1e23dcf76907c5fecb4b832f3be | |
bash-3.2$ lein clean | |
bash-3.2$ lein uberjar | |
Compiling copa.core | |
Compiling copa.core | |
Created /Users/ceteri/src/concur/CoPA/target/cascading-copa-0.1.0-SNAPSHOT.jar | |
Including cascading-copa-0.1.0-SNAPSHOT.jar | |
Including cascalog-more-taps-0.3.1-SNAPSHOT.jar | |
Including slf4j-log4j12-1.6.1.jar | |
Including reflectasm-1.07-shaded.jar | |
Including cascading-core-2.0.0.jar | |
Including cascading-hadoop-2.0.0.jar | |
Including clojure-csv-2.0.0-alpha2.jar | |
Including clojure-1.4.0.jar | |
Including objenesis-1.2.jar | |
Including geohash-1.0.1.jar | |
Including meat-locker-0.3.1.jar | |
Including carbonite-1.3.1.jar | |
Including kryo-2.17.jar | |
Including tools.macro-0.1.1.jar | |
Including tools.logging-0.2.3.jar | |
Including minlog-1.2.jar | |
Including date-clj-1.0.1.jar | |
Including jgrapht-jdk1.6-0.8.1.jar | |
Including log4j-1.2.16.jar | |
Including jackknife-0.1.2.jar | |
Including hadoop-util-0.2.8.jar | |
Including cascalog-1.10.1-SNAPSHOT.jar | |
Including riffle-0.1-dev.jar | |
Including asm-4.0.jar | |
Including maple-0.2.2.jar | |
Including cascading.kryo-0.4.5.jar | |
Including slf4j-api-1.6.1.jar | |
Created /Users/ceteri/src/concur/CoPA/target/copa.jar | |
bash-3.2$ rm -rf out | |
bash-3.2$ | |
bash-3.2$ hadoop jar ./target/copa.jar data/copa.csv data/meta_tree.tsv data/meta_road.tsv data/gps.csv \ | |
> out/trap out/park out/tree out/road out/shade out/gps out/reco | |
... | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 30 Street_Name: South... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 10 Street_Name: South... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 10 Street_Name: Starr... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 30 Street_Name: Starr... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 30 Street_Name: Stell... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 10 Street_Name: Stern... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 10 Street_Name: Stern... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 10 Street_Name: Suzan... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 10 Street_Name: Talis... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 10 Street_Name: Talis... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 10 Street_Name: Talis... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 50 Street_Name: Tasso... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 40 Street_Name: Tasso... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 60 Street_Name: Tasso... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 60 Street_Name: Tasso... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 10 Street_Name: Terma... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 10 Street_Name: Terma... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 10 Street_Name: Terma... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 10 Street_Name: Thain... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 10 Street_Name: Thain... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 10 Street_Name: Timlo... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 10 Street_Name: Torre... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 300 Street_Name: Univ... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 290 Street_Name: Univ... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 270 Street_Name: Univ... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 10 Street_Name: Unive... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 10 Street_Name: Unive... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 10 Street_Name: Unive... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 280 Street_Name: Univ... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 11 Street_Name: Unive... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 10 Street_Name: Unive... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 10 Street_Name: Unive... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 10 Street_Name: Unive... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 10 Street_Name: Unive... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 10 Street_Name: Unive... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 10 Street_Name: Unive... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 20 Street_Name: Urban... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 20 Street_Name: Urban... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 10 Street_Name: Urban... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 10 Street_Name: Verno... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 20 Street_Name: Verno... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 20 Street_Name: Vista... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 20 Street_Name: Vista... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 10 Street_Name: Vista... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 320 Street_Name: Wave... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 170 Street_Name: Wave... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 180 Street_Name: Wave... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 300 Street_Name: Wave... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 300 Street_Name: Wave... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 310 Street_Name: Wave... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 190 Street_Name: Wave... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 210 Street_Name: Wave... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 210 Street_Name: Wave... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 200 Street_Name: Wave... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 170 Street_Name: Webs... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 160 Street_Name: Webs... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 150 Street_Name: Webs... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 180 Street_Name: Webs... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 140 Street_Name: Webs... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 190 Street_Name: Webs... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 10 Street_Name: Wells... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 10 Street_Name: Whitc... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 WARN stream.TrapHandler: exception trap on branch: '28978a9b-3dcf-4f4e-bf3b-da7d4affacd9', for fields: [{1}:'?misc'] tuple: [' Sequence: 10 Street_Name: Ynigo... | |
cascading.tuple.TupleException: operation added the wrong number of fields, expected: ['?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type', '?overlay_year_str', '?bike_lane', '?bus_route', '?truck_route'], got result size: 0 | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:82) | |
at cascalog.ClojureMap.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascalog.ops.KryoInsert.operate(Unknown Source) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:60) | |
at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:33) | |
at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:67) | |
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93) | |
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:86) | |
at cascading.operation.Identity.operate(Identity.java:110) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:86) | |
at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:38) | |
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:124) | |
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436) | |
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372) | |
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212) | |
13/04/11 13:49:12 INFO io.TapOutputCollector: closing tap collector for: out/trap/road/part-m-00001-00000 | |
13/04/11 13:49:12 INFO util.Hadoop18TapUtil: committing task: 'attempt_local_0003_m_000000_0' - file:/Users/ceteri/src/concur/CoPA/out/trap/road/_temporary/_attempt_local_0003_m_000000_0 | |
13/04/11 13:49:12 INFO util.Hadoop18TapUtil: saved output of task 'attempt_local_0003_m_000000_0' to file:/Users/ceteri/src/concur/CoPA/out/trap/road | |
13/04/11 13:49:12 INFO mapred.MapTask: Starting flush of map output | |
13/04/11 13:49:12 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:12 INFO mapred.MapTask: Finished spill 0 | |
13/04/11 13:49:12 INFO mapred.Task: Task:attempt_local_0003_m_000000_0 is done. And is in the process of commiting | |
13/04/11 13:49:13 INFO mapred.LocalJobRunner: file:/Users/ceteri/src/concur/CoPA/out/gis/part-00000:0+8825889 | |
13/04/11 13:49:13 INFO mapred.Task: Task 'attempt_local_0003_m_000000_0' done. | |
13/04/11 13:49:13 INFO mapred.Task: Using ResourceCalculatorPlugin : null | |
13/04/11 13:49:13 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:13 INFO io.MultiInputSplit: current split input path: file:/Users/ceteri/src/concur/CoPA/data/meta_road.tsv | |
13/04/11 13:49:13 INFO mapred.MapTask: numReduceTasks: 1 | |
13/04/11 13:49:13 INFO mapred.MapTask: io.sort.mb = 100 | |
13/04/11 13:49:13 INFO mapred.MapTask: data buffer = 79691776/99614720 | |
13/04/11 13:49:13 INFO mapred.MapTask: record buffer = 262144/327680 | |
13/04/11 13:49:13 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:13 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:13 INFO hadoop.FlowMapper: sourcing from: Hfs["TextDelimited[['!__gen19', '!__gen20', '!__gen21']]"]["data/meta_road.tsv"]"] | |
13/04/11 13:49:13 INFO hadoop.FlowMapper: sinking to: CoGroup(8d6dd53d-66e8-45f4-a0b5-47332c745e37*1fcf4dab-6c0f-4b34-a383-8adc4b20a0db)[by:8d6dd53d-66e8-45f4-a0b5-47332c745e37:[{1}:'?surface_type']1fcf4dab-6c0f-4b34-a383-8adc4b20a0db:[{1}:'?surface_type']] | |
13/04/11 13:49:13 INFO hadoop.FlowMapper: trapping to: Hfs["TextLine[['line']->[ALL]]"]["out/trap/road"]"] | |
13/04/11 13:49:13 INFO mapred.MapTask: Starting flush of map output | |
13/04/11 13:49:13 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:13 INFO mapred.MapTask: Finished spill 0 | |
13/04/11 13:49:13 INFO mapred.Task: Task:attempt_local_0003_m_000001_0 is done. And is in the process of commiting | |
13/04/11 13:49:16 INFO mapred.LocalJobRunner: file:/Users/ceteri/src/concur/CoPA/data/meta_road.tsv:0+99 | |
13/04/11 13:49:16 INFO mapred.Task: Task 'attempt_local_0003_m_000001_0' done. | |
13/04/11 13:49:16 INFO mapred.Task: Using ResourceCalculatorPlugin : null | |
13/04/11 13:49:16 INFO mapred.LocalJobRunner: | |
13/04/11 13:49:16 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:16 INFO mapred.Merger: Merging 2 sorted segments | |
13/04/11 13:49:16 INFO mapred.Merger: Down to the last merge-pass, with 2 segments left of total size: 2809735 bytes | |
13/04/11 13:49:16 INFO mapred.LocalJobRunner: | |
13/04/11 13:49:16 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:16 INFO hadoop.FlowReducer: sourcing from: CoGroup(8d6dd53d-66e8-45f4-a0b5-47332c745e37*1fcf4dab-6c0f-4b34-a383-8adc4b20a0db)[by:8d6dd53d-66e8-45f4-a0b5-47332c745e37:[{1}:'?surface_type']1fcf4dab-6c0f-4b34-a383-8adc4b20a0db:[{1}:'?surface_type']] | |
13/04/11 13:49:16 INFO hadoop.FlowReducer: sinking to: TempHfs["SequenceFile[['?paving_width', '?paving_length', '?truck_route', '?surface_type', '?bike_lane', '?bus_route', '?road_name', '?traffic_count', '?paving_area', '?traffic_index', '?traffic_class', '?albedo', '!__gen25', '!__gen26', '!__gen27']]"][28978a9b-3dcf-4f4e-bf3b-d/93243/] | |
13/04/11 13:49:16 INFO hadoop.FlowReducer: trapping to: Hfs["TextLine[['line']->[ALL]]"]["out/trap/road"]"] | |
13/04/11 13:49:16 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:16 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:16 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:16 INFO collect.SpillableTupleList: attempting to load codec: org.apache.hadoop.io.compress.GzipCodec | |
13/04/11 13:49:16 INFO collect.SpillableTupleList: found codec: org.apache.hadoop.io.compress.GzipCodec | |
13/04/11 13:49:16 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:16 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:17 INFO mapred.Task: Task:attempt_local_0003_r_000000_0 is done. And is in the process of commiting | |
13/04/11 13:49:17 INFO mapred.LocalJobRunner: | |
13/04/11 13:49:17 INFO mapred.Task: Task attempt_local_0003_r_000000_0 is allowed to commit now | |
13/04/11 13:49:17 INFO mapred.FileOutputCommitter: Saved output of task 'attempt_local_0003_r_000000_0' to file:/tmp/hadoop-ceteri/28978a9b_3dcf_4f4e_bf3b_d_93243_45C8EE9EC29CD6561D084EC9E404846D | |
13/04/11 13:49:19 INFO mapred.LocalJobRunner: reduce > reduce | |
13/04/11 13:49:19 INFO mapred.Task: Task 'attempt_local_0003_r_000000_0' done. | |
13/04/11 13:49:19 INFO flow.FlowStep: [parse road data] starting step: (2/2) out/road | |
13/04/11 13:49:19 INFO mapred.FileInputFormat: Total input paths to process : 1 | |
13/04/11 13:49:19 INFO flow.FlowStep: [parse road data] submitted hadoop job: job_local_0004 | |
13/04/11 13:49:19 INFO mapred.Task: Using ResourceCalculatorPlugin : null | |
13/04/11 13:49:19 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:19 INFO io.MultiInputSplit: current split input path: file:/tmp/hadoop-ceteri/28978a9b_3dcf_4f4e_bf3b_d_93243_45C8EE9EC29CD6561D084EC9E404846D/part-00000 | |
13/04/11 13:49:19 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:19 INFO mapred.MapTask: numReduceTasks: 1 | |
13/04/11 13:49:19 INFO mapred.MapTask: io.sort.mb = 100 | |
13/04/11 13:49:19 INFO mapred.MapTask: data buffer = 79691776/99614720 | |
13/04/11 13:49:19 INFO mapred.MapTask: record buffer = 262144/327680 | |
13/04/11 13:49:19 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:19 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:19 INFO hadoop.FlowMapper: sourcing from: TempHfs["SequenceFile[['?paving_width', '?paving_length', '?truck_route', '?surface_type', '?bike_lane', '?bus_route', '?road_name', '?traffic_count', '?paving_area', '?traffic_index', '?traffic_class', '?albedo', '!__gen25', '!__gen26', '!__gen27']]"][28978a9b-3dcf-4f4e-bf3b-d/93243/] | |
13/04/11 13:49:19 INFO hadoop.FlowMapper: sinking to: GroupBy(28978a9b-3dcf-4f4e-bf3b-da7d4affacd9)[by:[{12}:'?paving_width', '?paving_length', '?truck_route', '?surface_type', '?bike_lane', '?bus_route', '?road_name', '?traffic_count', '?paving_area', '?traffic_index', '?traffic_class', '?albedo']] | |
13/04/11 13:49:19 INFO mapred.MapTask: Starting flush of map output | |
13/04/11 13:49:19 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:19 INFO mapred.MapTask: Finished spill 0 | |
13/04/11 13:49:19 INFO mapred.Task: Task:attempt_local_0004_m_000000_0 is done. And is in the process of commiting | |
13/04/11 13:49:22 INFO mapred.LocalJobRunner: file:/tmp/hadoop-ceteri/28978a9b_3dcf_4f4e_bf3b_d_93243_45C8EE9EC29CD6561D084EC9E404846D/part-00000:0+397071 | |
13/04/11 13:49:22 INFO mapred.Task: Task 'attempt_local_0004_m_000000_0' done. | |
13/04/11 13:49:22 INFO mapred.Task: Using ResourceCalculatorPlugin : null | |
13/04/11 13:49:22 INFO mapred.LocalJobRunner: | |
13/04/11 13:49:22 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:22 INFO mapred.Merger: Merging 1 sorted segments | |
13/04/11 13:49:22 INFO mapred.Merger: Down to the last merge-pass, with 1 segments left of total size: 406225 bytes | |
13/04/11 13:49:22 INFO mapred.LocalJobRunner: | |
13/04/11 13:49:22 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:22 INFO hadoop.FlowReducer: sourcing from: GroupBy(28978a9b-3dcf-4f4e-bf3b-da7d4affacd9)[by:[{12}:'?paving_width', '?paving_length', '?truck_route', '?surface_type', '?bike_lane', '?bus_route', '?road_name', '?traffic_count', '?paving_area', '?traffic_index', '?traffic_class', '?albedo']] | |
13/04/11 13:49:22 INFO hadoop.FlowReducer: sinking to: Hfs["TextDelimited[[UNKNOWN]->['?road_name', '?bike_lane', '?bus_route', '?truck_route', '?albedo', '?road_lat', '?road_lng', '?road_alt', '?geohash', '?traffic_count', '?traffic_index', '?traffic_class', '?paving_length', '?paving_width', '?paving_area', '?surface_type']]"]["out/road"]"] | |
13/04/11 13:49:22 INFO hadoop.FlowReducer: trapping to: Hfs["TextLine[['line']->[ALL]]"]["out/trap/road"]"] | |
13/04/11 13:49:22 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:22 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:22 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:23 INFO mapred.Task: Task:attempt_local_0004_r_000000_0 is done. And is in the process of commiting | |
13/04/11 13:49:23 INFO mapred.LocalJobRunner: | |
13/04/11 13:49:23 INFO mapred.Task: Task attempt_local_0004_r_000000_0 is allowed to commit now | |
13/04/11 13:49:23 INFO mapred.FileOutputCommitter: Saved output of task 'attempt_local_0004_r_000000_0' to file:/Users/ceteri/src/concur/CoPA/out/road | |
13/04/11 13:49:25 INFO mapred.LocalJobRunner: reduce > reduce | |
13/04/11 13:49:25 INFO mapred.Task: Task 'attempt_local_0004_r_000000_0' done. | |
13/04/11 13:49:25 INFO util.Hadoop18TapUtil: deleting temp path out/trap/road/_temporary | |
13/04/11 13:49:25 INFO util.Hadoop18TapUtil: deleting temp path out/trap/road/_temporary | |
13/04/11 13:49:25 INFO util.Hadoop18TapUtil: deleting temp path out/road/_temporary | |
13/04/11 13:49:25 INFO util.Hadoop18TapUtil: deleting temp path out/trap/road/_temporary | |
13/04/11 13:49:25 INFO util.HadoopUtil: resolving application jar from found main method on: copa.core | |
13/04/11 13:49:25 INFO planner.HadoopPlanner: using application jar: /Users/ceteri/src/concur/CoPA/./target/copa.jar | |
13/04/11 13:49:25 INFO flow.Flow: [parse parks data] starting | |
13/04/11 13:49:25 INFO flow.Flow: [parse parks data] source: Hfs["SequenceFile[[UNKNOWN]->[ALL]]"]["out/gis"]"] | |
13/04/11 13:49:25 INFO flow.Flow: [parse parks data] sink: Hfs["TextDelimited[[UNKNOWN]->['?blurb', '?misc', '?geo', '?kind']]"]["out/park"]"] | |
13/04/11 13:49:25 INFO flow.Flow: [parse parks data] parallel execution is enabled: false | |
13/04/11 13:49:25 INFO flow.Flow: [parse parks data] starting jobs: 1 | |
13/04/11 13:49:25 INFO flow.Flow: [parse parks data] allocating threads: 1 | |
13/04/11 13:49:25 INFO flow.FlowStep: [parse parks data] starting step: (1/1) out/park | |
13/04/11 13:49:25 INFO mapred.FileInputFormat: Total input paths to process : 1 | |
13/04/11 13:49:25 INFO flow.FlowStep: [parse parks data] submitted hadoop job: job_local_0005 | |
13/04/11 13:49:25 INFO mapred.Task: Using ResourceCalculatorPlugin : null | |
13/04/11 13:49:25 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:25 INFO io.MultiInputSplit: current split input path: file:/Users/ceteri/src/concur/CoPA/out/gis/part-00000 | |
13/04/11 13:49:25 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:25 INFO mapred.MapTask: numReduceTasks: 0 | |
13/04/11 13:49:25 INFO hadoop.FlowMapper: sourcing from: Hfs["SequenceFile[[UNKNOWN]->[ALL]]"]["out/gis"]"] | |
13/04/11 13:49:25 INFO hadoop.FlowMapper: sinking to: Hfs["TextDelimited[[UNKNOWN]->['?blurb', '?misc', '?geo', '?kind']]"]["out/park"]"] | |
13/04/11 13:49:25 INFO mapred.Task: Task:attempt_local_0005_m_000000_0 is done. And is in the process of commiting | |
13/04/11 13:49:25 INFO mapred.LocalJobRunner: | |
13/04/11 13:49:25 INFO mapred.Task: Task attempt_local_0005_m_000000_0 is allowed to commit now | |
13/04/11 13:49:25 INFO mapred.FileOutputCommitter: Saved output of task 'attempt_local_0005_m_000000_0' to file:/Users/ceteri/src/concur/CoPA/out/park | |
13/04/11 13:49:28 INFO mapred.LocalJobRunner: file:/Users/ceteri/src/concur/CoPA/out/gis/part-00000:0+8825889 | |
13/04/11 13:49:28 INFO mapred.Task: Task 'attempt_local_0005_m_000000_0' done. | |
13/04/11 13:49:28 INFO util.Hadoop18TapUtil: deleting temp path out/park/_temporary | |
13/04/11 13:49:28 INFO util.HadoopUtil: resolving application jar from found main method on: copa.core | |
13/04/11 13:49:28 INFO planner.HadoopPlanner: using application jar: /Users/ceteri/src/concur/CoPA/./target/copa.jar | |
13/04/11 13:49:28 INFO flow.Flow: [calculate shades] starting | |
13/04/11 13:49:28 INFO flow.Flow: [calculate shades] source: Hfs["TextDelimited[['!__gen43', '!__gen44', '!__gen45', '!__gen46', '!__gen47', '!__gen48', '!__gen49', '!__gen50', '!__gen51', '!__gen52', '!__gen53', '!__gen54', '!__gen55', '!__gen56', '!__gen57', '!__gen58']]"]["out/road"]"] | |
13/04/11 13:49:28 INFO flow.Flow: [calculate shades] source: Hfs["TextDelimited[['!__gen31', '!__gen32', '!__gen33', '!__gen34', '!__gen35', '!__gen36', '!__gen37', '!__gen38', '!__gen39', '!__gen40', '!__gen41', '!__gen42']]"]["out/tree"]"] | |
13/04/11 13:49:28 INFO flow.Flow: [calculate shades] sink: Hfs["TextDelimited[[UNKNOWN]->['?road_name', '?geohash', '?road_lat', '?road_lng', '?road_alt', '?road_metric', '?tree_metric']]"]["out/shade"]"] | |
13/04/11 13:49:28 INFO flow.Flow: [calculate shades] parallel execution is enabled: false | |
13/04/11 13:49:28 INFO flow.Flow: [calculate shades] starting jobs: 2 | |
13/04/11 13:49:28 INFO flow.Flow: [calculate shades] allocating threads: 1 | |
13/04/11 13:49:28 INFO flow.FlowStep: [calculate shades] starting step: (1/2) | |
13/04/11 13:49:28 INFO mapred.FileInputFormat: Total input paths to process : 1 | |
13/04/11 13:49:28 INFO mapred.FileInputFormat: Total input paths to process : 1 | |
13/04/11 13:49:28 INFO flow.FlowStep: [calculate shades] submitted hadoop job: job_local_0006 | |
13/04/11 13:49:28 INFO mapred.Task: Using ResourceCalculatorPlugin : null | |
13/04/11 13:49:28 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:28 INFO io.MultiInputSplit: current split input path: file:/Users/ceteri/src/concur/CoPA/out/tree/part-00000 | |
13/04/11 13:49:28 INFO mapred.MapTask: numReduceTasks: 1 | |
13/04/11 13:49:28 INFO mapred.MapTask: io.sort.mb = 100 | |
13/04/11 13:49:29 INFO mapred.MapTask: data buffer = 79691776/99614720 | |
13/04/11 13:49:29 INFO mapred.MapTask: record buffer = 262144/327680 | |
13/04/11 13:49:29 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:29 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:29 INFO hadoop.FlowMapper: sourcing from: Hfs["TextDelimited[['!__gen31', '!__gen32', '!__gen33', '!__gen34', '!__gen35', '!__gen36', '!__gen37', '!__gen38', '!__gen39', '!__gen40', '!__gen41', '!__gen42']]"]["out/tree"]"] | |
13/04/11 13:49:29 INFO hadoop.FlowMapper: sinking to: CoGroup(59469cf7-42df-4baa-bc4e-d8a255d78573*0061e2ed-6a3b-4a73-b71c-8e897ec72840)[by:59469cf7-42df-4baa-bc4e-d8a255d78573:[{1}:'?geohash']0061e2ed-6a3b-4a73-b71c-8e897ec72840:[{1}:'?geohash']] | |
13/04/11 13:49:29 INFO mapred.MapTask: Starting flush of map output | |
13/04/11 13:49:29 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:29 INFO mapred.MapTask: Finished spill 0 | |
13/04/11 13:49:29 INFO mapred.Task: Task:attempt_local_0006_m_000000_0 is done. And is in the process of commiting | |
13/04/11 13:49:31 INFO mapred.LocalJobRunner: file:/Users/ceteri/src/concur/CoPA/out/tree/part-00000:0+393733 | |
13/04/11 13:49:31 INFO mapred.Task: Task 'attempt_local_0006_m_000000_0' done. | |
13/04/11 13:49:31 INFO mapred.Task: Using ResourceCalculatorPlugin : null | |
13/04/11 13:49:31 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:31 INFO io.MultiInputSplit: current split input path: file:/Users/ceteri/src/concur/CoPA/out/road/part-00000 | |
13/04/11 13:49:31 INFO mapred.MapTask: numReduceTasks: 1 | |
13/04/11 13:49:31 INFO mapred.MapTask: io.sort.mb = 100 | |
13/04/11 13:49:32 INFO mapred.MapTask: data buffer = 79691776/99614720 | |
13/04/11 13:49:32 INFO mapred.MapTask: record buffer = 262144/327680 | |
13/04/11 13:49:32 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:32 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:32 INFO hadoop.FlowMapper: sourcing from: Hfs["TextDelimited[['!__gen43', '!__gen44', '!__gen45', '!__gen46', '!__gen47', '!__gen48', '!__gen49', '!__gen50', '!__gen51', '!__gen52', '!__gen53', '!__gen54', '!__gen55', '!__gen56', '!__gen57', '!__gen58']]"]["out/road"]"] | |
13/04/11 13:49:32 INFO hadoop.FlowMapper: sinking to: CoGroup(59469cf7-42df-4baa-bc4e-d8a255d78573*0061e2ed-6a3b-4a73-b71c-8e897ec72840)[by:59469cf7-42df-4baa-bc4e-d8a255d78573:[{1}:'?geohash']0061e2ed-6a3b-4a73-b71c-8e897ec72840:[{1}:'?geohash']] | |
13/04/11 13:49:32 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:32 INFO mapred.MapTask: Starting flush of map output | |
13/04/11 13:49:32 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:32 INFO mapred.MapTask: Finished spill 0 | |
13/04/11 13:49:32 INFO mapred.Task: Task:attempt_local_0006_m_000001_0 is done. And is in the process of commiting | |
13/04/11 13:49:34 INFO mapred.LocalJobRunner: file:/Users/ceteri/src/concur/CoPA/out/road/part-00000:0+331764 | |
13/04/11 13:49:34 INFO mapred.Task: Task 'attempt_local_0006_m_000001_0' done. | |
13/04/11 13:49:34 INFO mapred.Task: Using ResourceCalculatorPlugin : null | |
13/04/11 13:49:34 INFO mapred.LocalJobRunner: | |
13/04/11 13:49:34 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:34 INFO mapred.Merger: Merging 2 sorted segments | |
13/04/11 13:49:34 INFO mapred.Merger: Down to the last merge-pass, with 2 segments left of total size: 380518 bytes | |
13/04/11 13:49:34 INFO mapred.LocalJobRunner: | |
13/04/11 13:49:34 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:34 INFO hadoop.FlowReducer: sourcing from: CoGroup(59469cf7-42df-4baa-bc4e-d8a255d78573*0061e2ed-6a3b-4a73-b71c-8e897ec72840)[by:59469cf7-42df-4baa-bc4e-d8a255d78573:[{1}:'?geohash']0061e2ed-6a3b-4a73-b71c-8e897ec72840:[{1}:'?geohash']] | |
13/04/11 13:49:34 INFO hadoop.FlowReducer: sinking to: TempHfs["SequenceFile[['?geohash', '?road_lng', '?road_alt', '?road_name', '?road_metric', '?road_lat', '!__gen63']]"][6b44820c-53ba-46d9-8231-7/54740/] | |
13/04/11 13:49:34 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:34 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:34 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:35 INFO collect.SpillableTupleList: attempting to load codec: org.apache.hadoop.io.compress.GzipCodec | |
13/04/11 13:49:35 INFO collect.SpillableTupleList: found codec: org.apache.hadoop.io.compress.GzipCodec | |
13/04/11 13:49:35 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:35 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:35 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:35 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:35 INFO mapred.Task: Task:attempt_local_0006_r_000000_0 is done. And is in the process of commiting | |
13/04/11 13:49:35 INFO mapred.LocalJobRunner: | |
13/04/11 13:49:35 INFO mapred.Task: Task attempt_local_0006_r_000000_0 is allowed to commit now | |
13/04/11 13:49:35 INFO mapred.FileOutputCommitter: Saved output of task 'attempt_local_0006_r_000000_0' to file:/tmp/hadoop-ceteri/6b44820c_53ba_46d9_8231_7_54740_BD2B3C3AAE29D78C43A9D2CFA3F7CEAF | |
13/04/11 13:49:37 INFO mapred.LocalJobRunner: reduce > reduce | |
13/04/11 13:49:37 INFO mapred.Task: Task 'attempt_local_0006_r_000000_0' done. | |
13/04/11 13:49:38 INFO flow.FlowStep: [calculate shades] starting step: (2/2) out/shade | |
13/04/11 13:49:38 INFO mapred.FileInputFormat: Total input paths to process : 1 | |
13/04/11 13:49:38 INFO flow.FlowStep: [calculate shades] submitted hadoop job: job_local_0007 | |
13/04/11 13:49:38 INFO mapred.Task: Using ResourceCalculatorPlugin : null | |
13/04/11 13:49:38 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:38 INFO io.MultiInputSplit: current split input path: file:/tmp/hadoop-ceteri/6b44820c_53ba_46d9_8231_7_54740_BD2B3C3AAE29D78C43A9D2CFA3F7CEAF/part-00000 | |
13/04/11 13:49:38 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:38 INFO mapred.MapTask: numReduceTasks: 1 | |
13/04/11 13:49:38 INFO mapred.MapTask: io.sort.mb = 100 | |
13/04/11 13:49:38 INFO mapred.MapTask: data buffer = 79691776/99614720 | |
13/04/11 13:49:38 INFO mapred.MapTask: record buffer = 262144/327680 | |
13/04/11 13:49:38 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:38 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:38 INFO hadoop.FlowMapper: sourcing from: TempHfs["SequenceFile[['?geohash', '?road_lng', '?road_alt', '?road_name', '?road_metric', '?road_lat', '!__gen63']]"][6b44820c-53ba-46d9-8231-7/54740/] | |
13/04/11 13:49:38 INFO hadoop.FlowMapper: sinking to: GroupBy(6b44820c-53ba-46d9-8231-70a66089a334)[by:[{6}:'?geohash', '?road_lng', '?road_alt', '?road_name', '?road_metric', '?road_lat']] | |
13/04/11 13:49:38 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:38 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:38 INFO mapred.MapTask: Starting flush of map output | |
13/04/11 13:49:38 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:38 INFO mapred.MapTask: Finished spill 0 | |
13/04/11 13:49:38 INFO mapred.Task: Task:attempt_local_0007_m_000000_0 is done. And is in the process of commiting | |
13/04/11 13:49:41 INFO mapred.LocalJobRunner: file:/tmp/hadoop-ceteri/6b44820c_53ba_46d9_8231_7_54740_BD2B3C3AAE29D78C43A9D2CFA3F7CEAF/part-00000:0+261072 | |
13/04/11 13:49:41 INFO mapred.Task: Task 'attempt_local_0007_m_000000_0' done. | |
13/04/11 13:49:41 INFO mapred.Task: Using ResourceCalculatorPlugin : null | |
13/04/11 13:49:41 INFO mapred.LocalJobRunner: | |
13/04/11 13:49:41 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:41 INFO mapred.Merger: Merging 1 sorted segments | |
13/04/11 13:49:41 INFO mapred.Merger: Down to the last merge-pass, with 1 segments left of total size: 260009 bytes | |
13/04/11 13:49:41 INFO mapred.LocalJobRunner: | |
13/04/11 13:49:41 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:41 INFO hadoop.FlowReducer: sourcing from: GroupBy(6b44820c-53ba-46d9-8231-70a66089a334)[by:[{6}:'?geohash', '?road_lng', '?road_alt', '?road_name', '?road_metric', '?road_lat']] | |
13/04/11 13:49:41 INFO hadoop.FlowReducer: sinking to: Hfs["TextDelimited[[UNKNOWN]->['?road_name', '?geohash', '?road_lat', '?road_lng', '?road_alt', '?road_metric', '?tree_metric']]"]["out/shade"]"] | |
13/04/11 13:49:41 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:41 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:41 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:41 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:41 INFO mapred.Task: Task:attempt_local_0007_r_000000_0 is done. And is in the process of commiting | |
13/04/11 13:49:41 INFO mapred.LocalJobRunner: | |
13/04/11 13:49:41 INFO mapred.Task: Task attempt_local_0007_r_000000_0 is allowed to commit now | |
13/04/11 13:49:41 INFO mapred.FileOutputCommitter: Saved output of task 'attempt_local_0007_r_000000_0' to file:/Users/ceteri/src/concur/CoPA/out/shade | |
13/04/11 13:49:44 INFO mapred.LocalJobRunner: reduce > reduce | |
13/04/11 13:49:44 INFO mapred.Task: Task 'attempt_local_0007_r_000000_0' done. | |
13/04/11 13:49:44 INFO util.Hadoop18TapUtil: deleting temp path out/shade/_temporary | |
13/04/11 13:49:44 INFO util.HadoopUtil: resolving application jar from found main method on: copa.core | |
13/04/11 13:49:44 INFO planner.HadoopPlanner: using application jar: /Users/ceteri/src/concur/CoPA/./target/copa.jar | |
13/04/11 13:49:44 INFO flow.Flow: [parse gps data] starting | |
13/04/11 13:49:44 INFO flow.Flow: [parse gps data] source: Hfs["TextDelimited[['!__gen66', '!__gen67', '!__gen68', '!__gen69', '!__gen70', '!__gen71', '!__gen72', '!__gen73', '!__gen74']]"]["data/gps.csv"]"] | |
13/04/11 13:49:44 INFO flow.Flow: [parse gps data] sink: Hfs["TextDelimited[[UNKNOWN]->['?uuid', '?geohash', '?gps_count', '?recent_visit']]"]["out/gps"]"] | |
13/04/11 13:49:44 INFO flow.Flow: [parse gps data] parallel execution is enabled: false | |
13/04/11 13:49:44 INFO flow.Flow: [parse gps data] starting jobs: 1 | |
13/04/11 13:49:44 INFO flow.Flow: [parse gps data] allocating threads: 1 | |
13/04/11 13:49:44 INFO flow.FlowStep: [parse gps data] starting step: (1/1) out/gps | |
13/04/11 13:49:44 INFO mapred.FileInputFormat: Total input paths to process : 1 | |
13/04/11 13:49:44 INFO flow.FlowStep: [parse gps data] submitted hadoop job: job_local_0008 | |
13/04/11 13:49:44 INFO mapred.Task: Using ResourceCalculatorPlugin : null | |
13/04/11 13:49:44 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:44 INFO io.MultiInputSplit: current split input path: file:/Users/ceteri/src/concur/CoPA/data/gps.csv | |
13/04/11 13:49:44 INFO mapred.MapTask: numReduceTasks: 1 | |
13/04/11 13:49:44 INFO mapred.MapTask: io.sort.mb = 100 | |
13/04/11 13:49:44 INFO mapred.MapTask: data buffer = 79691776/99614720 | |
13/04/11 13:49:44 INFO mapred.MapTask: record buffer = 262144/327680 | |
13/04/11 13:49:44 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:44 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:44 INFO hadoop.FlowMapper: sourcing from: Hfs["TextDelimited[['!__gen66', '!__gen67', '!__gen68', '!__gen69', '!__gen70', '!__gen71', '!__gen72', '!__gen73', '!__gen74']]"]["data/gps.csv"]"] | |
13/04/11 13:49:44 INFO hadoop.FlowMapper: sinking to: GroupBy(faed3e3f-d022-4f21-945e-b014c5af68c6)[by:[{2}:'?geohash', '?uuid']] | |
13/04/11 13:49:44 INFO mapred.MapTask: Starting flush of map output | |
13/04/11 13:49:44 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:44 INFO mapred.MapTask: Finished spill 0 | |
13/04/11 13:49:44 INFO mapred.Task: Task:attempt_local_0008_m_000000_0 is done. And is in the process of commiting | |
13/04/11 13:49:47 INFO mapred.LocalJobRunner: file:/Users/ceteri/src/concur/CoPA/data/gps.csv:0+27991 | |
13/04/11 13:49:47 INFO mapred.Task: Task 'attempt_local_0008_m_000000_0' done. | |
13/04/11 13:49:47 INFO mapred.Task: Using ResourceCalculatorPlugin : null | |
13/04/11 13:49:47 INFO mapred.LocalJobRunner: | |
13/04/11 13:49:47 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:47 INFO mapred.Merger: Merging 1 sorted segments | |
13/04/11 13:49:47 INFO mapred.Merger: Down to the last merge-pass, with 1 segments left of total size: 770 bytes | |
13/04/11 13:49:47 INFO mapred.LocalJobRunner: | |
13/04/11 13:49:47 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:47 INFO hadoop.FlowReducer: sourcing from: GroupBy(faed3e3f-d022-4f21-945e-b014c5af68c6)[by:[{2}:'?geohash', '?uuid']] | |
13/04/11 13:49:47 INFO hadoop.FlowReducer: sinking to: Hfs["TextDelimited[[UNKNOWN]->['?uuid', '?geohash', '?gps_count', '?recent_visit']]"]["out/gps"]"] | |
13/04/11 13:49:47 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:47 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:47 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:47 INFO mapred.Task: Task:attempt_local_0008_r_000000_0 is done. And is in the process of commiting | |
13/04/11 13:49:47 INFO mapred.LocalJobRunner: | |
13/04/11 13:49:47 INFO mapred.Task: Task attempt_local_0008_r_000000_0 is allowed to commit now | |
13/04/11 13:49:47 INFO mapred.FileOutputCommitter: Saved output of task 'attempt_local_0008_r_000000_0' to file:/Users/ceteri/src/concur/CoPA/out/gps | |
13/04/11 13:49:50 INFO mapred.LocalJobRunner: reduce > reduce | |
13/04/11 13:49:50 INFO mapred.Task: Task 'attempt_local_0008_r_000000_0' done. | |
13/04/11 13:49:50 INFO util.Hadoop18TapUtil: deleting temp path out/gps/_temporary | |
13/04/11 13:49:50 INFO util.HadoopUtil: resolving application jar from found main method on: copa.core | |
13/04/11 13:49:50 INFO planner.HadoopPlanner: using application jar: /Users/ceteri/src/concur/CoPA/./target/copa.jar | |
13/04/11 13:49:50 INFO flow.Flow: [recommend road segments] starting | |
13/04/11 13:49:50 INFO flow.Flow: [recommend road segments] source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["out/shade"]"] | |
13/04/11 13:49:50 INFO flow.Flow: [recommend road segments] source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["out/gps"]"] | |
13/04/11 13:49:50 INFO flow.Flow: [recommend road segments] sink: Hfs["TextDelimited[[UNKNOWN]->['?uuid', '?road', '?geohash', '?lat', '?lng', '?alt', '?gps_count', '?recent_visit', '?road_metric', '?tree_metric']]"]["out/reco"]"] | |
13/04/11 13:49:50 INFO flow.Flow: [recommend road segments] parallel execution is enabled: false | |
13/04/11 13:49:50 INFO flow.Flow: [recommend road segments] starting jobs: 1 | |
13/04/11 13:49:50 INFO flow.Flow: [recommend road segments] allocating threads: 1 | |
13/04/11 13:49:50 INFO flow.FlowStep: [recommend road segments] starting step: (1/1) out/reco | |
13/04/11 13:49:50 INFO mapred.FileInputFormat: Total input paths to process : 1 | |
13/04/11 13:49:50 INFO mapred.FileInputFormat: Total input paths to process : 1 | |
13/04/11 13:49:50 INFO flow.FlowStep: [recommend road segments] submitted hadoop job: job_local_0009 | |
13/04/11 13:49:50 INFO mapred.Task: Using ResourceCalculatorPlugin : null | |
13/04/11 13:49:50 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:50 INFO io.MultiInputSplit: current split input path: file:/Users/ceteri/src/concur/CoPA/out/shade/part-00000 | |
13/04/11 13:49:50 INFO mapred.MapTask: numReduceTasks: 1 | |
13/04/11 13:49:50 INFO mapred.MapTask: io.sort.mb = 100 | |
13/04/11 13:49:50 INFO mapred.MapTask: data buffer = 79691776/99614720 | |
13/04/11 13:49:50 INFO mapred.MapTask: record buffer = 262144/327680 | |
13/04/11 13:49:50 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:50 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:50 INFO hadoop.FlowMapper: sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["out/shade"]"] | |
13/04/11 13:49:50 INFO hadoop.FlowMapper: sinking to: CoGroup(83ffbe69-6ac4-455b-ba95-a64fb6ee8b3c*5825731c-a689-44be-9ff1-770d1133c59b)[by:83ffbe69-6ac4-455b-ba95-a64fb6ee8b3c:[{1}:'?geohash']5825731c-a689-44be-9ff1-770d1133c59b:[{1}:'?geohash']] | |
13/04/11 13:49:50 INFO mapred.MapTask: Starting flush of map output | |
13/04/11 13:49:50 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:50 INFO mapred.MapTask: Finished spill 0 | |
13/04/11 13:49:50 INFO mapred.Task: Task:attempt_local_0009_m_000000_0 is done. And is in the process of commiting | |
13/04/11 13:49:53 INFO mapred.LocalJobRunner: file:/Users/ceteri/src/concur/CoPA/out/shade/part-00000:0+211208 | |
13/04/11 13:49:53 INFO mapred.Task: Task 'attempt_local_0009_m_000000_0' done. | |
13/04/11 13:49:53 INFO mapred.Task: Using ResourceCalculatorPlugin : null | |
13/04/11 13:49:53 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:53 INFO io.MultiInputSplit: current split input path: file:/Users/ceteri/src/concur/CoPA/out/gps/part-00000 | |
13/04/11 13:49:53 INFO mapred.MapTask: numReduceTasks: 1 | |
13/04/11 13:49:53 INFO mapred.MapTask: io.sort.mb = 100 | |
13/04/11 13:49:53 INFO mapred.MapTask: data buffer = 79691776/99614720 | |
13/04/11 13:49:53 INFO mapred.MapTask: record buffer = 262144/327680 | |
13/04/11 13:49:53 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:53 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:53 INFO hadoop.FlowMapper: sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["out/gps"]"] | |
13/04/11 13:49:53 INFO hadoop.FlowMapper: sinking to: CoGroup(83ffbe69-6ac4-455b-ba95-a64fb6ee8b3c*5825731c-a689-44be-9ff1-770d1133c59b)[by:83ffbe69-6ac4-455b-ba95-a64fb6ee8b3c:[{1}:'?geohash']5825731c-a689-44be-9ff1-770d1133c59b:[{1}:'?geohash']] | |
13/04/11 13:49:53 INFO mapred.MapTask: Starting flush of map output | |
13/04/11 13:49:53 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:53 INFO mapred.MapTask: Finished spill 0 | |
13/04/11 13:49:53 INFO mapred.Task: Task:attempt_local_0009_m_000001_0 is done. And is in the process of commiting | |
13/04/11 13:49:56 INFO mapred.LocalJobRunner: file:/Users/ceteri/src/concur/CoPA/out/gps/part-00000:0+678 | |
13/04/11 13:49:56 INFO mapred.Task: Task 'attempt_local_0009_m_000001_0' done. | |
13/04/11 13:49:56 INFO mapred.Task: Using ResourceCalculatorPlugin : null | |
13/04/11 13:49:56 INFO mapred.LocalJobRunner: | |
13/04/11 13:49:56 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:56 INFO mapred.Merger: Merging 2 sorted segments | |
13/04/11 13:49:56 INFO mapred.Merger: Down to the last merge-pass, with 2 segments left of total size: 264186 bytes | |
13/04/11 13:49:56 INFO mapred.LocalJobRunner: | |
13/04/11 13:49:56 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:56 INFO hadoop.FlowReducer: sourcing from: CoGroup(83ffbe69-6ac4-455b-ba95-a64fb6ee8b3c*5825731c-a689-44be-9ff1-770d1133c59b)[by:83ffbe69-6ac4-455b-ba95-a64fb6ee8b3c:[{1}:'?geohash']5825731c-a689-44be-9ff1-770d1133c59b:[{1}:'?geohash']] | |
13/04/11 13:49:56 INFO hadoop.FlowReducer: sinking to: Hfs["TextDelimited[[UNKNOWN]->['?uuid', '?road', '?geohash', '?lat', '?lng', '?alt', '?gps_count', '?recent_visit', '?road_metric', '?tree_metric']]"]["out/reco"]"] | |
13/04/11 13:49:56 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:56 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:56 INFO collect.SpillableTupleList: attempting to load codec: org.apache.hadoop.io.compress.GzipCodec | |
13/04/11 13:49:56 INFO collect.SpillableTupleList: found codec: org.apache.hadoop.io.compress.GzipCodec | |
13/04/11 13:49:56 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:56 INFO hadoop.TupleSerialization: using default comparator: cascalog.hadoop.DefaultComparator | |
13/04/11 13:49:56 INFO mapred.Task: Task:attempt_local_0009_r_000000_0 is done. And is in the process of commiting | |
13/04/11 13:49:56 INFO mapred.LocalJobRunner: | |
13/04/11 13:49:56 INFO mapred.Task: Task attempt_local_0009_r_000000_0 is allowed to commit now | |
13/04/11 13:49:56 INFO mapred.FileOutputCommitter: Saved output of task 'attempt_local_0009_r_000000_0' to file:/Users/ceteri/src/concur/CoPA/out/reco | |
13/04/11 13:49:59 INFO mapred.LocalJobRunner: reduce > reduce | |
13/04/11 13:49:59 INFO mapred.Task: Task 'attempt_local_0009_r_000000_0' done. | |
13/04/11 13:49:59 INFO util.Hadoop18TapUtil: deleting temp path out/reco/_temporary | |
bash-3.2$ | |
bash-3.2$ more out/reco/part-00000 | |
342ac6fd3f5f44c6b97724d618d587cf Ben Lomond Drive from Scripps Avenue to Scripps Avenue 9q9hv6 37.4121199015873 -122.1120714099095 0.0 | |
1 1972376691180 [1.0 0.183258146374831 0.88] 0.047722406612074525 | |
342ac6fd3f5f44c6b97724d618d587cf Scripps Court from Scripps Avenue to End 9q9hv6 37.4130300894995 -122.11112177995801 0.0 1 | |
1972376691180 [1.0 -Infinity 0.88] 0.044550463379027384 | |
342ac6fd3f5f44c6b97724d618d587cf Scripps Avenue from Ben Lomond Drive to Scripps Court 9q9hv6 37.413602878184946 -122.111103824523 0.0 | |
1 1972376691180 [1.0 0.11192315758708453 0.88] 0.03927409848033678 | |
342ac6fd3f5f44c6b97724d618d587cf Ferne Avenue from Alma Street to Ferne Court 9q9hv6 37.41060561364825 -122.1107096823655 0.0 1 | |
1972376691180 [1.0 0.2772588722239781 0.95] 0.10732227521650002 | |
342ac6fd3f5f44c6b97724d618d587cf Ferne Avenue from Ferne Court to Briarwood Way 9q9hv6 37.411135853680605 -122.110597890197 0.0 1 | |
1972376691180 [1.0 0.2772588722239781 0.88] 0.08775790668674047 | |
342ac6fd3f5f44c6b97724d618d587cf Alma Street from Ferne Avenue to San Antonio Avenue 9q9hv6 37.408924141076156 -122.11053185314049 0.0 | |
1 1972376691180 [0.0 0.8906484069027861 0.88] 0.16734380645907318 | |
342ac6fd3f5f44c6b97724d618d587cf Scripps Avenue from Scripps Court to Ben Lomond Drive 9q9hv6 37.41317579263425 -122.110427891666 0.0 | |
1 1972376691180 [1.0 0.13862943611198905 0.88] 0.04536253757530023 | |
342ac6fd3f5f44c6b97724d618d587cf Ferne Court from Ferne Avenue to End 9q9hv6 37.41092355433625 -122.11009205275249 0.0 1 1972376691180 [1.0 -Infinity 0.88] 0.10984583112030273 | |
342ac6fd3f5f44c6b97724d618d587cf Scripps Avenue from Ben Lomond Drive to Ferne Avenue 9q9hv6 37.41272860506055 -122.109720282045 0.0 | |
1 1972376691180 [1.0 0.1820545319097184 0.88] 0.0526522787698061 | |
342ac6fd3f5f44c6b97724d618d587cf Ferne Avenue from Briarwood Way to Scripps Court 9q9hv6 37.4121592805417 -122.109685996555 0.0 | |
1 1972376691180 [1.0 0.183258146374831 0.88] 0.06355418600754391 | |
342ac6fd3f5f44c6b97724d618d587cf Ferne Avenue from Scripps Court to Mackay Drive 9q9hv6 37.412793915678904 -122.1090632594855 0.0 1 |