rmoff commented on issue #9947:
URL: https://github.com/apache/iceberg/issues/9947#issuecomment-1994334466
CTAS definitely works in some cases:
```
Flink SQL> CREATE TABLE iceberg_test WITH (
> 'connector' = 'iceberg',
> 'catalog-type'='hive',
> 'catalog-name'='dev',
> 'warehouse' = 's3a://warehouse',
> 'hive-conf-dir' = './conf')
> AS
> SELECT name, COUNT(*) AS cnt FROM (VALUES ('Bob'), ('Alice'), ('Greg'),
('Bob')) AS NameTable(name) GROUP BY name;
[INFO] Submitting SQL update statement to the cluster...
[INFO] SQL update statement has been successfully submitted to the cluster:
Job ID: 7777828c279a5b93e6bb0bfb1cd40b6a
Flink SQL> SELECT * FROM iceberg_test;
+----+--------------------------------+----------------------+
| op | name | cnt |
+----+--------------------------------+----------------------+
| +I | Bob | 1 |
| +I | Alice | 1 |
| +I | Greg | 1 |
| +I | Bob | 1 |
| +I | Bob | 2 |
+----+--------------------------------+----------------------+
Received a total of 5 rows
```
--
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-unsubscr...@iceberg.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscr...@iceberg.apache.org
For additional commands, e-mail: issues-h...@iceberg.apache.org
