草庐IT

JDBC4Connection

全部标签

java - Hive jdbc.query(sql, rowmapper) 抛出 UnCatogarized 异常

我正在使用spring-jdbc模板来查询Hive-0.11.0以下代码效果很好。publicListlistStudents(){StringSQL="select*fromStudent";Liststudents=jdbcTemplateObject.query(SQL,newStudentMapper());returnstudents;}publicclassStudentMapperimplementsRowMapper{publicStudentmapRow(ResultSetrs,introwNum)throwsSQLException{Studentstudent=n

java - 使用jdbc在hive中插入map等复杂类型

我有一个java映射(Map)和一个到配置单元服务器的JDBC连接。服务器上表的架构包含一个Map类型的列。是否可以使用JDBC将javaMap插入到具有相似数据类型的hive表列?我试过:"createtabletest(keystring,valueMap)""insertintotabletestvalues('keywer',map('subkey','subvalue'))fromdummylimit1;"引用:Hiveinsertingvaluestoanarraycomplextypecolumn但插入失败:"Error:Errorwhilecompilingstatem

mysql - Spark : Exception in thread "main" java. lang.ClassNotFoundException : com. mysql.jdbc.Driver

我在spark中编写了一个简单的程序来将数据帧写入mySql中的表。程序如下:importorg.apache.spark.SparkConfimportorg.apache.spark.SparkContextimportorg.apache.spark.rdd.RDDimportorg.apache.spark.sql.SQLContextimportorg.apache.spark.sql.hive.HiveContextimportorg.apache.spark.SparkContext._importorg.apache.spark.rdd._//importorg.apa

java - 无法从 Web 应用程序通过 JDBC 连接到 HIVE

我已经使用JDBCapi连接到HIVE2,引用here,它是成功的,所以为了便于访问,我想围绕它创建一个webapp,使用JSP作为前端页面来输入服务器名称和查询。虽然所有参数都从JSP页面正确解析为servlet,但它在连接到所需的HIVE服务器时抛出错误将libthrift和hiveJARS放在WEB-INF/lib目录中,我将其放在WEB-INF/lib和类路径中。问题是因为hivejar首先出现在WEB-INF/lib中,并且因为它没有“org.apache.thrift.protocol.TProtocol.getScheme()”方法,所以我一直没有收到这样的方法错误。我提

hadoop - Hive JDBC 连接返回 "query did not generate a resultset"

我已经从git构建了hive-jdbc,并尝试执行基本的jdbc查询来获取结果集。由于某种原因,查询抛出以下异常。16/07/0122:08:12INFOUtils:Suppliedauthorities:localhost:1000016/07/0122:08:12INFOUtils:Resolvedauthority:localhost:1000016/07/0122:08:12DEBUGTSaslTransport:openingtransportorg.apache.thrift.transport.TSaslClientTransport@5536088816/07/0122

sql-server - 索引超出范围 : JDBC SqlServer exception

我正在使用Sqoop将数据从SQL服务器导入到本地HDFS。我正在使用一个简单的自由格式查询从表中提取大约10行。下面是我从终端执行的sqoop命令:sqoopimport--connect'jdbc:sqlserver://xx.xx.xx.xx;username=xx;password=xxxxx;database=DBName'--query"SELECTtop10OrderIDfromDJShopcart_OrderItemswhere\$CONDITIONS"--split-by"OrderID"--target-dir/work/gearpurchase当我从我的本地机器执

hadoop - OOZIE : Connection exception has occurred [ java.net.ConnectException 连接被拒绝(连接被拒绝)]

我正在尝试在以下工具的帮助下执行Oozie作业网址:https://www.safaribooksonline.com/library/view/apache-oozie/9781449369910/ch05.html执行时ooziejob-run-configtarget/example/job.properties获取错误为:Connectionexceptionhasoccurred[java.net.ConnectExceptionConnectionrefused(Connectionrefused)].Tryingafter1sec.Retrycount=1Connecti

java - Dropwizard 和 hive-jdbc 之间的不兼容

我正在尝试使用Dropwizard创建一个WSREST,以获取查询的Hive结果并以XML格式呈现。每个单独的部分都可以毫无错误地完成。当我加入所有内容时,我发现Dropwizard和hive-jdbc之间不兼容。显然hive-jdbc有jersey1作为依赖项,而Dropwizard有jersey2。我不确定这是否是问题所在。我试图排除pom.xml中的依赖项,但没有解决。我试图制作一个应用程序,只是将hive-jdbc作为依赖项放在pom.xml文件中,而不使用或导入代码的任何部分,但错误仍然发生。POM.XML3.0.04.0.0testws-test1.0.0ws-testUT

java - 使用 JDBC 和 Kerberos 身份验证连接到 Hive 时出现异常

我正在尝试使用Java中的JDBC和Kerberos身份验证连接到Hive。为此,我想出了以下代码。importjava.io.IOException;importjava.sql.Connection;importjava.sql.DriverManager;importjava.sql.SQLException;importorg.apache.hadoop.conf.Configuration;importorg.apache.hadoop.security.UserGroupInformation;publicclassDbManager{privatestaticConnec

jdbc - 使用 JDBC 连接到 Hadoop 中的命名队列

在AWS上安装Cloudera。尝试对其进行设置,使其具有多个命名队列,并且我可以使用JDBC连接到队列并执行查询。根据我目前收集到的信息,一旦队列在那里,使用JDBC连接到它们就相当简单,因为它只有以下格式:http://:/但是,在查看大量不同文档时并不清楚如何首先设置队列。似乎如果你有一个hadoop-site.xml文件,你可以进去并添加属性mapred.queue.name和一个逗号分隔的字符串。但是Cloudera没有那个文件。它确实有一个mapred-site.xml,但添加该属性然后转到命令行并询问队列列表仍然只是返回默认值。然后我们尝试使用FairScheduler,