Hi Mike,
UNSIGNED_FLOAT is mapped to Float dataype of Pig.
https://github.com/apache/phoenix/blob/4.0/phoenix-pig/src/main/java/org/apache/phoenix/pig/util/TypeUtil.java#L77
There seems to be an issue. I have raised this ticket
https://issues.apache.org/jira/browse/PHOENIX-1464 .
Regards
Ravi
On Mon, Nov 17, 2014 at 3:25 PM, Mike Friedman <[email protected]>
wrote:
> Hi,
>
> I am wondering what Pig data type I should use with a Phoenix
> UNSIGNED_FLOAT column. "float" in the load statement results in an error
>
> 2014-11-17 14:30:55,098 FATAL [IPC Server handler 11 on 32806]
> org.apache.hadoop.mapred.TaskAttemptListenerImpl: Task:
> attempt_1415884152130_0045_m_000000_0 - exited :
> org.apache.phoenix.schema.IllegalDataException
> at
> org.apache.phoenix.schema.PDataType$UnsignedFloatCodec.decodeFloat(PDataType.java:6430)
> at
> org.apache.phoenix.schema.PDataType$7.toObject(PDataType.java:1051)
> at
> org.apache.phoenix.schema.PDataType$7.toObject(PDataType.java:924)
> at
> org.apache.phoenix.schema.PDataType.toObject(PDataType.java:6914)
> at
> org.apache.phoenix.schema.PDataType$20.toObject(PDataType.java:2791)
> at
> org.apache.phoenix.schema.PDataType.toObject(PDataType.java:6930)
> at
> org.apache.phoenix.compile.ExpressionProjector.getValue(ExpressionProjector.java:75)
> at
> org.apache.phoenix.jdbc.PhoenixResultSet.getObject(PhoenixResultSet.java:482)
> at
> org.apache.phoenix.pig.hadoop.PhoenixRecord.read(PhoenixRecord.java:94)
> at
> org.apache.phoenix.pig.hadoop.PhoenixRecordReader.nextKeyValue(PhoenixRecordReader.java:130)
> at
> org.apache.phoenix.pig.PhoenixHBaseLoader.getNext(PhoenixHBaseLoader.java:190)
> at
> org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigRecordReader.nextKeyValue(PigRecordReader.java:211)
> at
> org.apache.hadoop.mapred.MapTask$NewTrackingRecordReader.nextKeyValue(MapTask.java:553)
> at
> org.apache.hadoop.mapreduce.task.MapContextImpl.nextKeyValue(MapContextImpl.java:80)
> at
> org.apache.hadoop.mapreduce.lib.map.WrappedMapper$Context.nextKeyValue(WrappedMapper.java:91)
> at org.apache.hadoop.mapreduce.Mapper.run(Mapper.java:144)
> at org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:784)
> at org.apache.hadoop.mapred.MapTask.run(MapTask.java:341)
> at org.apache.hadoop.mapred.YarnChild$2.run(YarnChild.java:168)
> at java.security.AccessController.doPrivileged(Native Method)
> at javax.security.auth.Subject.doAs(Subject.java:415)
> at
> org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1614)
> at org.apache.hadoop.mapred.YarnChild.main(YarnChild.java:163)
>
> Thanks.
>
>
> Mike
>
