2017-02-22 11 views
1

この問題が発生しました:DB呼び出しはテーブルを作成するだけで、JDBC結果セットを取得する問題があります。 .verify.JDBC.resultでRJDBC dbGetQuery()外部テーブルを作成するためのエラーHIVE

エラー(rは、「JDBCを取得することができませんが、 コールの結果セット:dbGetQuery ... dbSendQuery - > dbSendQuery - > .localの - > .verify.JDBC.result 実行は

を停止しました
options(java.parameters = "-Xmx32g") 
    library(rJava) 
    library(RJDBC) 
    drv <- JDBC("org.apache.hive.jdbc.HiveDriver", "/tmp/r_jars/hive-jdbc.jar") 
    for(jar in list.files('/tmp/r_jars/')){ 
     .jaddClassPath(paste("/tmp/r_jars/",jar,sep="")) 
    } 

    conn <- dbConnect(drv, "jdbc:hive2://10.40.51.75:10000/default", "myusername", "mypassword") 

    createSCOREDDL_query <- "CREATE EXTERNAL TABLE hiveschema.mytable (
     myvariables 
    ) 
    ROW FORMAT SERDE 
    'com.bizo.hive.serde.csv.CSVSerde' 
    STORED AS INPUTFORMAT 
    'org.apache.hadoop.mapred.TextInputFormat' 
    OUTPUTFORMAT 
    'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat' 
    LOCATION 
    's3://mybucket/myschema/'" 

    dbGetQuery(conn, createSCOREDDL_query) 
    dbDisconnect(conn) 
+0

テーブルが作成された、適切なデータがS3バケットから割り当てられたが、これプロセスは常に停止してエラーを返すので、私はmultiplを作ることができません1つのRスクリプト内のテーブルを作成する代わりに、作成する必要がある各テーブルごとに1つのRスクリプトを作成する必要があります。 –

答えて

0

代わりのdbGetQuery私は同様の問題を有し、このスイッチは、問題を解決作っていた?dbSendUpdateを使用して試すことができます。

関連する問題