When I execute the following statement in Flink SQL client:
CREATE CATALOG rest_catalog WITH (
'type'='iceberg',
'catalog-type'='rest',
'uri'='http://localhost:8181'
);
USE CATALOG rest_catalog;
CREATE TABLE all_users_sink (
database_name STRING,
table_name STRING,
`id` DECIMAL(20, 0) NOT NULL,
name STRING,
address STRING,
phone_number STRING,
email STRING,
PRIMARY KEY (database_name, table_name, `id`) NOT ENFORCED
);
An error occurred:
[ERROR] Could not execute SQL statement. Reason: org.apache.iceberg.exceptions.ServiceFailureException: Server error: SdkClientException: Received an UnknownHostException when attempting to interact with a service. See cause for the exact endpoint that is failing to resolve. If this is happening on an endpoint that previously worked, there may be a network connectivity issue or your DNS cache could be storing endpoints for too long.
The same configuration in tabulario/iceberg-rest:0.2.0, Execute fine.
environments:
When I execute the following statement in Flink SQL client:
An error occurred:
[ERROR] Could not execute SQL statement. Reason: org.apache.iceberg.exceptions.ServiceFailureException: Server error: SdkClientException: Received an UnknownHostException when attempting to interact with a service. See cause for the exact endpoint that is failing to resolve. If this is happening on an endpoint that previously worked, there may be a network connectivity issue or your DNS cache could be storing endpoints for too long.
The same configuration in tabulario/iceberg-rest:0.2.0, Execute fine.