NullPointerException in EMR Job

45 views
Skip to first unread message

Neeki Patel

unread,
Apr 21, 2015, 9:21:09 AM4/21/15
to snowpl...@googlegroups.com
Hello,

My ERM jobs started failing, and see the following in the AWS console logs:

2015-04-21 12:37:25,907 INFO org.apache.hadoop.util.NativeCodeLoader (main): Loaded the native-hadoop library
2015-04-21 12:37:26,109 INFO org.apache.hadoop.mapred.TaskRunner (main): Creating symlink: /mnt/var/lib/hadoop/mapred/taskTracker/distcache/-2643132834156240618_-1421377178_1542957072/hdfs/cache/GeoLiteCity.dat <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/./ip_geo
2015-04-21 12:37:26,118 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/job.jar <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/job.jar
2015-04-21 12:37:26,120 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/.job.jar.crc <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/.job.jar.crc
2015-04-21 12:37:26,122 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/META-INF <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/META-INF
2015-04-21 12:37:26,124 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/.options <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/.options
2015-04-21 12:37:26,126 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/ASL-2.0.txt <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/ASL-2.0.txt
2015-04-21 12:37:26,127 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/DebugProtoTest.thrift <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/DebugProtoTest.thrift
2015-04-21 12:37:26,129 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/LGPL-3.0.txt <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/LGPL-3.0.txt
2015-04-21 12:37:26,131 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/LICENSE_rhino-1.7R4.txt <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/LICENSE_rhino-1.7R4.txt
2015-04-21 12:37:26,133 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/PropertyList-1.0.dtd <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/PropertyList-1.0.dtd
2015-04-21 12:37:26,135 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/address_book.thrift <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/address_book.thrift
2015-04-21 12:37:26,136 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/bin.tgz <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/bin.tgz
2015-04-21 12:37:26,138 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/build.properties <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/build.properties
2015-04-21 12:37:26,140 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/cascading <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/cascading
2015-04-21 12:37:26,142 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/ch <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/ch
2015-04-21 12:37:26,143 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/com <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/com
2015-04-21 12:37:26,146 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/compiler.properties <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/compiler.properties
2015-04-21 12:37:26,148 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/contribs <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/contribs
2015-04-21 12:37:26,150 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/core-default.xml <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/core-default.xml
2015-04-21 12:37:26,151 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/decoder.properties <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/decoder.properties
2015-04-21 12:37:26,153 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/digesterRules.xml <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/digesterRules.xml
2015-04-21 12:37:26,155 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/draftv3 <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/draftv3
2015-04-21 12:37:26,157 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/draftv4 <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/draftv4
2015-04-21 12:37:26,159 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/eu <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/eu
2015-04-21 12:37:26,160 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/hdfs-default.xml <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/hdfs-default.xml
2015-04-21 12:37:26,162 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/hsqlServlet.class <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/hsqlServlet.class
2015-04-21 12:37:26,164 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/iglu-client-embedded <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/iglu-client-embedded
2015-04-21 12:37:26,166 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/images <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/images
2015-04-21 12:37:26,167 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/javax <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/javax
2015-04-21 12:37:26,169 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/jdtCompilerAdapter.jar <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/jdtCompilerAdapter.jar
2015-04-21 12:37:26,171 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/joptsimple <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/joptsimple
2015-04-21 12:37:26,173 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/junit <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/junit
2015-04-21 12:37:26,175 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/library.properties <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/library.properties
2015-04-21 12:37:26,177 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/licenses <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/licenses
2015-04-21 12:37:26,179 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/log4j.properties <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/log4j.properties
2015-04-21 12:37:26,181 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/mapred-default.xml <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/mapred-default.xml
2015-04-21 12:37:26,183 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/minlog-1.2.jar <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/minlog-1.2.jar
2015-04-21 12:37:26,184 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/objenesis-1.2.jar <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/objenesis-1.2.jar
2015-04-21 12:37:26,186 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/org.codehaus.commons.compiler.properties <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/org.codehaus.commons.compiler.properties
2015-04-21 12:37:26,188 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/org <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/org
2015-04-21 12:37:26,190 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/plugin.properties <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/plugin.properties
2015-04-21 12:37:26,191 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/plugin.xml <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/plugin.xml
2015-04-21 12:37:26,193 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/properties.dtd <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/properties.dtd
2015-04-21 12:37:26,195 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/referers.json <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/referers.json
2015-04-21 12:37:26,197 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/referers.yml <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/referers.yml
2015-04-21 12:37:26,198 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/reflect.properties <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/reflect.properties
2015-04-21 12:37:26,200 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/reflectasm-1.07-shaded.jar <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/reflectasm-1.07-shaded.jar
2015-04-21 12:37:26,202 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/riffle <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/riffle
2015-04-21 12:37:26,203 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/rootdoc.txt <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/rootdoc.txt
2015-04-21 12:37:26,205 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/scala <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/scala
2015-04-21 12:37:26,207 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/scalaz <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/scalaz
2015-04-21 12:37:26,209 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/shapeless <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/shapeless
2015-04-21 12:37:26,210 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/stylesheet.css <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/stylesheet.css
2015-04-21 12:37:26,212 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/templates <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/templates
2015-04-21 12:37:26,214 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/test.thrift <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/test.thrift
2015-04-21 12:37:26,215 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/thrift <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/thrift
2015-04-21 12:37:26,217 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/ua_parser <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/ua_parser
2015-04-21 12:37:26,219 INFO org.apache.hadoop.filecache.TrackerDistributedCacheManager (main): Creating symlink: /mnt1/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/jars/webapps <- /mnt/var/lib/hadoop/mapred/taskTracker/hadoop/jobcache/job_201504211230_0003/attempt_201504211230_0003_m_000000_1/work/webapps
2015-04-21 12:37:26,394 WARN org.apache.hadoop.metrics2.impl.MetricsSystemImpl (main): Source name ugi already exists!
2015-04-21 12:37:26,488 INFO org.apache.hadoop.mapred.MapTask (main): Host name: ip-172-31-63-60.ec2.internal
2015-04-21 12:37:26,507 INFO org.apache.hadoop.util.ProcessTree (main): setsid exited with exit code 0
2015-04-21 12:37:26,513 INFO org.apache.hadoop.mapred.Task (main):  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@5a232b4c
2015-04-21 12:37:27,188 INFO cascading.tap.hadoop.io.MultiInputSplit (main): current split input path: hdfs://172.31.57.87:9000/local/snowplow/raw-events/2015-04-210.lzo
2015-04-21 12:37:27,200 INFO com.hadoop.compression.lzo.GPLNativeCodeLoader (main): Loaded native gpl library
2015-04-21 12:37:27,202 INFO com.hadoop.compression.lzo.LzoCodec (main): Successfully loaded & initialized native-lzo library [hadoop-lzo rev 049362b7cf53ff5f739d6b1532457f2c6cd495e8]
2015-04-21 12:37:27,207 WARN org.apache.hadoop.io.compress.snappy.LoadSnappy (main): Snappy native library is available
2015-04-21 12:37:27,207 INFO org.apache.hadoop.io.compress.snappy.LoadSnappy (main): Snappy native library loaded
2015-04-21 12:37:27,218 INFO org.apache.hadoop.mapred.MapTask (main): numReduceTasks: 0
2015-04-21 12:37:27,236 INFO cascading.flow.hadoop.FlowMapper (main): cascading version: 2.5.5
2015-04-21 12:37:27,236 INFO cascading.flow.hadoop.FlowMapper (main): child jvm opts: -Xmx1096m
2015-04-21 12:37:27,487 INFO cascading.flow.hadoop.FlowMapper (main): sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["hdfs:/local/snowplow/raw-events"]
2015-04-21 12:37:27,487 INFO cascading.flow.hadoop.FlowMapper (main): sinking to: Hfs["TextDelimited[['app_id', 'platform', 'etl_tstamp', 'collector_tstamp', 'dvce_tstamp', 'event', 'event_id', 'txn_id', 'name_tracker', 'v_tracker', 'v_collector', 'v_etl', 'user_id', 'user_ipaddress', 'user_fingerprint', 'domain_userid', 'domain_sessionidx', 'network_userid', 'geo_country', 'geo_region', 'geo_city', 'geo_zipcode', 'geo_latitude', 'geo_longitude', 'geo_region_name', 'ip_isp', 'ip_organization', 'ip_domain', 'ip_netspeed', 'page_url', 'page_title', 'page_referrer', 'page_urlscheme', 'page_urlhost', 'page_urlport', 'page_urlpath', 'page_urlquery', 'page_urlfragment', 'refr_urlscheme', 'refr_urlhost', 'refr_urlport', 'refr_urlpath', 'refr_urlquery', 'refr_urlfragment', 'refr_medium', 'refr_source', 'refr_term', 'mkt_medium', 'mkt_source', 'mkt_term', 'mkt_content', 'mkt_campaign', 'contexts', 'se_category', 'se_action', 'se_label', 'se_property', 'se_value', 'unstruct_event', 'tr_orderid', 'tr_affiliation', 'tr_total', 'tr_tax', 'tr_shipping', 'tr_city', 'tr_state', 'tr_country', 'ti_orderid', 'ti_sku', 'ti_name', 'ti_category', 'ti_price', 'ti_quantity', 'pp_xoffset_min', 'pp_xoffset_max', 'pp_yoffset_min', 'pp_yoffset_max', 'useragent', 'br_name', 'br_family', 'br_version', 'br_type', 'br_renderengine', 'br_lang', 'br_features_pdf', 'br_features_flash', 'br_features_java', 'br_features_director', 'br_features_quicktime', 'br_features_realplayer', 'br_features_windowsmedia', 'br_features_gears', 'br_features_silverlight', 'br_cookies', 'br_colordepth', 'br_viewwidth', 'br_viewheight', 'os_name', 'os_family', 'os_manufacturer', 'os_timezone', 'dvce_type', 'dvce_ismobile', 'dvce_screenwidth', 'dvce_screenheight', 'doc_charset', 'doc_width', 'doc_height', 'tr_currency', 'tr_total_base', 'tr_tax_base', 'tr_shipping_base', 'ti_currency', 'ti_price_base', 'base_currency', 'geo_timezone', 'mkt_clickid', 'mkt_network', 'etl_tags', 'dvce_sent_tstamp', 'refr_domain_userid', 'refr_dvce_tstamp', 'derived_contexts', 'domain_sessionid', 'derived_tstamp']]"]["hdfs:/local/snowplow/enriched-events"]
2015-04-21 12:41:07,052 ERROR cascading.flow.stream.TrapHandler (main): caught Throwable, no trap available, rethrowing
cascading.pipe.OperatorException: [com.twitter.scalding.M...][com.twitter.scalding.RichPipe.each(RichPipe.scala:471)] operator Each failed executing operation
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:107)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:441)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:377)
	at org.apache.hadoop.mapred.Child$4.run(Child.java:255)
	at java.security.AccessController.doPrivileged(Native Method)
	at javax.security.auth.Subject.doAs(Subject.java:415)
	at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1132)
	at org.apache.hadoop.mapred.Child.main(Child.java:249)
Caused by: java.lang.NullPointerException
	at com.snowplowanalytics.snowplow.enrich.common.utils.JsonUtils$.stripInstanceEtc(JsonUtils.scala:240)
	at com.snowplowanalytics.snowplow.enrich.common.utils.JsonUtils$.extractJson(JsonUtils.scala:204)
	at com.snowplowanalytics.snowplow.enrich.common.utils.JsonUtils$.validateAndReformatJson(JsonUtils.scala:189)
	at com.snowplowanalytics.snowplow.enrich.common.utils.JsonUtils$$anonfun$1.apply(JsonUtils.scala:59)
	at com.snowplowanalytics.snowplow.enrich.common.utils.JsonUtils$$anonfun$1.apply(JsonUtils.scala:58)
	at com.snowplowanalytics.snowplow.enrich.common.enrichments.EnrichmentManager$$anonfun$4.apply(EnrichmentManager.scala:103)
	at com.snowplowanalytics.snowplow.enrich.common.enrichments.EnrichmentManager$$anonfun$4.apply(EnrichmentManager.scala:103)
	at com.snowplowanalytics.snowplow.enrich.common.utils.MapTransformer$$anonfun$1.apply(MapTransformer.scala:158)
	at com.snowplowanalytics.snowplow.enrich.common.utils.MapTransformer$$anonfun$1.apply(MapTransformer.scala:155)
	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
	at scala.collection.immutable.HashMap$HashMap1.foreach(HashMap.scala:224)
	at scala.collection.immutable.HashMap$HashTrieMap.foreach(HashMap.scala:403)
	at scala.collection.TraversableLike$class.map(TraversableLike.scala:244)
	at scala.collection.AbstractTraversable.map(Traversable.scala:105)
	at com.snowplowanalytics.snowplow.enrich.common.utils.MapTransformer$.com$snowplowanalytics$snowplow$enrich$common$utils$MapTransformer$$_transform(MapTransformer.scala:155)
	at com.snowplowanalytics.snowplow.enrich.common.utils.MapTransformer$TransformableClass.transform(MapTransformer.scala:132)
	at com.snowplowanalytics.snowplow.enrich.common.enrichments.EnrichmentManager$.enrichEvent(EnrichmentManager.scala:193)
	at com.snowplowanalytics.snowplow.enrich.common.EtlPipeline$$anonfun$1$$anonfun$apply$1$$anonfun$apply$2$$anonfun$apply$3.apply(EtlPipeline.scala:81)
	at com.snowplowanalytics.snowplow.enrich.common.EtlPipeline$$anonfun$1$$anonfun$apply$1$$anonfun$apply$2$$anonfun$apply$3.apply(EtlPipeline.scala:80)
	at scalaz.NonEmptyList$class.map(NonEmptyList.scala:29)
	at scalaz.NonEmptyListFunctions$$anon$4.map(NonEmptyList.scala:164)
	at com.snowplowanalytics.snowplow.enrich.common.EtlPipeline$$anonfun$1$$anonfun$apply$1$$anonfun$apply$2.apply(EtlPipeline.scala:80)
	at com.snowplowanalytics.snowplow.enrich.common.EtlPipeline$$anonfun$1$$anonfun$apply$1$$anonfun$apply$2.apply(EtlPipeline.scala:78)
	at scalaz.Validation$class.map(Validation.scala:114)
	at scalaz.Success.map(Validation.scala:329)
	at com.snowplowanalytics.snowplow.enrich.common.EtlPipeline$$anonfun$1$$anonfun$apply$1.apply(EtlPipeline.scala:78)
	at com.snowplowanalytics.snowplow.enrich.common.EtlPipeline$$anonfun$1$$anonfun$apply$1.apply(EtlPipeline.scala:76)
	at scala.Option.map(Option.scala:145)
	at com.snowplowanalytics.snowplow.enrich.common.EtlPipeline$$anonfun$1.apply(EtlPipeline.scala:76)
	at com.snowplowanalytics.snowplow.enrich.common.EtlPipeline$$anonfun$1.apply(EtlPipeline.scala:74)
	at scalaz.Validation$class.map(Validation.scala:114)
	at scalaz.Success.map(Validation.scala:329)
	at com.snowplowanalytics.snowplow.enrich.common.EtlPipeline$.processEvents(EtlPipeline.scala:74)
	at com.snowplowanalytics.snowplow.enrich.hadoop.EtlJob$$anonfun$7.apply(EtlJob.scala:172)
	at com.snowplowanalytics.snowplow.enrich.hadoop.EtlJob$$anonfun$7.apply(EtlJob.scala:171)
	at com.twitter.scalding.MapFunction.operate(Operations.scala:58)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	... 11 more
2015-04-21 12:41:07,054 ERROR cascading.flow.stream.SourceStage (main): caught throwable
cascading.pipe.OperatorException: [com.twitter.scalding.M...][com.twitter.scalding.RichPipe.each(RichPipe.scala:471)] operator Each failed executing operation
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:107)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:441)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:377)
	at org.apache.hadoop.mapred.Child$4.run(Child.java:255)
	at java.security.AccessController.doPrivileged(Native Method)
	at javax.security.auth.Subject.doAs(Subject.java:415)
	at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1132)
	at org.apache.hadoop.mapred.Child.main(Child.java:249)
Caused by: java.lang.NullPointerException
	at com.snowplowanalytics.snowplow.enrich.common.utils.JsonUtils$.stripInstanceEtc(JsonUtils.scala:240)
	at com.snowplowanalytics.snowplow.enrich.common.utils.JsonUtils$.extractJson(JsonUtils.scala:204)
	at com.snowplowanalytics.snowplow.enrich.common.utils.JsonUtils$.validateAndReformatJson(JsonUtils.scala:189)
	at com.snowplowanalytics.snowplow.enrich.common.utils.JsonUtils$$anonfun$1.apply(JsonUtils.scala:59)
	at com.snowplowanalytics.snowplow.enrich.common.utils.JsonUtils$$anonfun$1.apply(JsonUtils.scala:58)
	at com.snowplowanalytics.snowplow.enrich.common.enrichments.EnrichmentManager$$anonfun$4.apply(EnrichmentManager.scala:103)
	at com.snowplowanalytics.snowplow.enrich.common.enrichments.EnrichmentManager$$anonfun$4.apply(EnrichmentManager.scala:103)
	at com.snowplowanalytics.snowplow.enrich.common.utils.MapTransformer$$anonfun$1.apply(MapTransformer.scala:158)
	at com.snowplowanalytics.snowplow.enrich.common.utils.MapTransformer$$anonfun$1.apply(MapTransformer.scala:155)
	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
	at scala.collection.immutable.HashMap$HashMap1.foreach(HashMap.scala:224)
	at scala.collection.immutable.HashMap$HashTrieMap.foreach(HashMap.scala:403)
	at scala.collection.TraversableLike$class.map(TraversableLike.scala:244)
	at scala.collection.AbstractTraversable.map(Traversable.scala:105)
	at com.snowplowanalytics.snowplow.enrich.common.utils.MapTransformer$.com$snowplowanalytics$snowplow$enrich$common$utils$MapTransformer$$_transform(MapTransformer.scala:155)
	at com.snowplowanalytics.snowplow.enrich.common.utils.MapTransformer$TransformableClass.transform(MapTransformer.scala:132)
	at com.snowplowanalytics.snowplow.enrich.common.enrichments.EnrichmentManager$.enrichEvent(EnrichmentManager.scala:193)
	at com.snowplowanalytics.snowplow.enrich.common.EtlPipeline$$anonfun$1$$anonfun$apply$1$$anonfun$apply$2$$anonfun$apply$3.apply(EtlPipeline.scala:81)
	at com.snowplowanalytics.snowplow.enrich.common.EtlPipeline$$anonfun$1$$anonfun$apply$1$$anonfun$apply$2$$anonfun$apply$3.apply(EtlPipeline.scala:80)
	at scalaz.NonEmptyList$class.map(NonEmptyList.scala:29)
	at scalaz.NonEmptyListFunctions$$anon$4.map(NonEmptyList.scala:164)
	at com.snowplowanalytics.snowplow.enrich.common.EtlPipeline$$anonfun$1$$anonfun$apply$1$$anonfun$apply$2.apply(EtlPipeline.scala:80)
	at com.snowplowanalytics.snowplow.enrich.common.EtlPipeline$$anonfun$1$$anonfun$apply$1$$anonfun$apply$2.apply(EtlPipeline.scala:78)
	at scalaz.Validation$class.map(Validation.scala:114)
	at scalaz.Success.map(Validation.scala:329)
	at com.snowplowanalytics.snowplow.enrich.common.EtlPipeline$$anonfun$1$$anonfun$apply$1.apply(EtlPipeline.scala:78)
	at com.snowplowanalytics.snowplow.enrich.common.EtlPipeline$$anonfun$1$$anonfun$apply$1.apply(EtlPipeline.scala:76)
	at scala.Option.map(Option.scala:145)
	at com.snowplowanalytics.snowplow.enrich.common.EtlPipeline$$anonfun$1.apply(EtlPipeline.scala:76)
	at com.snowplowanalytics.snowplow.enrich.common.EtlPipeline$$anonfun$1.apply(EtlPipeline.scala:74)
	at scalaz.Validation$class.map(Validation.scala:114)
	at scalaz.Success.map(Validation.scala:329)
	at com.snowplowanalytics.snowplow.enrich.common.EtlPipeline$.processEvents(EtlPipeline.scala:74)
	at com.snowplowanalytics.snowplow.enrich.hadoop.EtlJob$$anonfun$7.apply(EtlJob.scala:172)
	at com.snowplowanalytics.snowplow.enrich.hadoop.EtlJob$$anonfun$7.apply(EtlJob.scala:171)
	at com.twitter.scalding.MapFunction.operate(Operations.scala:58)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	... 11 more
2015-04-21 12:41:07,062 INFO org.apache.hadoop.mapred.TaskLogsTruncater (main): Initializing logs' truncater with mapRetainSize=-1 and reduceRetainSize=-1
2015-04-21 12:41:07,081 INFO org.apache.hadoop.io.nativeio.NativeIO (main): Initialized cache for UID to User mapping with a cache timeout of 14400 seconds.
2015-04-21 12:41:07,081 INFO org.apache.hadoop.io.nativeio.NativeIO (main): Got UserName hadoop for UID 105 from the native implementation
2015-04-21 12:41:07,082 WARN org.apache.hadoop.mapred.Child (main): Error running child
cascading.pipe.OperatorException: [com.twitter.scalding.M...][com.twitter.scalding.RichPipe.each(RichPipe.scala:471)] operator Each failed executing operation
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:107)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:441)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:377)
	at org.apache.hadoop.mapred.Child$4.run(Child.java:255)
	at java.security.AccessController.doPrivileged(Native Method)
	at javax.security.auth.Subject.doAs(Subject.java:415)
	at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1132)
	at org.apache.hadoop.mapred.Child.main(Child.java:249)
Caused by: java.lang.NullPointerException
	at com.snowplowanalytics.snowplow.enrich.common.utils.JsonUtils$.stripInstanceEtc(JsonUtils.scala:240)
	at com.snowplowanalytics.snowplow.enrich.common.utils.JsonUtils$.extractJson(JsonUtils.scala:204)
	at com.snowplowanalytics.snowplow.enrich.common.utils.JsonUtils$.validateAndReformatJson(JsonUtils.scala:189)
	at com.snowplowanalytics.snowplow.enrich.common.utils.JsonUtils$$anonfun$1.apply(JsonUtils.scala:59)
	at com.snowplowanalytics.snowplow.enrich.common.utils.JsonUtils$$anonfun$1.apply(JsonUtils.scala:58)
	at com.snowplowanalytics.snowplow.enrich.common.enrichments.EnrichmentManager$$anonfun$4.apply(EnrichmentManager.scala:103)
	at com.snowplowanalytics.snowplow.enrich.common.enrichments.EnrichmentManager$$anonfun$4.apply(EnrichmentManager.scala:103)
	at com.snowplowanalytics.snowplow.enrich.common.utils.MapTransformer$$anonfun$1.apply(MapTransformer.scala:158)
	at com.snowplowanalytics.snowplow.enrich.common.utils.MapTransformer$$anonfun$1.apply(MapTransformer.scala:155)
	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
	at scala.collection.immutable.HashMap$HashMap1.foreach(HashMap.scala:224)
	at scala.collection.immutable.HashMap$HashTrieMap.foreach(HashMap.scala:403)
	at scala.collection.TraversableLike$class.map(TraversableLike.scala:244)
	at scala.collection.AbstractTraversable.map(Traversable.scala:105)
	at com.snowplowanalytics.snowplow.enrich.common.utils.MapTransformer$.com$snowplowanalytics$snowplow$enrich$common$utils$MapTransformer$$_transform(MapTransformer.scala:155)
	at com.snowplowanalytics.snowplow.enrich.common.utils.MapTransformer$TransformableClass.transform(MapTransformer.scala:132)
	at com.snowplowanalytics.snowplow.enrich.common.enrichments.EnrichmentManager$.enrichEvent(EnrichmentManager.scala:193)
	at com.snowplowanalytics.snowplow.enrich.common.EtlPipeline$$anonfun$1$$anonfun$apply$1$$anonfun$apply$2$$anonfun$apply$3.apply(EtlPipeline.scala:81)
	at com.snowplowanalytics.snowplow.enrich.common.EtlPipeline$$anonfun$1$$anonfun$apply$1$$anonfun$apply$2$$anonfun$apply$3.apply(EtlPipeline.scala:80)
	at scalaz.NonEmptyList$class.map(NonEmptyList.scala:29)
	at scalaz.NonEmptyListFunctions$$anon$4.map(NonEmptyList.scala:164)
	at com.snowplowanalytics.snowplow.enrich.common.EtlPipeline$$anonfun$1$$anonfun$apply$1$$anonfun$apply$2.apply(EtlPipeline.scala:80)
	at com.snowplowanalytics.snowplow.enrich.common.EtlPipeline$$anonfun$1$$anonfun$apply$1$$anonfun$apply$2.apply(EtlPipeline.scala:78)
	at scalaz.Validation$class.map(Validation.scala:114)
	at scalaz.Success.map(Validation.scala:329)
	at com.snowplowanalytics.snowplow.enrich.common.EtlPipeline$$anonfun$1$$anonfun$apply$1.apply(EtlPipeline.scala:78)
	at com.snowplowanalytics.snowplow.enrich.common.EtlPipeline$$anonfun$1$$anonfun$apply$1.apply(EtlPipeline.scala:76)
	at scala.Option.map(Option.scala:145)
	at com.snowplowanalytics.snowplow.enrich.common.EtlPipeline$$anonfun$1.apply(EtlPipeline.scala:76)
	at com.snowplowanalytics.snowplow.enrich.common.EtlPipeline$$anonfun$1.apply(EtlPipeline.scala:74)
	at scalaz.Validation$class.map(Validation.scala:114)
	at scalaz.Success.map(Validation.scala:329)
	at com.snowplowanalytics.snowplow.enrich.common.EtlPipeline$.processEvents(EtlPipeline.scala:74)
	at com.snowplowanalytics.snowplow.enrich.hadoop.EtlJob$$anonfun$7.apply(EtlJob.scala:172)
	at com.snowplowanalytics.snowplow.enrich.hadoop.EtlJob$$anonfun$7.apply(EtlJob.scala:171)
	at com.twitter.scalding.MapFunction.operate(Operations.scala:58)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	... 11 more
2015-04-21 12:41:07,086 INFO org.apache.hadoop.mapred.Task (main): Runnning cleanup for the task

Alex Dean

unread,
Apr 21, 2015, 9:26:11 AM4/21/15
to snowpl...@googlegroups.com
Hi Neeki,

It sounds a lot like this one: https://groups.google.com/forum/#!topic/snowplow-user/JuNn4BIz_EM

Cheers,

Alex

--
You received this message because you are subscribed to the Google Groups "Snowplow" group.
To unsubscribe from this group and stop receiving emails from it, send an email to snowplow-use...@googlegroups.com.
For more options, visit https://groups.google.com/d/optout.



--
Co-founder
Snowplow Analytics
The Roma Building, 32-38 Scrutton Street, London EC2A 4RQ, United Kingdom
+44 (0)203 589 6116
+44 7881 622 925
@alexcrdean

Neeki Patel

unread,
Apr 21, 2015, 9:42:25 AM4/21/15
to snowpl...@googlegroups.com
Yes rolling back to 0.12.0 resolved the issue. Thanks for much

Neeki
...
Reply all
Reply to author
Forward
0 new messages