[GitHub] [iceberg] asnowfox commented on issue #2468: master branch - flink sql create hive catalog error

[GitBox <gi...@apache.org>]

asnowfox commented on issue #2468:
URL: https://github.com/apache/iceberg/issues/2468#issuecomment-927508700


   in my flink cluster. it runs like this:
   
   
   Flink SQL> CREATE CATALOG flow_catalog WITH (
   >   'type'='iceberg',
   >   'catalog-type'='hadoop',
   >   'warehouse'='hdfs://namenode-206-10:8020/warehouse/flows',
   >   'property-version'='1'
   > );
   2021-09-27 11:56:43,219 WARN  org.apache.hadoop.hdfs.shortcircuit.DomainSocketFactory      [] - The short-circuit local reads feature cannot be used because libhadoop cannot be loaded.
   [INFO] Catalog has been created.
   
   Flink SQL> use catalog flow_catalog;
   
   Flink SQL> CREATE DATABASE iceberg_db;
   [ERROR] Could not execute SQL statement. Reason:
   org.apache.iceberg.exceptions.AlreadyExistsException: Namespace already exists: iceberg_db
   
   Flink SQL> drop database iceberg_db;
   [ERROR] Could not execute SQL statement. Reason:
   org.apache.iceberg.exceptions.NamespaceNotEmptyException: Namespace iceberg_db is not empty.
   
   Flink SQL> use iceberg_db;
   
   Flink SQL> show tables;
   test
   
   Flink SQL> drop table test;
   [INFO] Table has been removed.
   
   Flink SQL> drop database iceberg_db;
   [INFO] Database has been removed.
   
   Flink SQL> CREATE DATABASE iceberg_db;
   [INFO] Database has been created.
   
   Flink SQL> USE iceberg_db;
   
   Flink SQL> CREATE TABLE test (
   >     id BIGINT COMMENT 'unique id',
   >     data STRING
   > );
   [INFO] Table has been created.
   
   Flink SQL> INSERT INTO test VALUES (1, 'a');
   [INFO] Submitting SQL update statement to the cluster...
   [INFO] Table update statement has been successfully submitted to the cluster:
   Job ID: 68bf513689c4920e2af3d49f4231945f
   
   
   Flink SQL> select * from test;
   [INFO] Result retrieval cancelled.
   
   Flink SQL> 
   > SET execution.type = batch;
   [INFO] Session property has been set.
   
   Flink SQL> select * from test;
   [ERROR] Could not execute SQL statement. Reason:
   java.lang.ClassCastException: org.apache.iceberg.hadoop.HadoopCatalog cannot be cast to org.apache.iceberg.catalog.Catalog
   
   Flink SQL>  set execution.type = streaming;
   [INFO] Session property has been set.
   
   Flink SQL> select * from test;
   [ERROR] Could not execute SQL statement. Reason:
   java.lang.ClassCastException: org.apache.iceberg.hadoop.HadoopCatalog cannot be cast to org.apache.iceberg.catalog.Catalog
   
   Flink SQL> 
   


-- 
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: issues-unsubscribe@iceberg.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@iceberg.apache.org
For additional commands, e-mail: issues-help@iceberg.apache.org