[jira] [Commented] (CASSANDRA-5941) Incorrect Schema with PIG CqlStorage Queries

2013-08-27 Thread Alex Liu (JIRA)

[ 
https://issues.apache.org/jira/browse/CASSANDRA-5941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13751441#comment-13751441
 ] 

Alex Liu commented on CASSANDRA-5941:
-

[~schappetj]Can you try  patch 5867-bug-fix-filter-push-down-1.2-branch.txt on 
CASSANDRA-5876?

 Incorrect Schema with PIG CqlStorage Queries
 

 Key: CASSANDRA-5941
 URL: https://issues.apache.org/jira/browse/CASSANDRA-5941
 Project: Cassandra
  Issue Type: Bug
Reporter: James Schappet
Assignee: Alex Liu

 A = LOAD 'cql://my/data?where_clause=key%3D\'status\' ' USING CqlStorage() AS 
 (
 type:chararray,
 barcode:chararray,
 row_id:bytearray,
 key:chararray,
 status:chararray
 );
 DESCRIBE A;
 --A: {type: chararray,barcode: chararray,row_id: bytearray,key: 
 chararray,status: chararray}
 B = FOREACH A GENERATE FLATTEN( status );
 I am trying to process the following data:
 B = FOREACH A GENERATE FLATTEN( status);
 DUMB B;
 (value,LIVING)
 (value,LIVING)
 (value,LIVING)
 (value,DECEASED)
 (value,LIVING)
 (value,DECEASED)
 (value,DECEASED)
 (value,LIVING)
 But when I try to filter it (FILTER A BY status MATCHES 'DECEASED') 
 I get the following error:
 2013-08-23 08:47:16,290 [Thread-4] WARN  
 org.apache.hadoop.mapred.LocalJobRunner - job_local_0001
 java.lang.ClassCastException: org.apache.pig.data.BinSedesTuple cannot be 
 cast to java.lang.String
 at 
 org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.PORegexp.getNext(PORegexp.java:84)
 at 
 org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POFilter.getNext(POFilter.java:148)
 at 
 org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator.processInput(PhysicalOperator.java:290)
 at 
 org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POForEach.getNext(POForEach.java:233)
 at 
 org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapReduce$Reduce.runPipeline(PigGenericMapReduce.java:460)
 ...
 There are two StackOverFlow questions related to this:
 http://stackoverflow.com/questions/18407248/cce-binsedestuple-cannot-be-cast-to-string?lq=1
 http://stackoverflow.com/questions/18391552/cqlstorage-generates-wrong-pig-schema?lq=1

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira


[jira] [Commented] (CASSANDRA-5941) Incorrect Schema with PIG CqlStorage Queries

2013-08-27 Thread James Schappet (JIRA)

[ 
https://issues.apache.org/jira/browse/CASSANDRA-5941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13751535#comment-13751535
 ] 

James Schappet commented on CASSANDRA-5941:
---

Please pardon my ignorance, but I have never applied a patch.

How do I apply it?  and to what version should it be applied?

 Incorrect Schema with PIG CqlStorage Queries
 

 Key: CASSANDRA-5941
 URL: https://issues.apache.org/jira/browse/CASSANDRA-5941
 Project: Cassandra
  Issue Type: Bug
Reporter: James Schappet
Assignee: Alex Liu

 A = LOAD 'cql://my/data?where_clause=key%3D\'status\' ' USING CqlStorage() AS 
 (
 type:chararray,
 barcode:chararray,
 row_id:bytearray,
 key:chararray,
 status:chararray
 );
 DESCRIBE A;
 --A: {type: chararray,barcode: chararray,row_id: bytearray,key: 
 chararray,status: chararray}
 B = FOREACH A GENERATE FLATTEN( status );
 I am trying to process the following data:
 B = FOREACH A GENERATE FLATTEN( status);
 DUMB B;
 (value,LIVING)
 (value,LIVING)
 (value,LIVING)
 (value,DECEASED)
 (value,LIVING)
 (value,DECEASED)
 (value,DECEASED)
 (value,LIVING)
 But when I try to filter it (FILTER A BY status MATCHES 'DECEASED') 
 I get the following error:
 2013-08-23 08:47:16,290 [Thread-4] WARN  
 org.apache.hadoop.mapred.LocalJobRunner - job_local_0001
 java.lang.ClassCastException: org.apache.pig.data.BinSedesTuple cannot be 
 cast to java.lang.String
 at 
 org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.PORegexp.getNext(PORegexp.java:84)
 at 
 org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POFilter.getNext(POFilter.java:148)
 at 
 org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator.processInput(PhysicalOperator.java:290)
 at 
 org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POForEach.getNext(POForEach.java:233)
 at 
 org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapReduce$Reduce.runPipeline(PigGenericMapReduce.java:460)
 ...
 There are two StackOverFlow questions related to this:
 http://stackoverflow.com/questions/18407248/cce-binsedestuple-cannot-be-cast-to-string?lq=1
 http://stackoverflow.com/questions/18391552/cqlstorage-generates-wrong-pig-schema?lq=1

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira


[jira] [Commented] (CASSANDRA-5941) Incorrect Schema with PIG CqlStorage Queries

2013-08-27 Thread Alex Liu (JIRA)

[ 
https://issues.apache.org/jira/browse/CASSANDRA-5941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13751546#comment-13751546
 ] 

Alex Liu commented on CASSANDRA-5941:
-

git checkout cassandra-1.2 branch. then patch -p1  
5867-bug-fix-filter-push-down-1.2-branch.txt

 Incorrect Schema with PIG CqlStorage Queries
 

 Key: CASSANDRA-5941
 URL: https://issues.apache.org/jira/browse/CASSANDRA-5941
 Project: Cassandra
  Issue Type: Bug
Reporter: James Schappet
Assignee: Alex Liu

 A = LOAD 'cql://my/data?where_clause=key%3D\'status\' ' USING CqlStorage() AS 
 (
 type:chararray,
 barcode:chararray,
 row_id:bytearray,
 key:chararray,
 status:chararray
 );
 DESCRIBE A;
 --A: {type: chararray,barcode: chararray,row_id: bytearray,key: 
 chararray,status: chararray}
 B = FOREACH A GENERATE FLATTEN( status );
 I am trying to process the following data:
 B = FOREACH A GENERATE FLATTEN( status);
 DUMB B;
 (value,LIVING)
 (value,LIVING)
 (value,LIVING)
 (value,DECEASED)
 (value,LIVING)
 (value,DECEASED)
 (value,DECEASED)
 (value,LIVING)
 But when I try to filter it (FILTER A BY status MATCHES 'DECEASED') 
 I get the following error:
 2013-08-23 08:47:16,290 [Thread-4] WARN  
 org.apache.hadoop.mapred.LocalJobRunner - job_local_0001
 java.lang.ClassCastException: org.apache.pig.data.BinSedesTuple cannot be 
 cast to java.lang.String
 at 
 org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.PORegexp.getNext(PORegexp.java:84)
 at 
 org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POFilter.getNext(POFilter.java:148)
 at 
 org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator.processInput(PhysicalOperator.java:290)
 at 
 org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POForEach.getNext(POForEach.java:233)
 at 
 org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapReduce$Reduce.runPipeline(PigGenericMapReduce.java:460)
 ...
 There are two StackOverFlow questions related to this:
 http://stackoverflow.com/questions/18407248/cce-binsedestuple-cannot-be-cast-to-string?lq=1
 http://stackoverflow.com/questions/18391552/cqlstorage-generates-wrong-pig-schema?lq=1

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira


[jira] [Commented] (CASSANDRA-5941) Incorrect Schema with PIG CqlStorage Queries

2013-08-27 Thread James Schappet (JIRA)

[ 
https://issues.apache.org/jira/browse/CASSANDRA-5941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13751561#comment-13751561
 ] 

James Schappet commented on CASSANDRA-5941:
---

That fixed it.  It's now filtering as expected.  



 Incorrect Schema with PIG CqlStorage Queries
 

 Key: CASSANDRA-5941
 URL: https://issues.apache.org/jira/browse/CASSANDRA-5941
 Project: Cassandra
  Issue Type: Bug
Reporter: James Schappet
Assignee: Alex Liu

 A = LOAD 'cql://my/data?where_clause=key%3D\'status\' ' USING CqlStorage() AS 
 (
 type:chararray,
 barcode:chararray,
 row_id:bytearray,
 key:chararray,
 status:chararray
 );
 DESCRIBE A;
 --A: {type: chararray,barcode: chararray,row_id: bytearray,key: 
 chararray,status: chararray}
 B = FOREACH A GENERATE FLATTEN( status );
 I am trying to process the following data:
 B = FOREACH A GENERATE FLATTEN( status);
 DUMB B;
 (value,LIVING)
 (value,LIVING)
 (value,LIVING)
 (value,DECEASED)
 (value,LIVING)
 (value,DECEASED)
 (value,DECEASED)
 (value,LIVING)
 But when I try to filter it (FILTER A BY status MATCHES 'DECEASED') 
 I get the following error:
 2013-08-23 08:47:16,290 [Thread-4] WARN  
 org.apache.hadoop.mapred.LocalJobRunner - job_local_0001
 java.lang.ClassCastException: org.apache.pig.data.BinSedesTuple cannot be 
 cast to java.lang.String
 at 
 org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.PORegexp.getNext(PORegexp.java:84)
 at 
 org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POFilter.getNext(POFilter.java:148)
 at 
 org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator.processInput(PhysicalOperator.java:290)
 at 
 org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POForEach.getNext(POForEach.java:233)
 at 
 org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapReduce$Reduce.runPipeline(PigGenericMapReduce.java:460)
 ...
 There are two StackOverFlow questions related to this:
 http://stackoverflow.com/questions/18407248/cce-binsedestuple-cannot-be-cast-to-string?lq=1
 http://stackoverflow.com/questions/18391552/cqlstorage-generates-wrong-pig-schema?lq=1

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira