Афина бросает Симба JDBC 11300 с ALTER TABLE ADD PARTITION - PullRequest
Новая
       6

Афина бросает Симба JDBC 11300 с ALTER TABLE ADD PARTITION

1 голос
/ 02 октября 2019

Запуск ALTER TABLE ADD PARTITION с использованием драйвера Athena JDBC вызывает исключение, которое трудно понять, это код: 

package none;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.Properties;

public class test {

    public static void main(String[] args) throws Exception {
        Properties info = new Properties();

        info.put("User","myUser");
        info.put("Password","myPass");
        info.put("S3OutputLocation", "s3://my-bucket/output");

        Class.forName("com.simba.athena.jdbc.Driver");
        Connection connection = DriverManager.getConnection("jdbc:awsathena://AwsRegion=us-east-1;",info);

        Statement statement = connection.createStatement();
        ResultSet queryResults = statement.executeQuery("ALTER TABLE test01 ADD PARTITION (col2 = 'b') LOCATION 's3://my-bucket/col2=b/'");             
    }

}

Это ошибка, которую выдает код выше, обратите внимание, что запрос выполняется нормально в консоли Athena , если я копирую, вставляю его из сообщения об ошибке: 

Exception in thread "main" java.sql.SQLDataException: [Simba][JDBC](11300) A ResultSet was expected but not generated from query "ALTER TABLE test01 ADD PARTITION (col2 = 'b') LOCATION 's3://my-bucket/col2=b/'". Query not executed. 
    at com.simba.athena.exceptions.ExceptionConverter.toSQLException(Unknown Source)
    at com.simba.athena.jdbc.common.SStatement.checkCondition(Unknown Source)
    at com.simba.athena.jdbc.common.SStatement.executeNoParams(Unknown Source)
    at com.simba.athena.jdbc.common.SStatement.executeNoParams(Unknown Source)
    at com.simba.athena.jdbc.common.SStatement.executeQuery(Unknown Source)
    at none.test.main(test.java:22)

Однако, если я заменяю оператор простым SELECT, он работает нормально: 

//this works fine
ResultSet queryResults = statement.executeQuery("SELECT * FROM test01");
queryResults.next();
System.out.println(queryResults.getString("col1") + " -> " + queryResults.getString("col2"));

Вот определение таблицы: 

CREATE EXTERNAL TABLE test01 (
  `col1` string
) PARTITIONED BY (
  col2 string 
)
ROW FORMAT SERDE 'org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
WITH SERDEPROPERTIES (
  'serialization.format' = ',',
  'field.delim' = ','
) LOCATION 's3://my-bucket/'
TBLPROPERTIES ('has_encrypted_data'='false');

Используемая версия драйвера указана в документации Athena: https://s3.amazonaws.com/athena-downloads/drivers/JDBC/SimbaAthenaJDBC_2.0.9/AthenaJDBC42_2.0.9.jar

Любые мысли о том, как обратитьсяэто? Спасибо!

1 Ответ

2 голосов
/ 02 октября 2019

Вы, кажется, используете statement.executeQuery(...) для выполнения оператора SQL, который не является запросом.

Попробуйте вместо этого использовать statement.execute(...): 

    statement.execute("ALTER TABLE test01 ADD PARTITION (col2 = 'b') LOCATION 's3://my-bucket/col2=b/'");
...