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.D |