Just trying to run simple example using pig 0.8.0 and Cloudera Hadoop CDH3. I set all my PIG_X variables. Any idea what may be wrong?

export PIG_RPC_PORT=9160
export PIG_INITIAL_ADDRESS=localhost
export PIG_PARTITIONER=org.apache.cassandra.dht.RandomPartitioner

rows = load 'cassandra://Keyspace/MyColumnFamily/' USING CassandraStorage();
dump rows;

task_201103161955_0013_m_000000  
<http://localhost:50030/taskdetails.jsp?jobid=job_201103161955_0013&tipid=task_201103161955_0013_m_000000>
  FAILED

java.lang.NumberFormatException: null
        at java.lang.Integer.parseInt(Integer.java:417)
        at java.lang.Integer.parseInt(Integer.java:499)
        at 
org.apache.cassandra.hadoop.ConfigHelper.getRpcPort(ConfigHelper.java:233)
        at 
org.apache.cassandra.hadoop.pig.CassandraStorage.setConnectionInformation(Unknown
 Source)
        at org.apache.cassandra.hadoop.pig.CassandraStorage.setLocation(Unknown 
Source)
        at 
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigInputFormat.mergeSplitSpecificConf(PigInputFormat.java:133)
        at 
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigInputFormat.createRecordReader(PigInputFormat.java:111)
        at org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:588)
        at org.apache.hadoop.mapred.MapTask.run(MapTask.java:305)
        at org.apache.hadoop.mapred.Child.main(Child.java:170)


Reply via email to