Replies: 8 comments 2 replies
-
what other information is required? |
Beta Was this translation helpful? Give feedback.
-
I believe you need to use |
Beta Was this translation helpful? Give feedback.
-
Your property
|
Beta Was this translation helpful? Give feedback.
-
Thank for your help ... that change made another empty table. I'm just interested in reading a parquet file in trino? |
Beta Was this translation helpful? Give feedback.
-
Set-up minio data store with parquet file Weather.parquet from here so you put your data in minio right? and want to read data from minio using trino? you might use s3a instead s3 I guess CREATE TABLE datalake.weather.weather_table ( |
Beta Was this translation helpful? Give feedback.
-
...from here so you put your data in minio right? SQL Error [16777216]: Query failed (#20240502_141556_00015_sfafn): Got exception: org.apache.hadoop.fs.UnsupportedFileSystemException No FileSystem for scheme "s3" ... with 3a SQL Error [16777216]: Query failed (#20240502_141707_00016_sfafn): Got exception: org.apache.hadoop.fs.FileAlreadyExistsException Path is a file: s3a://datalake/Weather.parquet |
Beta Was this translation helpful? Give feedback.
-
Here's my stack ... |
Beta Was this translation helpful? Give feedback.
-
did you init schema? Yes |
Beta Was this translation helpful? Give feedback.
-
Set-up minio data store with parquet file Weather.parquet
-Can Access file from duckdb
SELECT count(1) FROM 's3://datalake/Weather.parquet';
=> 366
When attempting the same in trino get 0 rows ... please advise
Catalog File ...
connector.name=hive
hive.metastore=file
hive.s3-file-system-type=TRINO
hive.metastore.catalog.dir=s3://datalake/
hive.s3.aws-access-key=xxx
hive.s3.aws-secret-key=xxx
hive.s3.endpoint=127.0.0.1:9000
hive.s3.path-style-access=true
hive.s3.ssl.enabled=false
All below runs wo error and not finding errors in logs (INFO or DEBUG)
drop schema datalake.weather;
CREATE SCHEMA datalake.weather
WITH (location = 's3://datalake/');
drop table datalake.weather.weather_table;
CREATE TABLE datalake.weather.weather_table (
MinTemp DOUBLE,
MaxTemp DOUBLE,
Rainfall DOUBLE,
Evaporation DOUBLE,
Sunshine VARCHAR,
WindGustDir VARCHAR,
WindGustSpeed VARCHAR,
WindDir9am VARCHAR,
WindDir3pm VARCHAR,
WindSpeed9am VARCHAR,
WindSpeed3pm BIGINT,
Humidity9am BIGINT,
Humidity3pm BIGINT,
Pressure9am DOUBLE,
Pressure3pm DOUBLE,
Cloud9am BIGINT,
Cloud3pm BIGINT,
Temp9am DOUBLE,
Temp3pm DOUBLE,
RainToday VARCHAR,
RISK_MM DOUBLE,
RainTomorrow VARCHAR
)
WITH (
format = 'parquet',
external_location = 's3://datalake/Weather.parquet'
);
select count(1) from datalake.weather.weather_table;
=> 0
Beta Was this translation helpful? Give feedback.
All reactions