[ https://issues.apache.org/jira/browse/KUDU-1849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15838182#comment-15838182 ]
Todd Lipcon commented on KUDU-1849: ----------------------------------- Can you post the output of "kudu -version"? Sounds like your server might be too old to support the IN list predicate. > IN_LIST predicate is not working > -------------------------------- > > Key: KUDU-1849 > URL: https://issues.apache.org/jira/browse/KUDU-1849 > Project: Kudu > Issue Type: Bug > Components: api, client > Affects Versions: 1.1.0 > Environment: Used cloudera kudu sandbox 5.8.0 > Reporter: karthik > Priority: Critical > > We modified kudu-examples/java/java-sample to test IN_LIST predicate. > {code} > ColumnSchema column = new ColumnSchema.ColumnSchemaBuilder("key", > Type.INT32).build(); > List<Object> values = new ArrayList<>(); > values.add(0); > values.add(2); > KuduPredicate predicate = KuduPredicate.newInListPredicate(column, values > ); > KuduScanner scanner = > client.newScannerBuilder(table).addPredicate(predicate).build(); > {code} > We are getting the following exception: > {code} > org.apache.kudu.client.NonRecoverableException: Unknown predicate type for > column: key > at > org.apache.kudu.client.TabletClient.dispatchTSErrorOrReturnException(TabletClient.java:560) > at org.apache.kudu.client.TabletClient.decode(TabletClient.java:491) > at org.apache.kudu.client.TabletClient.decode(TabletClient.java:83) > at > org.apache.kudu.client.shaded.org.jboss.netty.handler.codec.replay.ReplayingDecoder.callDecode(ReplayingDecoder.java:500) > at > org.apache.kudu.client.shaded.org.jboss.netty.handler.codec.replay.ReplayingDecoder.messageReceived(ReplayingDecoder.java:435) > at > org.apache.kudu.client.shaded.org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70) > at > org.apache.kudu.client.TabletClient.handleUpstream(TabletClient.java:679) > at > org.apache.kudu.client.shaded.org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564) > at > org.apache.kudu.client.shaded.org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791) > at > org.apache.kudu.client.shaded.org.jboss.netty.handler.timeout.ReadTimeoutHandler.messageReceived(ReadTimeoutHandler.java:184) > at > org.apache.kudu.client.shaded.org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70) > at > org.apache.kudu.client.shaded.org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564) > at > org.apache.kudu.client.shaded.org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559) > at > org.apache.kudu.client.shaded.org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:268) > at > org.apache.kudu.client.shaded.org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:255) > at > org.apache.kudu.client.shaded.org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:88) > at > org.apache.kudu.client.shaded.org.jboss.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:108) > at > org.apache.kudu.client.shaded.org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:337) > at > org.apache.kudu.client.shaded.org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89) > at > org.apache.kudu.client.shaded.org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178) > at > org.apache.kudu.client.shaded.org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108) > at > org.apache.kudu.client.shaded.org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42) > 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) > {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)