Странная ошибка при использовании hive udf через клиент jdbc

все. Я столкнулся со странной ошибкой, когда использую hive udf через клиент jdbc.

У меня есть udf, который поможет мне преобразовать строку в формат метки времени с именем reformat_date. Сначала я выполняю ADD JAR и CREATE TEMPORARY FUNCTION, оба работают нормально.

SQL также может быть объяснен в режиме hive cli и может быть выполнен. Но при использовании клиента jdbc я получил ошибки:

    Query returned non-zero code: 10, cause: 
    FAILED: Error in semantic analysis: Line 1:283 Wrong arguments ''20121201000000'': 
    org.apache.hadoop.hive.ql.metadata.HiveException: 
    Unable to execute method public org.apache.hadoop.io.Text com.aa.datawarehouse.hive.udf.ReformatDate.evaluate(org.apache.hadoop.io.Text)  on object com.aa.datawarehouse.hive.udf.ReformatDate@4557e3e8 of class com.aa.datawarehouse.hive.udf.ReformatDate with arguments {20121201000000:org.apache.hadoop.io.Text} of size 1: 
    at com.aa.statistic.dal.impl.TjLoginDalImpl.selectAwakenedUserCount(TjLoginDalImpl.java:258)
    at com.aa.statistic.backtask.service.impl.UserBehaviorAnalysisServiceImpl.recordAwakenedUser(UserBehaviorAnalysisServiceImpl.java:326)
    at com.aa.statistic.backtask.controller.BackstatisticController$21.execute(BackstatisticController.java:773)
    at com.aa.statistic.backtask.controller.BackstatisticController$DailyExecutor.execute(BackstatisticController.java:823)

Мой SQL

select count(distinct a.user_id) as cnt from ( select user_id, user_kind, login_date, login_time from tj_login_hive where p_month = '2012_12' and login_date = '20121201' and user_kind = '0' ) a join ( select user_id from tj_login_hive where p_month <= '2012_12' and datediff(to_date(reformat_date(concat('20121201', '000000'))), to_date(reformat_date(concat(login_date, '000000')))) >= 90 ) b on a.user_id = b.user_id

Спасибо.


hadoop hive jdbc hiveql
person scarcer    schedule 28.12.2012    source источник

Ответы (1)


arrow_upward
0
arrow_downward

я думаю, что ваш udf выдал исключение. если reformat_date функция - это то, что вы делаете, вы должны проверить свою логику. если нет, вы должны проверить спецификацию udf.

person gimmesilver    schedule 04.04.2013
comment
reformat_date это мой udf. Я могу использовать его в оболочке улья, но не могу использовать его через клиент java JDBC. - person scarcer; 11.04.2013