0
我準備了使用hive jdbc客戶端調用Hadoop DB的Java應用程序。 當我嘗試做像'select * from students'這樣的簡單查詢時,它工作正常。 但只要我添加一些條件語句(例如,在年齡> 10),它開始與例外如下回應:Hive jdbc驅動程序迴應非描述性消息
Caused by: java.sql.SQLException: Query returned non-zero code: 2, cause: FAILED: Execution Error, return code 2 from org.apache.hadoop.hive.ql.exec.mr.MapRedTask
at org.apache.hadoop.hive.jdbc.HiveStatement.executeQuery(HiveStatement.java:194)
at org.springframework.jdbc.core.JdbcTemplate$1QueryStatementCallback.doInStatement(JdbcTemplate.java:441)
at org.springframework.jdbc.core.JdbcTemplate.execute(JdbcTemplate.java:396)
... 29 more
唯一可能的原因是我在谷歌發現它缺少庫。但對我來說,看起來很奇怪,我需要額外的lib來處理更復雜的查詢。
以防萬一,這裏是從的build.gradle
compile "org.springframework:spring-core:"+spring_version
compile "org.springframework:spring-beans:"+spring_version
compile "org.springframework:spring-context:"+spring_version
compile "org.springframework:spring-jdbc:"+spring_version
compile "commons-io:commons-io:2.1"
compile 'org.apache.hadoop:hadoop-core:1.0.0'
compile 'org.apache.hive:hive-jdbc:0.13.0'
compile 'org.apache.hive:hive-exec:0.13.0'
compile 'org.apache.hive:hive-service:0.13.0'
compile 'org.apache.hive:hive-metastore:0.13.0'
compile 'org.apache.thrift:libfb303:0.9.2'
compile 'org.apache.thrift:libthrift:0.9.2'
compile 'log4j:log4j:1.2.15'
compile 'org.antlr:antlr-runtime:3.5'
compile 'org.apache.derby:derby:10.10.1.1'
compile 'javax.jdo:jdo2-api:2.3-eb'
compile 'jpox:jpox:1.1.9'
compile 'jpox:jpox:1.1.9'
和Spring配置的依存列表JDBC模板
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:c="http://www.springframework.org/schema/c"
xmlns:context="http://www.springframework.org/schema/context"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.2.xsd">
<bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
<property name="location">
<value>classpath:spring/application.properties</value>
</property>
</bean>
<context:component-scan base-package="com.sample" />
<!-- basic Hive driver bean -->
<bean id="hive-driver" class="org.apache.hadoop.hive.jdbc.HiveDriver" />
<bean id="hiveSource"
class="org.springframework.jdbc.datasource.SimpleDriverDataSource"
c:driver-ref="hive-driver" c:url="${hadoop.jdbc.driver.path}"
c:username="${hadoop.login}" c:password="${hadoop.password}" />
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate"
c:data-source-ref="hiveSource" />
<bean id="hiveDao" class="com.sample.dao.HiveDao">
<property name="jdbcTemplate" ref="jdbcTemplate" />
</bean>
<bean id="hiveClient" class=" com.sample.client.HiveClient">
<property name="hiveDao" ref="hiveDao" />
</bean>
</beans>
請告知或與工作實例分享。
最好的問候, 亞歷