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)