[
https://issues.apache.org/jira/browse/FLINK-28036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-28036:
-----------------------------
Description:
In HiveInspectors, we will create Hive's ConstantObjectInspector by passing
writable type such as ByteWritable, DoubleWritable, all of the writable class
are classes of package org.apache.hadoop.io. But the Hive's
ConstantObjectInspector may require different class such as
WritableConstantDoubleObjectInspector require class
org.apache.hadoop.hive.serde2.io.DoubleWritable, which is class of package
org.apache.hadoop.hive.serde2.io.DoubleWritable. Then when touch such code, it
will throw "no such method exception:
org.apache.hadoop.hive.serde2.objectinspector.primitive.WritableConstantDoubleObjectinspector.<init>(org.apache.hadoop.io.DoubleWritable).
I found ByteWritable, ShortWritable, DoubleWritable should be the class in
package of `class org.apache.hadoop.hive.serde2.io` instead of
`org.apache.hadoop.io`.
was:In
> HiveInspectors should use correct writable type to creaet
> ConstantObjectInspector
> ---------------------------------------------------------------------------------
>
> Key: FLINK-28036
> URL: https://issues.apache.org/jira/browse/FLINK-28036
> Project: Flink
> Issue Type: Sub-task
> Components: Connectors / Hive
> Reporter: luoyuxia
> Priority: Major
> Fix For: 1.16.0
>
>
> In HiveInspectors, we will create Hive's ConstantObjectInspector by passing
> writable type such as ByteWritable, DoubleWritable, all of the writable class
> are classes of package org.apache.hadoop.io. But the Hive's
> ConstantObjectInspector may require different class such as
> WritableConstantDoubleObjectInspector require class
> org.apache.hadoop.hive.serde2.io.DoubleWritable, which is class of package
> org.apache.hadoop.hive.serde2.io.DoubleWritable. Then when touch such code,
> it will throw "no such method exception:
> org.apache.hadoop.hive.serde2.objectinspector.primitive.WritableConstantDoubleObjectinspector.<init>(org.apache.hadoop.io.DoubleWritable).
>
> I found ByteWritable, ShortWritable, DoubleWritable should be the class in
> package of `class org.apache.hadoop.hive.serde2.io` instead of
> `org.apache.hadoop.io`.
>
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
