blackfaced opened a new issue, #8023:
URL: https://github.com/apache/gravitino/issues/8023

   ### Version
   
   main branch
   
   ### Describe what's wrong
   
   When following the Gravitino official documentation to run the Spark Iceberg 
Catalog example, I encountered the following error:
   java.lang.ClassCastException: org.apache.iceberg.aws.s3.S3InputFile cannot 
be cast to org.apache.iceberg.hadoop.HadoopInputFile
   Please see the attached screenshot for the full stack trace.
   
   ### Error message and/or stacktrace
   
   java.lang.ClassCastException: org.apache.iceberg.aws.s3.S3InputFile cannot 
be cast to org.apache.iceberg.hadoop.HadoopInputFile
       at org.apache.iceberg.parquet.ParquetBatchReader.build(Parquet.java:1156)
       at 
org.apache.iceberg.parquet.ParquetBatchReader.newParquetIterable(BaseBatchReader.java:108)
       ...
       (full stack trace in the screenshot)
   
   
![Image](https://github.com/user-attachments/assets/c605a802-2f33-420a-864b-94891ae93c37)
   
   ### How to reproduce
   
   Gravitino version: 1.0.0.SNAPSHOT
   Spark version: 3.5.1
   Iceberg version: 1.5.2
   Environment: [volc serverless 
spark](https://www.volcengine.com/docs/6491/1262176)+ tos
   
   ```sql
   set tqs.query.engine.type=sparkcli;
   SET 
spark.plugins=org.apache.gravitino.spark.connector.plugin.GravitinoSparkPlugin;
   SET spark.sql.gravitino.uri=http://xxxxx:8090;
   SET spark.sql.gravitino.metalake=test;
   SET spark.sql.gravitino.enableIcebergSupport=true;
   set spark.hadoop.hive.metastore.uris=thrift://xxxx;
   set las.spark.jar.depend.jars = 
[{"fileName":"tos://.../gravitino-spark-connector-runtime-3.5_2.12-1.0.0-SNAPSHOT.jar"},{"fileName":"tos://.../iceberg-aws-bundle-1.6.1.jar"},{"fileName":"tos://.....iceberg-spark-runtime-3.5_2.12-1.5.2.jar"}];
   set spark.sql.storeAssignmentPolicy=ANSI;
   
   USE catalog_iceberg_plb;
   CREATE DATABASE IF NOT EXISTS test_gravitino_db_202508071701;
   USE test_gravitino_db_202508071701;
   CREATE TABLE IF NOT EXISTS employee (
     id bigint,
     name string,
     department string,
     hire_date timestamp
   ) USING iceberg
   PARTITIONED BY (days(hire_date));
   DESC TABLE EXTENDED employee;
   
   INSERT INTO employee
   VALUES
   (1, 'Alice', 'Engineering', TIMESTAMP '2021-01-02 09:00:00'),
   (2, 'Bob', 'Marketing', TIMESTAMP '2021-02-02 10:30:00'),
   (3, 'Charlie', 'Sales', TIMESTAMP '2021-03-02 08:45:00');
   
   SELECT * FROM employee WHERE date(hire_date) = '2021-01-02';
                                                                                
    
   ```
   
   ### Additional context
   
   _No response_


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to