Skip to content

Instantly share code, notes, and snippets.

@sixtus
Created April 8, 2014 13:34
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save sixtus/10124853 to your computer and use it in GitHub Desktop.
Save sixtus/10124853 to your computer and use it in GitHub Desktop.
com.metamx.common.RE: Failure on row[{... cut ... }]
at io.druid.indexer.HadoopDruidIndexerMapper.map(HadoopDruidIndexerMapper.java:81)
at io.druid.indexer.HadoopDruidIndexerMapper.map(HadoopDruidIndexerMapper.java:33)
at org.apache.hadoop.mapreduce.Mapper.run(Mapper.java:144)
at org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:764)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:370)
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:1136)
at org.apache.hadoop.mapred.Child.main(Child.java:249)
Caused by: com.metamx.common.ISE: row[MapBasedInputRow{timestamp=2014-03-07T17:00:14.000Z, event={... cut ...}] doesn't fit in any shard[[HadoopyShardSpec{actualSpec=HashBasedNumberedShardSpec{partitionNum=0, partitions=11}, shardNum=0}, HadoopyShardSpec{actualSpec=HashBasedNumberedShardSpec{partitionNum=1, partitions=11}, shardNum=1}, HadoopyShardSpec{actualSpec=HashBasedNumberedShardSpec{partitionNum=2, partitions=11}, shardNum=2}, HadoopyShardSpec{actualSpec=HashBasedNumberedShardSpec{partitionNum=3, partitions=11}, shardNum=3}, HadoopyShardSpec{actualSpec=HashBasedNumberedShardSpec{partitionNum=4, partitions=11}, shardNum=4}, HadoopyShardSpec{actualSpec=HashBasedNumberedShardSpec{partitionNum=5, partitions=11}, shardNum=5}, HadoopyShardSpec{actualSpec=HashBasedNumberedShardSpec{partitionNum=6, partitions=11}, shardNum=6}, HadoopyShardSpec{actualSpec=HashBasedNumberedShardSpec{partitionNum=7, partitions=11}, shardNum=7}, HadoopyShardSpec{actualSpec=HashBasedNumberedShardSpec{partitionNum=8, partitions=11}, shardNum=8}, HadoopyShardSpec{actualSpec=HashBasedNumberedShardSpec{partitionNum=9, partitions=11}, shardNum=9}, HadoopyShardSpec{actualSpec=HashBasedNumberedShardSpec{partitionNum=10, partitions=11}, shardNum=10}]]
at io.druid.indexer.HadoopDruidIndexerConfig.getBucket(HadoopDruidIndexerConfig.java:485)
at io.druid.indexer.IndexGeneratorJob$IndexGeneratorMapper.innerMap(IndexGeneratorJob.java:197)
at io.druid.indexer.HadoopDruidIndexerMapper.map(HadoopDruidIndexerMapper.java:77)
... 9 more
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment