【问题标题】:Apache Drill JDBC Java Client ExceptionApache Drill JDBC Java 客户端异常
【发布时间】:2016-07-11 03:33:39
【问题描述】:

我是 Apache Drill 的新手,并且可以很好地设置它以在本地以嵌入式模式和通过 Web 界面运行。但是,在尝试使用 JDBC 通过 Java 客户端访问时遇到以下问题。

按照钻探文档和这里的一些帖子,我的设置如下:

<dependency>
    <groupId>org.apache.drill.exec</groupId>
    <artifactId>drill-jdbc</artifactId>
    <version>1.7.0</version>
</dependency>

代码:

public static void main(String[] args) {
  Class.forName("org.apache.drill.jdbc.Driver");
  **Connection connection = DriverManager.getConnection("jdbc:drill:zk=local");**
  Statement st = connection.createStatement();
  ResultSet rs = st.executeQuery("SELECT * from cp.`employee` LIMIT 10");
  while (rs.next()) {
    System.out.println(rs.getString(1));
  }
...

没有编译问题,但是,在运行上述代码时,我在上面代码的突出显示部分收到以下 OutOfMemoryException:

Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/drill/exec/exception/OutOfMemoryException
 at org.apache.drill.jdbc.impl.DrillJdbc41Factory.newDrillConnection(DrillJdbc41Factory.java:64)
 at org.apache.drill.jdbc.impl.DrillFactory.newConnection(DrillFactory.java:69)
 at net.hydromatic.avatica.UnregisteredDriver.connect(UnregisteredDriver.java:126)
 at org.apache.drill.jdbc.Driver.connect(Driver.java:72)
 at java.sql.DriverManager.getConnection(DriverManager.java:664)
 at java.sql.DriverManager.getConnection(DriverManager.java:270)
 at com.mapr.drill.DrillJDBCExample.runMode1(DrillJDBCExample.java:49)
 at com.mapr.drill.DrillJDBCExample.main(DrillJDBCExample.java:21)
 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
 at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
 at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
 at java.lang.reflect.Method.invoke(Method.java:497)
 at com.intellij.rt.execution.application.AppMain.main(AppMain.java:134)
Caused by: java.lang.ClassNotFoundException: org.apache.drill.exec.exception.OutOfMemoryException
 at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
 at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
 at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:331)
 at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
 ... 13 more

我是通过在本地运行的钻头做到这一点的。还尝试将 jdbc url 更改为 "jdbc:drill:drillbit=localhost";

请帮忙。

【问题讨论】:

  • 你是在windows机器还是Linux上工作?
  • 对我来说似乎是一个构建问题。请确保mvn clean install -DskipTests 成功。由于钻头在本地运行,因此请尝试使用"jdbc:drill:drillbit=localhost"你也提到过
  • mvn 命令运行良好。没有可跳过的测试。还尝试了在本地启动的带有钻头的 localhost 钻头。还尝试将 localhost 更改为 ip 地址。

标签: apache jdbc apache-drill java-client


【解决方案1】:

我假设您尝试在您的类路径中查询employee.json 文件并启用 cp 存储插件。

那么你的查询应该是

SELECT * from cp.`employee.json` LIMIT 10

编辑:

尝试一件事,只需在您的项目中添加位于&lt;drill-directory&gt;/jars/jdbc-driverdrill-jdbc-all-1.7.0.jar 并尝试您的JDBC 代码。这个 jar 与所有依赖的 jar 捆绑在一起。

【讨论】:

  • 感谢开发者。我已经尝试过这个查询,但有同样的例外。
  • 如果有错误请纠正我,但代码中提供的 jdbc URL 应该会导致钻取查询中的employee.json 文件,不是吗?文件在类路径中有什么关系?
  • @user3638201 用钻创建 JDBC 连接与类路径无关。当钻运行时,转到localhost:8047/storage,您将看到存储插件。您可以查询 Enabled Storage Plugins 下的那些。检查插件的详细信息:drill.apache.org/docs/storage-plugin-registration。根据查询,您正在使用 cp 插件名称,该名称实际上用于查询 Classpath 中的所有文件
  • 是的,cp 存储已启用,因为我一直在针对该存储插件运行命令行和浏览器查询。另外,之前我的意思是,如果文件已经在钻类路径中,那么就 java 客户端而言,没有其他类路径设置可以设置。查询存储插件应该注意从我想的第 3 方 foodmart jar 访问 employee.json 文件。
  • 是的,foodmart jaremployee.json 文件。
【解决方案2】:

使用drill-jdbc-all 代替drill-jdbc。下面是一个例子

<dependency>
        <groupId>org.apache.drill.exec</groupId>
        <artifactId>drill-jdbc-all</artifactId>
        <version>1.15.0</version>
        <exclusions>
            <exclusion>
                <groupId>org.slf4j</groupId>
                <artifactId>log4j-over-slf4j</artifactId>
            </exclusion>
        </exclusions>
    </dependency>

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2019-11-09
    • 2019-09-18
    • 1970-01-01
    相关资源
    最近更新 更多