presto mongo query - string comparison

[Saju Joseph]

Hi,

I am using presto 0.148 version to fetch data from mongo db.

Following query is failing for me - 

select * from mongo.mydb.appinfo app where app.startedtime > '1478743146000';

Here is the exception I see in presto CLI:

Query 20161116_132932_00004_z8a3b failed: Can't find a codec for class io.airlift.slice.Slice.

org.bson.codecs.configuration.CodecConfigurationException: Can't find a codec for class io.airlift.slice.Slice.

at org.bson.codecs.configuration.CodecCache.getOrThrow(CodecCache.java:46)

at org.bson.codecs.configuration.ProvidersCodecRegistry.get(ProvidersCodecRegistry.java:63)

at org.bson.codecs.configuration.ChildCodecRegistry.get(ChildCodecRegistry.java:51)

at org.bson.codecs.DocumentCodec.writeValue(DocumentCodec.java:174)

at org.bson.codecs.DocumentCodec.writeMap(DocumentCodec.java:189)

at org.bson.codecs.DocumentCodec.writeValue(DocumentCodec.java:172)

at org.bson.codecs.DocumentCodec.writeMap(DocumentCodec.java:189)

at org.bson.codecs.DocumentCodec.encode(DocumentCodec.java:131)

at org.bson.codecs.DocumentCodec.encode(DocumentCodec.java:45)

at org.bson.codecs.BsonDocumentWrapperCodec.encode(BsonDocumentWrapperCodec.java:63)

at org.bson.codecs.BsonDocumentWrapperCodec.encode(BsonDocumentWrapperCodec.java:29)

at org.bson.codecs.EncoderContext.encodeWithChildContext(EncoderContext.java:91)

at org.bson.codecs.BsonDocumentCodec.writeValue(BsonDocumentCodec.java:136)

at org.bson.codecs.BsonDocumentCodec.encode(BsonDocumentCodec.java:115)

at org.bson.codecs.BsonDocumentCodec.encode(BsonDocumentCodec.java:41)

at com.mongodb.connection.RequestMessage.addDocument(RequestMessage.java:253)

at com.mongodb.connection.RequestMessage.addDocument(RequestMessage.java:205)

at com.mongodb.connection.CommandMessage.encodeMessageBodyWithMetadata(CommandMessage.java:75)

at com.mongodb.connection.RequestMessage.encodeWithMetadata(RequestMessage.java:160)

at com.mongodb.connection.CommandProtocol.sendMessage(CommandProtocol.java:186)

at com.mongodb.connection.CommandProtocol.execute(CommandProtocol.java:111)

at com.mongodb.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:168)

at com.mongodb.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:289)

at com.mongodb.connection.DefaultServerConnection.command(DefaultServerConnection.java:176)

at com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocol(CommandOperationHelper.java:216)

at com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocol(CommandOperationHelper.java:207)

at com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocol(CommandOperationHelper.java:113)

at com.mongodb.operation.FindOperation$1.call(FindOperation.java:488)

at com.mongodb.operation.FindOperation$1.call(FindOperation.java:483)

at com.mongodb.operation.OperationHelper.withConnectionSource(OperationHelper.java:241)

at com.mongodb.operation.OperationHelper.withConnection(OperationHelper.java:214)

at com.mongodb.operation.FindOperation.execute(FindOperation.java:483)

at com.mongodb.operation.FindOperation.execute(FindOperation.java:80)

at com.mongodb.Mongo.execute(Mongo.java:818)

at com.mongodb.Mongo$2.execute(Mongo.java:805)

at com.mongodb.OperationIterable.iterator(OperationIterable.java:47)

at com.mongodb.FindIterableImpl.iterator(FindIterableImpl.java:143)

at com.facebook.presto.mongodb.MongoSession.execute(MongoSession.java:254)

at com.facebook.presto.mongodb.MongoPageSource.<init>(MongoPageSource.java:80)

at com.facebook.presto.mongodb.MongoPageSourceProvider.createPageSource(MongoPageSourceProvider.java:51)

at com.facebook.presto.split.PageSourceManager.createPageSource(PageSourceManager.java:56)

at com.facebook.presto.operator.ScanFilterAndProjectOperator.getOutput(ScanFilterAndProjectOperator.java:213)

at com.facebook.presto.operator.Driver.processInternal(Driver.java:378)

at com.facebook.presto.operator.Driver.processFor(Driver.java:301)

at com.facebook.presto.execution.SqlTaskExecution$DriverSplitRunner.processFor(SqlTaskExecution.java:622)

at com.facebook.presto.execution.TaskExecutor$PrioritizedSplitRunner.process(TaskExecutor.java:534)

at com.facebook.presto.execution.TaskExecutor$Runner.run(TaskExecutor.java:670)

at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)

at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)

at java.lang.Thread.run(Thread.java:745)

If I try select * from mongo.mydb.appinfo app where app.startedtime =  '1478743146000';  it works. But obviously, I don't get the data I need.
If this requires enhancing the codecs, I am ready to help. But I am new to presto source code side and so I don't know how quick to debug this particular issue.

Thanks for your time.

Saj