0

我是 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";

请帮忙。

4

2 回答 2

0

使用 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>
于 2020-05-28T13:01:03.450 回答
0

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

那么你的查询应该是

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

编辑：

尝试一件事，只需在您的项目中添加drill-jdbc-all-1.7.0.jar并<drill-directory>/jars/jdbc-driver尝试您的 JDBC 代码。这个 jar 与所有依赖的 jar 捆绑在一起。

于 2016-07-11T04:59:03.127 回答