如何使用impala或HiveJDBC驱动程序执行kudu查询(使用jdbctemplate.update方法)

nwsw7zdq  于 2021-06-21  发布在  Kudu
关注(0)|答案(0)|浏览(312)

当我试图在hivejdbc驱动程序的帮助下执行kudu查询时,我得到了一个异常。
java代码:

String createStmt =  "CREATE  TABLE IF NOT EXISTS cnxamd_core.a_9999_cnxa_hdfs_stats_V_2_forview(\n" +
            "bytes bigint COMMENT 'File Size in Bytes' ,\n" +
            "dat String COMMENT 'Date' ,\n" +
            "tm String COMMENT 'Time' ,\n" +
            "load_key String COMMENT 'LOAD_KEY AS DEFINED DURING WORKFLOW PROCESS' ,\n" +
            "fn String COMMENT 'File Name' ,CDL_DATETIME String COMMENT 'CDL_DATETIME' ,\n" +
            "CDL_SOURCE_FILE String COMMENT 'CDL_SOURCE_FILE' , \n" +
            "PRIMARY KEY (bytes)) \n" +
            "PARTITION BY HASH \n" +
            "PARTITIONS 2  \n" +
            "STORED AS KUDU";

    System.out.println("createStmt.. " + createStmt);

    hiveJdbcTemplate.update(createStmt);

错误:
java.sql.sqlexception:[cloudera]hivejdbcdriver处理查询/语句时出错。错误代码:40000,sql状态:tstatustatuscode:error_status,infomessages:[*org.apache.hive.service.cli.hivesqlexception:error while 编译语句:失败:parseexception行8:19无法识别enable spec中“)”分区“”by“附近的输入ification:17:16,org.apache.hive.service.cli.operation。operation:tosqlexception:操作。java:329,org.apache.hive.service.cli.operation.sqloperation:prepare:sqloperation。java:207,org.apache.hive.service.cli.operation.sqloperation:runinternal:sqloperation。java:290,org.apache.hive.service.cli.operation。operation:run:操作。java:260,org.apache.hive.service.cli.session.hivesessionimpl:executestatementinternal:hivesessionimpl。java:504,org.apache.hive.service.cli.session.hivesessionimpl:executestatementasync:hivesessionimpl。java:490,org.apache.hive.service.cli.cliservice:executestatementasync:cliservice。java:295,org.apache.hive.service.cli.thrift.thriftcliservice:executestatement:节俭服务。java:507,org.apache.hive.service.rpc.thrift.tcliservice$处理器$executestatement:getresult:t仪器。java:1437,org.apache.hive.service.rpc.thrift.tcliservice$处理器$executestatement:getresult:t仪器。java:1422,org.apache.thrift.proces网站sfunction:process:processfunction。java:39,org.apache.thrift.tbaseprocessor:process:t基础处理器。java:39,org.apache.hadoop.hive.thrift.hadoopthriftauthbridge$服务器$tugiasumingprocessor:process:hadoopthriftauthbridge。java:567,org.apache.thrift.server.tthreadpoolserver$工作erprocess:run:t线程池服务器。java:286,java.util.concurrent.threadpoolexecutor:runworker:threadpoolexecutor。java:1142,java.util.concurrent.threadpoolexecutor$worker:run:threadpoolexecutor。java:617,java.lang。thread:run:线程。java:745,*org.apache.hadoop.hive.ql.parse.parseexception:line 8:19无法识别enable spec中“)”分区“”by“”附近的输入ification:22:6,org.apache.hadoop.hive.ql.parse.parsedriver:parse:解析驱动程序。java:221,org.apache.hadoop.hive.ql.parse.parseutils:parse:parseutils。java:75,org.apache.hadoop.hive.ql.parse.parseutils:parse:parseutils。java:68,org.apache.hadoop.hive.ql。driver:compile:驱动器。java:564,org.apache.hadoop.hive.ql。driver:compileinternal:驱动器。java:1425,org.apache.hadoop.hive.ql。driver:compileandrespond:驱动器。java:1398,org.apache.hive.service.cli.operation.sqloperation:prepare:sqloperation。java:205], sqlstate:42000,

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题