Hi
I'm trying to write data into a phoenix table via a Pig Script. The table
is created correctly , but the pig statement
STORE INTO ' hbase://$table_name/$col_list'
using org.apache.phoenix.pig.PhoenixHBaseStorage('zk', 'batchsize -500');
fails with the following error log:
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
> *Error: java.lang.RuntimeException:
> org.apache.phoenix.schema.ColumnFamilyNotFoundException: ERROR 1001
> (42I01): Undefined column family. familyName= C at
> org.apache.phoenix.mapreduce.PhoenixOutputFormat.getRecordWriter(PhoenixOutputFormat.java:58)
> at
> org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigOutputFormat.getRecordWriter(PigOutputFormat.java:83)
> at
> org.apache.hadoop.mapred.ReduceTask$NewTrackingRecordWriter.<init>(ReduceTask.java:548)
> at
> org.apache.hadoop.mapred.ReduceTask.runNewReducer(ReduceTask.java:622)
> at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:390) at
> org.apache.hadoop.mapred.YarnChild$2.run(YarnChild.java:164) at
> java.security.AccessController.doPrivileged(Native Method) at
> javax.security.auth.Subject.doAs(Subject.java:422) at
> org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1698)
> at org.apache.hadoop.mapred.YarnChild.main(YarnChild.java:158)Caused
> by: org.apache.phoenix.schema.ColumnFamilyNotFoundException: ERROR 1001
> (42I01): Undefined column family. familyName= C at
> org.apache.phoenix.schema.PTableImpl.getColumnFamily(PTableImpl.java:836)
> at
> org.apache.phoenix.util.PhoenixRuntime.getColumnInfo(PhoenixRuntime.java:474)
> at
> org.apache.phoenix.util.PhoenixRuntime.generateColumnInfo(PhoenixRuntime.java:420)
> at
> org.apache.phoenix.mapreduce.util.PhoenixConfigurationUtil.getUpsertColumnMetadataList(PhoenixConfigurationUtil.java:237)
> at
> org.apache.phoenix.mapreduce.util.PhoenixConfigurationUtil.getUpsertStatement(PhoenixConfigurationUtil.java:253)
> at
> org.apache.phoenix.mapreduce.PhoenixRecordWriter.<init>(PhoenixRecordWriter.java:51)
> at
> org.apache.phoenix.mapreduce.PhoenixOutputFormat.getRecordWriter(PhoenixOutputFormat.java:55)
> ... 9 more.*
I've checked the Phoenix create DDL and there seems to be no issue with the
column family there. Any help is appreciated.
Thanks
Parth S
