amoro
amoro copied to clipboard
[Bug][FLINK]: flink unified catalog doesn't support mixed_hive
What happened?
SQL like this:
CREATE CATALOG unifiedCatalog WITH (
'type' = 'unified',
'metastore.url' = 'thrift://xxxx:pppp/unified_catalog'
)
create table if not exists unifiedCatalog.iceberg_test.mh_by_uc_spark_test(
id int,
name string,
dt string,
primary key (id,dt) not enforced
) with ('write.upsert.enabled'='true');
we encounted the error
Affects Versions
master
What engines are you seeing the problem on?
Flink
How to reproduce
CREATE CATALOG unifiedCatalog WITH (
'type' = 'unified',
'metastore.url' = 'thrift://xxxx:pppp/unified_catalog'
)
create table if not exists unifiedCatalog.iceberg_test.mh_by_uc_spark_test(
id int,
name string,
dt string,
primary key (id,dt) not enforced
) with ('write.upsert.enabled'='true');
Relevant log output
No response
Anything else
No response
Are you willing to submit a PR?
- [X] Yes I am willing to submit a PR!
Code of Conduct
- [X] I agree to follow this project's Code of Conduct