waywtdcc created HUDI-5259:
------------------------------
Summary: Spark reports an error when modifying the schema of the
Flink table
Key: HUDI-5259
URL: https://issues.apache.org/jira/browse/HUDI-5259
Project: Apache Hudi
Issue Type: New Feature
Components: flink-sql, spark-sql
Reporter: waywtdcc
Spark reports an error when modifying the schema of the Flink table
* flink create table and write data
{code:java}
CREATE CATALOG myhudi WITH(
'type' = 'hudi',
'default-database' = 'default',
'catalog.path' = '/user/hdpu/warehouse',
'mode' = 'hms',
'hive.conf.dir' = 'hdfs:///user/hdpu/streamx/conf_data/hive_conf',
-- Default attribute value of table creation
'table-prop.connector' = 'hudi',
'table-prop.table.type' = 'COPY_ON_WRITE',
'table-prop.compaction.tasks' = '1',
'table-prop.write.tasks' = '1',
'table-prop.index.bootstrap.enabled' = 'true',
'table-prop.read.utc-timezone' = 'false',
'table-prop.hoodie.bucket.index.num.buckets' = '1',
'table-prop.index.type' = 'BUCKET',
'table-prop.index.global.enabled' = 'true'
);drop table if exists myhudi.test_hudi3.hudi_test19;create table if not
exists myhudi.test_hudi3.hudi_test19
(id bigint not null, `_extra_test2` string not null, `_extra_test23` string
not null,name string,_extra_test int not null
,PRIMARY KEY (`id`,`_extra_test2`) NOT ENFORCED
)
;
show create table myhudi.test_hudi3.hudi_test19;
insert into myhudi.test_hudi3.hudi_test19
values
(1, '888','c123cc','ccc', 43);
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
