3

我试图执行一个小hive query的 from Java，但它失败并出现以下错误，当我复制相同的查询并在终端上运行时，它给了我结果。

有人可以帮我解决这个问题。

Java 代码：

Runtime.getRuntime().exec("hive -e 'show databases;'");

抛出的错误：

FAILED: ParseException line 1:5 cannot recognize input near '<EOF>' '<EOF>' '<EOF>' in ddl statement

问候， GHK。

4

1 回答 1

3

我一直在处理这个 Java 问题，我相信我已经解决了这个问题。基本上你失败的原因是环境变量没有正确启动。将以下内容放入您的/home/<username>/.bash_profile文件中并重新启动计算机以解决此问题。

HIVE_HOME=/usr/lib/hive

export HIVE_HOME

PATH=$PATH:$HIVE_HOME/bin/hive

export PATH

这将确保它们正确设置。

但是，虽然这将消除错误，但它仍然不会向您显示数据库列表，因为运行 hive 命令的进程将在后台运行，而不是在运行主程序的控制台上。以下代码将让您将程序的输出重定向到运行主程序的控制台。

package testing.console;

import java.io.IOException;
import java.lang.ProcessBuilder;
import java.util.Map;

import testing.console.OutputRedirector;

//This Works

public class ConsoleTester {

    /**
     * @param args
     * @throws IOException
     */
    public static void main(String[] args) throws IOException {

        ProcessBuilder hiveProcessBuilder = new ProcessBuilder("hive", "-e",
                "show databases");
        String path = processEnv.get("PATH");
        Process hiveProcess = hiveProcessBuilder.start();

        OutputRedirector outRedirect = new OutputRedirector(
                hiveProcess.getInputStream(), "HIVE_OUTPUT");
        OutputRedirector outToConsole = new OutputRedirector(
                hiveProcess.getErrorStream(), "HIVE_LOG");

        outRedirect.start();
        outToConsole.start();    
    }

}

以及用于将输出获取到控制台的 OutputRedirector 类。

package testing.console;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;

public class OutputRedirector extends Thread {

    InputStream is;
    String type;

    public OutputRedirector(InputStream is, String type){
        this.is = is;
        this.type = type;
    }
    @Override
    public void run() {
        try {
            InputStreamReader isr = new InputStreamReader(is);
            BufferedReader br = new BufferedReader(isr);
            String line = null;
            while ((line = br.readLine()) != null) {
                System.out.println(type + "> " + line);
            }
        } catch (IOException ioE) {

        }
    }

}
于 2013-11-12T19:52:11.080 回答