hadoop - hive jdbc抛出 “Error running query: java.lang.NullPointerException”

Question

FROM cr_expanded_crcs_halen c INSERT OVERWRITE TABLE merge_result SELECT 'crcs', operator_id, instance_id, ts, user, application, actualconn, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL

我尝试使用带有dbc的以上sql将数据插入表merge_result，发现错误如下

Exception in thread "main" java.sql.SQLException: Error running query: java.lang.NullPointerException
at org.apache.hive.jdbc.Utils.verifySuccess(Utils.java:159)
at org.apache.hive.jdbc.Utils.verifySuccessWithInfo(Utils.java:147)
at org.apache.hive.jdbc.HiveStatement.execute(HiveStatement.java:182)
at org.apache.solr.handler.dataimport.scheduler.HiveClient.main(HiveClient.java:63)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:601)
at com.intellij.rt.execution.application.AppMain.main(AppMain.java:120)

但数据已成功插入。
有谁能帮助我？

Answer 1

我有同样的错误。
不幸的是，我找不到失败的原因，但是我找到了解决方法。
当您在以JDBC为基础的select语句中使用单词NULL时，就会出现问题，我的难看的解决方案是用udf“null_value()”替换NULL。

我将为此问题开一个吉拉

@Description(name="null_value", value="_FUNC() return null")
@UDFType(deterministic=true, stateful=false)
public class NullValue extends GenericUDF {


    @Override
    public ObjectInspector initialize(ObjectInspector[] arguments)
            throws UDFArgumentException {
        return PrimitiveObjectInspectorFactory.javaStringObjectInspector;
    }

    @Override
    public Object evaluate(DeferredObject[] arguments) throws HiveException {
        return null;
    }

    @Override
    public String getDisplayString(String[] children) {
        return "keys_to_lower_"+children[0];
    }

}

谢谢，
加博