如何使用JDBC API捕获配置单元退出状态或错误代码

Question

使用JDBC API在配置单元中执行insert查询。但查询未运行。谁能告诉我哪里出了问题。另外，请告诉我如何在运行查询时捕获hive抛出的错误代码。配置单元版本0.13.0

当我在命令行中运行日志中生成的查询时，它们运行良好。

public static void onSuccess() {
        // Write to log on Success
        LOGGER.info("Job Succeeded, Updating the " + hiveDB + "." + logTable + " with status SUCCESS");
        String insertOnSuccess = "insert into table " + hiveDB + "." + logTable + " select " + currentJobID + "," + "'"
                + startTime + "'" + "," + "'" + stopTime + "'" + "," + runTime + "," + "\'SUCCESS\' from " + hiveDB
                + "." + "dual" + " limit 1; ";
        commonDB.InsertToTable(insertOnSuccess);
        JobMailer.PostMail("IB Load Successfully completed", "Load completed");

    }


public void InsertToTable(String insertquery) {
        try {

            stm = hiveConn.createStatement();
            stm.executeUpdate(insertquery);
        } catch (SQLException e) {
            LOGGER.error("Running the insert query for :" + insertquery);
        } catch (Exception e) {
            LOGGER.error(e.getMessage());
        } finally {
            if (stm != null) {
                try {
                    stm.close();
                } catch (SQLException e) {
                    LOGGER.error(e.getMessage());
                    ;
                }
            }
        }
    }

以下是我的错误日志：

16/02/12 12:31:09错误HiveConnector.CommondButilities：运行插入查询y：insert into table INSTALLBASE.IB_LOG select 25,“2016-02-12 12:26:43.037”,“2016-02-12 12:31:09.057”,22982400,INSTALLBASE.DUAL limit 1“成功”；16/02/12 12:31:09信息HiveConnector.JobMailer：发送带有：ib Load Succe ssfully完成16/02/12 12:31:09信息HiveConnector.MainApp：插入记录到installbase.data_usage_governance_log表16/02/12 12:31:10错误HiveConnector.CommondButilities：运行insert查询y：insert到表installbase.data_usage_governance_log select data_asset_reference,File_Name,Origin_System,Transfer_System,“

Answer 1

很遗憾你被Hive0.13卡住了，因为...

从配置单元0.14.0开始，HiveServer2操作日志可用于Beeline客户端。https://cwiki.apache.org/confluence/display/hive/hiveserver2+clients#hiveserver2clients-hiveserver2logging

一旦日志分派在服务器端被激活，您就可以从Java代码中检索这些日志条目--或者异步地检索，或者在执行结束时以类似...

  private static void DumpHiveMessages (java.sql.Statement stmtGeneric)
  { org.apache.hive.jdbc.HiveStatement stmtExtended ;
    try
    { stmtExtended =(org.apache.hive.jdbc.HiveStatement)stmtGeneric ;
      for (String sLogMessage : stmtExtended.getQueryLog())
      { JustTraceIt("HIVE SAYS>" +sLogMessage) ;    } 
      if (stmtExtended.hasMoreLogs())
      { JustTraceIt("WARNING>(...log stream still open...") ; }
    }
    catch (Exception duh)
    { JustTraceIt("WARNING>Error while accessing Hive log stream");
      JustTraceIt("WARNING>" +MakeSenseOfDirtyHadoopException(duh)) ;
    }
  }

这些东西并没有真正的文档化，但是有HiveStatement的源代码，它显示了几个非JDBC标准的html" target="_blank">方法，比如GetQueryLog和HasMoreLogs--还有用于Hive2+的GetYarnatsGuid和用于Hive3+的其他东西。
这里是指向GitHub上的“master”分支的链接，可以切换到您使用的任何版本（可能是旧版本1.2，以兼容Spark）。