6

我正在尝试在 Glue 目录中创建一个表,其中包含来自使用 hive 在 EMR 中运行的 spark 的 s3 路径位置。我尝试了以下命令,但收到错误:

pyspark.sql.utils.AnalysisException:u'java.lang.IllegalArgumentException:无法从空字符串创建路径;'

sparksession.sql("CREATE TABLE IF NOT EXISTS abc LOCATION 's3://my-bucket/test/' as (SELECT * from my_table)")

sparksession.sql("CREATE TABLE abcSTORED AS PARQUET LOCATION 's3://my-bucket/test/' AS select * from my_table")

sparksession.sql("CREATE TABLE abcas SELECT * from my_table USING PARQUET LOCATION 's3://my-bucket/test/'")

有人可以建议我缺少的参数吗?

4

1 回答 1

4

当在没有指定位置的情况下创建数据库时会出现此问题:

CREATE DATABASE db_name;

要解决此问题,请在创建数据库时指定位置:

CREATE DATABASE db_name LOCATION 's3://my-bucket/db_path';

然后,创建一个表:

USE db_name;
CREATE TABLE IF NOT EXISTS abc LOCATION 's3://my-bucket/db_path/abc' as (SELECT * from my_table)
于 2020-11-25T09:02:14.113 回答