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: [email protected]

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



---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to