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

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

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


   @qq564567484 @iQiuyu-0821 @asnowfox @erictan90 ,  I tried to reproduce this issue in my host, by the following command but failed to get the same stacktrace as you said ( it works correctly): 
   
   ```
   #
   # This add mutiple iceberg flink runtime jar and mutiple iceberg catalog jars in the same classpath.
   # 
   ./bin/sql-client.sh embedded -j /Users/openinx/software/apache-iceberg/flink-runtime/build/libs/iceberg-flink-runtime-0.5.0-1598-g838cc65.jar \
   -j /Users/openinx/software/apache-iceberg/flink-runtime/build/libs/iceberg-flink-runtime-0.5.0-1610-gc492ec0.jar \
   -j /Users/openinx/software/apache-iceberg/flink/build/libs/iceberg-flink-0.5.0-1534-g868d7a2.jar \
   -j /Users/openinx/software/apache-iceberg/core/build/libs/iceberg-core-0.5.0-1534-g868d7a2.jar  \
   shell
   
   
   Flink SQL> CREATE TABLE iceberg_table (
   >   id  BIGINT,
   >   data STRING
   > ) WITH (
   >   'connector'='iceberg',
   >   'catalog-type'='hadoop',
   >   'catalog-name'='hadoop_catalog',
   >   'warehouse'='file:///Users/openinx/test/iceberg-warehouse'
   > );
   [INFO] Table has been created.
   
   Flink SQL> select * from iceberg_table;
   +----+------+
   | id | data |
   +----+------+
   |  1 |    d |
   |  1 |    b |
   |  1 |    a |
   |  1 |    a |
   |  1 |    c |
   +----+------+
   5 rows in set
   
   Flink SQL> insert into iceberg_table values (1, 'e');
   [INFO] Submitting SQL update statement to the cluster...
   [INFO] Table update statement has been successfully submitted to the cluster:
   Job ID: a223cbe4e5f32688bfc2577f2161b6ac
   
   Flink SQL> set execution.type = streaming;
   [INFO] Session property has been set.
   
   Flink SQL> insert into iceberg_table values (1, 'f');
   [INFO] Submitting SQL update statement to the cluster...
   [INFO] Table update statement has been successfully submitted to the cluster:
   Job ID: bbd88410d6bc8450b3beadcfe9659137
   
   Flink SQL> select * from iceberg_table;
   +----+------+
   | id | data |
   +----+------+
   |  1 |    d |
   |  1 |    b |
   |  1 |    e |
   |  1 |    a |
   |  1 |    f |
   |  1 |    a |
   |  1 |    c |
   +----+------+
   7 rows in set
   ```
   
   Could you show me the correct step how to reproduce this class loader issues ?  I'm glad to dig the reason why it breaks.


-- 
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