[jira] [Updated] (CARBONDATA-3550) Query carbondata table from presto shows error like 'Partition location does not exist: hdfs://xxx/hive_carbon3-__PLACEHOLDER__'

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Updated] (CARBONDATA-3550) Query carbondata table from presto shows error like 'Partition location does not exist: hdfs://xxx/hive_carbon3-__PLACEHOLDER__'

Akash R Nilugal (Jira)

     [ https://issues.apache.org/jira/browse/CARBONDATA-3550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

wupeng updated CARBONDATA-3550:
-------------------------------
    Issue Type: Task  (was: Bug)

> Query carbondata table from presto shows error like 'Partition location does not exist: hdfs://xxx/hive_carbon3-__PLACEHOLDER__'
> --------------------------------------------------------------------------------------------------------------------------------
>
>                 Key: CARBONDATA-3550
>                 URL: https://issues.apache.org/jira/browse/CARBONDATA-3550
>             Project: CarbonData
>          Issue Type: Task
>    Affects Versions: 1.6.0
>            Reporter: wupeng
>            Priority: Major
>
> Hello everyone, I'm a newbee in Carbondata, I read the document and I think you people are doing very create job, Carbondata is awesome!
>  
> I'm using Carbondata-1.6.0-rc3, I followed this hive-guide in carbondata official site and I can create carbondata table and load data to it in spark-shell, and I also can query it.
> But when I query the table in presto, the error accurs:
> {code:java}
> presto:default> select * from hive_carbon3;
> Query 20191018_055826_00071_j94n7 failed: Partition location does not exist: hdfs://mycluster/apps/hive/warehouse/hive_carbon3-__PLACEHOLDER__ {code}
> I'm using prestosql-315, so I miragated the presto-carbondata connector from prestodb-0.217.
> {code:java}
> below is how I create table and load data:
> import org.apache.spark.sql.SparkSession
> import org.apache.spark.sql.CarbonSession._
> val rootPath = "hdfs://mycluster/apps/hive"
> val storeLocation = s"$rootPath/store"
> val warehouse = s"$rootPath/warehouse"
> val metaStoreDB = s"$rootPath/metastore_db"
> val carbon = SparkSession.builder().enableHiveSupport().config("spark.sql.warehouse.dir", warehouse).config(org.apache.carbondata.core.constants.CarbonCommonConstants.STORE_LOCATION, storeLocation).getOrCreateCarbonSession(storeLocation, metaStoreDB)
>  
> carbon.sql("CREATE TABLE IF NOT EXISTS hive_carbon3(id int, name string, scale decimal, country string, salary double) STORED BY 'carbondata'")
> carbon.sql("LOAD DATA INPATH 'hdfs://mycluster/tmp/sample-hive_carbon.csv' INTO TABLE hive_carbon3")
> carbon.sql("SELECT * FROM hive_carbon3").show()
> {code}
>  
> Please help me, thank you very much!



--
This message was sent by Atlassian Jira
(v8.3.4#803005)