2013-08-23 86 views
0

我試圖處理以下數據:CCE:BinSedesTuple不能轉換爲String

B = FOREACH A GENERATE FLATTEN(vitalStatus); 
DUMB B; 
(value,LIVING) 
(value,LIVING) 
(value,LIVING) 
(value,DECEASED) 
(value,LIVING) 
(value,DECEASED) 
(value,DECEASED) 
(value,LIVING) 

但是當我嘗試對其進行過濾(過濾器BY vitalStatus匹配'死者) 我在做什麼錯?

我收到以下錯誤:

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) 
... 
+0

什麼是輸出'DESCRIBE乙;'? – mr2ert

+0

B:{vitalStatus:chararray} – e90jimmy

+0

如果數據來自CqlStorage,cassandra客戶端是豬。 – e90jimmy

回答

1

CASSANDRA-5941

通過應用修訂解析爲亞歷克斯·雷,在我的票中提到:

git clone http://git-wip-us.apache.org/repos/asf/cassandra.git 
cd cassandra 
git checkout cassandra-1.2 
patch -p1 < 5867-bug-fix-filter-push-down-1.2-branch.txt 
ant 
相關問題