openinx commented on issue #3079: URL: https://github.com/apache/iceberg/issues/3079#issuecomment-914159475
@shengkui I think you need to use the master branch to build the latest flink-iceberg-runtime jar because the PR #2666 was got merged only in master branch now ( Not get released in 0.12.0). I tried to use the connector to executing the following SQL: ```shell ./bin/sql-client.sh embedded -j /Users/openinx/software/apache-iceberg/flink-runtime/build/libs/iceberg-flink-runtime-5f90476.jar shell Flink SQL> CREATE TABLE iceberg_table ( > id BIGINT, > data STRING > ) WITH ( > 'connector'='iceberg', > 'catalog-name'='hive_prod', > 'uri'='thrift://localhost:9083', > 'warehouse'='file:///Users/openinx/test/iceberg-warehouse' > ); [INFO] Table has been created. Flink SQL> INSERT INTO iceberg_table values (1, 'AAA'), (2, 'BBB'), (3, 'CCC'); [INFO] Submitting SQL update statement to the cluster... [INFO] Table update statement has been successfully submitted to the cluster: Job ID: c9742d48cbd35502f9a3093d0d668543 Flink SQL> select * from iceberg_table ; +----+------+ | id | data | +----+------+ | 1 | AAA | | 2 | BBB | | 3 | CCC | +----+------+ 3 rows in set ``` All seems OK. -- 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]
