You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@drill.apache.org by "Don Tavoletti (JIRA)" <ji...@apache.org> on 2018/04/17 18:08:00 UTC
[jira] [Created] (DRILL-6337) Kafka plugin, jdbc drill:
NoClassDefFoundError: org/apache/hadoop/io/Text
Don Tavoletti created DRILL-6337:
------------------------------------
Summary: Kafka plugin, jdbc drill: NoClassDefFoundError: org/apache/hadoop/io/Text
Key: DRILL-6337
URL: https://issues.apache.org/jira/browse/DRILL-6337
Project: Apache Drill
Issue Type: Bug
Components: Client - JDBC
Affects Versions: 1.12.0
Environment: I am using scala version 2.11.8 and running in IntelliJ IDEA.
I have the following dependencies:
"org.apache.drill.exec" % "drill-jdbc-all" % "1.1.0",
"org.slf4j" % "slf4j-log4j12" % "1.7.21",
"org.scalatest" % "scalatest_2.11" % "2.2.6"
Reporter: Don Tavoletti
Attachments: Main.scala
I am attempting to get information from a Kafka topic. I am able to get all information except for when I try to get information from a nested field.
I can do a select on any field except for the following field (ingestionStats) which is a nested field.
The following command works perfectly from: "Apache Drill Web Console", however from my scala app, it crashes.
select ingestionStats from kafka.`INGEST_STATUS`
When I call:
// Query kafka data
val resultSet: ResultSet = ourStatement.executeQuery(sqlCommand)
I get the following crash:
13:56:48.554 [main] DEBUG o.a.d.j.impl.DrillStatementRegistry - Auto-closing (via open-statements registry): org.apache.drill.jdbc.impl.DrillStatementImpl@1252d480
13:56:48.554 [main] DEBUG o.a.d.j.i.DrillResultSetImpl$ResultsListener - [#2] Query listener closing.
13:56:48.554 [main] DEBUG o.a.d.j.impl.DrillStatementRegistry - Removing from open-statements registry: org.apache.drill.jdbc.impl.DrillStatementImpl@1252d480
13:56:48.554 [main] DEBUG o.apache.drill.exec.rpc.BasicClient - Closing client
13:56:48.554 [Client-1] INFO o.a.drill.exec.rpc.user.UserClient - Channel closed /10.25.130.75:52762 <--> cdtskfka32u.rxcorp.com/162.44.24.145:31010.
13:56:48.570 [main] DEBUG o.a.c.f.imps.CuratorFrameworkImpl - Closing
13:56:48.570 [main] DEBUG o.a.curator.CuratorZookeeperClient - Closing
13:56:48.570 [main] DEBUG org.apache.curator.ConnectionState - Closing
13:56:48.570 [main] DEBUG org.apache.zookeeper.ZooKeeper - Closing session: 0x26287e724621a64
13:56:48.570 [main] DEBUG org.apache.zookeeper.ClientCnxn - Closing client for session: 0x26287e724621a64
13:56:48.585 [main-SendThread(10.121.48.202:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Reading reply sessionid:0x26287e724621a64, packet:: clientPath:null serverPath:null finished:false header:: 13,-11 replyHeader:: 13,365073887558,0 request:: null response:: null
13:56:48.585 [main-SendThread(10.121.48.202:2181)] DEBUG org.apache.zookeeper.ClientCnxn - An exception was thrown while closing send thread for session 0x26287e724621a64 : Unable to read additional data from server sessionid 0x26287e724621a64, likely server has closed socket
13:56:48.585 [main] DEBUG org.apache.zookeeper.ClientCnxn - Disconnecting client for session: 0x26287e724621a64
Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/hadoop/io/Text
at org.apache.drill.exec.util.JsonStringHashMap.<clinit>(JsonStringHashMap.java:39)
13:56:48.601 [main] INFO org.apache.zookeeper.ZooKeeper - Session: 0x26287e724621a64 closed
at org.apache.drill.exec.vector.complex.MapVector$Accessor.getObject(MapVector.java:295)
13:56:48.601 [main-EventThread] INFO org.apache.zookeeper.ClientCnxn - EventThread shut down
at org.apache.drill.exec.vector.accessor.GenericAccessor.getObject(GenericAccessor.java:38)
at org.apache.drill.exec.vector.accessor.AbstractSqlAccessor.getString(AbstractSqlAccessor.java:101)
at org.apache.drill.exec.vector.accessor.BoundCheckingAccessor.getString(BoundCheckingAccessor.java:119)
at org.apache.drill.jdbc.impl.TypeConvertingSqlAccessor.getString(TypeConvertingSqlAccessor.java:643)
at org.apache.drill.jdbc.impl.AvaticaDrillSqlAccessor.getString(AvaticaDrillSqlAccessor.java:88)
at net.hydromatic.avatica.AvaticaResultSet.getString(AvaticaResultSet.java:205)
at org.apache.drill.jdbc.impl.DrillResultSetImpl.getString(DrillResultSetImpl.java:182)
at DrillDemo.DrillJdbcTest$.method(Main.scala:60)
at DrillDemo.DrillJdbcTest$.main(Main.scala:12)
at DrillDemo.DrillJdbcTest.main(Main.scala)
Caused by: java.lang.ClassNotFoundException: org.apache.hadoop.io.Text
at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:335)
at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
... 12 more
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)