[jira] [Created] (DRILL-6337) Kafka plugin, jdbc drill: NoClassDefFoundError: org/apache/hadoop/io/Text

["Don Tavoletti (JIRA)" <ji...@apache.org>]

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)