You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by "paul cannon (JIRA)" <ji...@apache.org> on 2012/07/09 21:51:36 UTC
[jira] [Commented] (CASSANDRA-4426) CQL error on query prepare
[ https://issues.apache.org/jira/browse/CASSANDRA-4426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13409786#comment-13409786 ]
paul cannon commented on CASSANDRA-4426:
----------------------------------------
Thanks, this is very useful information. The tcpdump answers a lot of the initial questions I would have had, like "are you sure the queries are going to the same host and port", "are you using the lib correctly", etc.
About how often do you get the error? Is it as common as, say, one per 10 queries? Or more like one per million? If it's very reproducible, we should be able to track it down.
> CQL error on query prepare
> --------------------------
>
> Key: CASSANDRA-4426
> URL: https://issues.apache.org/jira/browse/CASSANDRA-4426
> Project: Cassandra
> Issue Type: Bug
> Affects Versions: 1.1.2
> Reporter: Marco Matarazzo
>
> We're using (packaged) cassandra 1.1.2 on Ubuntu LTS 12.04 .
> This is a CF on a KS with replica_factor 3, on a cluster with 3 nodes:
> cqlsh:goh_release> DESCRIBE COLUMNFAMILY agents_skill
> CREATE TABLE agents_skill (
> agent_id ascii,
> skill ascii,
> value ascii,
> PRIMARY KEY (agent_id, skill)
> ) WITH COMPACT STORAGE AND
> comment='' AND
> caching='KEYS_ONLY' AND
> read_repair_chance=0.100000 AND
> gc_grace_seconds=864000 AND
> min_compaction_threshold=4 AND
> max_compaction_threshold=32 AND
> replicate_on_write='true' AND
> compaction_strategy_class='SizeTieredCompactionStrategy' AND
> compression_parameters:sstable_compression='SnappyCompressor';
> cqlsh:goh_release>
> On this query :
> UPDATE agents_skill USING CONSISTENCY QUORUM SET value = ? WHERE agent_id = ? and skill = ?
> ...sometimes we get this error on cql_prepare_query():
> Error : line 1:78 mismatched input 'and' expecting EOF
> The error happens randomly (or with a pattern that I can't understand) and it does not make any sense to me. Normally the query works, as I would expect.
> I am using PHPCassa, and I was not sure where the error could be. I somewhat remembered that CQL should be passed to cassandra "as is", but not knowing Cassandra internal too well, I took a very low-level approach... I hope is not too low :-)
> I see this on tcpdump when i receive the error:
> 18:49:51.800398 IP 10.0.3.177.42205 > 10.0.3.170.9160: Flags [P.], seq 840:979, ack 766, win 1047, options [nop,nop,TS val 130357758 ecr 135322260], length 139
> 0x0000: aacc 0000 0208 aacc 0000 020f 0800 4500 ..............E.
> 0x0010: 00bf c2d9 4000 4006 5c05 0a00 03b1 0a00 ....@.@.\.......
> 0x0020: 03aa a4dd 23c8 16b9 de71 a9db 9466 8018 ....#....q...f..
> 0x0030: 0417 ad09 0000 0101 080a 07c5 19fe 0810 ................
> 0x0040: da94 0000 0087 8001 0001 0000 0011 7072 ..............pr
> 0x0050: 6570 6172 655f 6371 6c5f 7175 6572 7900 epare_cql_query.
> 0x0060: 0000 000b 0001 0000 005b 5550 4441 5445 .........[UPDATE
> 0x0070: 2061 6765 6e74 735f 736b 696c 6c20 5553 .agents_skill.US
> 0x0080: 494e 4720 434f 4e53 4953 5445 4e43 5920 ING.CONSISTENCY.
> 0x0090: 5155 4f52 554d 2053 4554 2076 616c 7565 QUORUM.SET.value
> 0x00a0: 203d 203f 2057 4845 5245 2061 6765 6e74 .=.?.WHERE.agent
> 0x00b0: 5f69 6420 3d20 3f20 616e 6420 736b 696c _id.=.?.and.skil
> 0x00c0: 6c20 3d20 3f08 0002 0000 0002 00 l.=.?........
> 18:49:51.817323 IP 10.0.3.170.9160 > 10.0.3.177.42205: Flags [P.], seq 766:857, ack 979, win 587, options [nop,nop,TS val 135322264 ecr 130357758], length 91
> 0x0000: aacc 0000 020f aacc 0000 0208 0800 4500 ..............E.
> 0x0010: 008f 4b1d 4000 4006 d3f1 0a00 03aa 0a00 ..K.@.@.........
> 0x0020: 03b1 23c8 a4dd a9db 9466 16b9 defc 8018 ..#......f......
> 0x0030: 024b 1bdc 0000 0101 080a 0810 da98 07c5 .K..............
> 0x0040: 19fe 0000 0057 8001 0002 0000 0011 7072 .....W........pr
> 0x0050: 6570 6172 655f 6371 6c5f 7175 6572 7900 epare_cql_query.
> 0x0060: 0000 000c 0001 0b00 0100 0000 2e6c 696e .............lin
> 0x0070: 6520 313a 3738 206d 6973 6d61 7463 6865 e.1:78.mismatche
> 0x0080: 6420 696e 7075 7420 2761 6e64 2720 6578 d.input.'and'.ex
> 0x0090: 7065 6374 696e 6720 454f 4600 00 pecting.EOF..
> Same query, some minutes later, worked (as I would expect) and I see this:
> 19:11:26.471750 IP 10.0.3.177.42283 > 10.0.3.170.9160: Flags [P.], seq 906:1045, ack 1181, win 1114, options [nop,nop,TS val 130681426 ecr 135645928], length 139
> 0x0000: aacc 0000 0208 aacc 0000 020f 0800 4500 ..............E.
> 0x0010: 00bf 352a 4000 4006 e9b4 0a00 03b1 0a00 ..5*@.@.........
> 0x0020: 03aa a52b 23c8 232a 42f7 c47b cf1e 8018 ...+#.#*B..{....
> 0x0030: 045a 0578 0000 0101 080a 07ca 0a52 0815 .Z.x.........R..
> 0x0040: cae8 0000 0087 8001 0001 0000 0011 7072 ..............pr
> 0x0050: 6570 6172 655f 6371 6c5f 7175 6572 7900 epare_cql_query.
> 0x0060: 0000 000b 0001 0000 005b 5550 4441 5445 .........[UPDATE
> 0x0070: 2061 6765 6e74 735f 736b 696c 6c20 5553 .agents_skill.US
> 0x0080: 494e 4720 434f 4e53 4953 5445 4e43 5920 ING.CONSISTENCY.
> 0x0090: 5155 4f52 554d 2053 4554 2076 616c 7565 QUORUM.SET.value
> 0x00a0: 203d 203f 2057 4845 5245 2061 6765 6e74 .=.?.WHERE.agent
> 0x00b0: 5f69 6420 3d20 3f20 616e 6420 736b 696c _id.=.?.and.skil
> 0x00c0: 6c20 3d20 3f08 0002 0000 0002 00 l.=.?........
> 19:11:26.472067 IP 10.0.3.170.9160 > 10.0.3.177.42283: Flags [P.], seq 1181:1318, ack 1045, win 587, options [nop,nop,TS val 135645928 ecr 130681426], length 137
> 0x0000: aacc 0000 020f aacc 0000 0208 0800 4500 ..............E.
> 0x0010: 00bd 0069 4000 4006 1e78 0a00 03aa 0a00 ...i@.@..x......
> 0x0020: 03b1 23c8 a52b c47b cf1e 232a 4382 8018 ..#..+.{..#*C...
> 0x0030: 024b 1c0a 0000 0101 080a 0815 cae8 07ca .K..............
> 0x0040: 0a52 0000 0085 8001 0002 0000 0011 7072 .R............pr
> 0x0050: 6570 6172 655f 6371 6c5f 7175 6572 7900 epare_cql_query.
> 0x0060: 0000 000c 0000 0800 0188 659f 9308 0002 ..........e.....
> 0x0070: 0000 0003 0f00 030b 0000 0003 0000 0009 ................
> 0x0080: 4173 6369 6954 7970 6500 0000 0941 7363 AsciiType....Asc
> 0x0090: 6969 5479 7065 0000 0009 4173 6369 6954 iiType....AsciiT
> 0x00a0: 7970 650f 0004 0b00 0000 0300 0000 0576 ype............v
> 0x00b0: 616c 7565 0000 0008 6167 656e 745f 6964 alue....agent_id
> 0x00c0: 0000 0005 736b 696c 6c00 00 ....skill..
> When i get the error I just see this on system.log :
> DEBUG [Thrift:1637] 2012-07-07 18:49:51,800 CassandraServer.java (line 1250) prepare_cql_query
> DEBUG [Thrift:1637] 2012-07-07 18:49:51,818 CustomTThreadPoolServer.java (line 196) Thrift transport error occurred during processing of message.
> org.apache.thrift.transport.TTransportException
> at org.apache.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java:132)
> at org.apache.thrift.transport.TTransport.readAll(TTransport.java:84)
> at org.apache.thrift.transport.TFramedTransport.readFrame(TFramedTransport.java:129)
> at org.apache.thrift.transport.TFramedTransport.read(TFramedTransport.java:101)
> at org.apache.thrift.transport.TTransport.readAll(TTransport.java:84)
> at org.apache.thrift.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:378)
> at org.apache.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:297)
> at org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:204)
> at org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:22)
> at org.apache.cassandra.thrift.CustomTThreadPoolServer$WorkerProcess.run(CustomTThreadPoolServer.java:186)
> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Unknown Source)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
> at java.lang.Thread.run(Unknown Source)
> Enabling TRACE does not give much more, to my eyes:
> DEBUG [Thrift:11] 2012-07-07 19:34:51,284 CassandraServer.java (line 1250) prepare_cql_query
> TRACE [Thrift:11] 2012-07-07 19:34:51,284 QueryProcessor.java (line 883) CQL QUERY: UPDATE agents_skill USING CONSISTENCY QUORUM SET value = ? WHERE agent_id = ? and skill = ?
> DEBUG [ReadRepairStage:2] 2012-07-07 19:34:51,285 RowDigestResolver.java (line 110) resolve: 2 ms.
> DEBUG [Thrift:11] 2012-07-07 19:34:51,286 CustomTThreadPoolServer.java (line 196) Thrift transport error occurred during processing of message.
> org.apache.thrift.transport.TTransportException
> at org.apache.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java:132)
> at org.apache.thrift.transport.TTransport.readAll(TTransport.java:84)
> at org.apache.thrift.transport.TFramedTransport.readFrame(TFramedTransport.java:129)
> at org.apache.thrift.transport.TFramedTransport.read(TFramedTransport.java:101)
> at org.apache.thrift.transport.TTransport.readAll(TTransport.java:84)
> at org.apache.thrift.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:378)
> at org.apache.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:297)
> at org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:204)
> at org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:22)
> at org.apache.cassandra.thrift.CustomTThreadPoolServer$WorkerProcess.run(CustomTThreadPoolServer.java:186)
> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Unknown Source)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
> at java.lang.Thread.run(Unknown Source)
> DEBUG [Thrift:11] 2012-07-07 19:34:51,294 ClientState.java (line 130) logged out: #<User allow_all groups=[]>
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira