StarBoy1005 created HUDI-6190:
---------------------------------
Summary: The default value of RECORD_KEY_FIELD lead to the
description in exception of checkRecordKey is not so accurate.
Key: HUDI-6190
URL: https://issues.apache.org/jira/browse/HUDI-6190
Project: Apache Hudi
Issue Type: Improvement
Components: flink-sql
Reporter: StarBoy1005
Attachments: image-2023-05-08-18-24-47-583.png
In master branch, I treat uuid as recordkey field,
{code:java}
create table test_uuid_a (
rid bigint,
wr_returned_date_sk bigint
)
WITH (
'hoodie.datasource.write.recordkey.field'='uuid',
'connector'='hudi',
'path'='/tmp/hudi_tpcds/test_uuid_a',
'table.type'='COPY_ON_WRITE',
'read.start-commit'='earliest',
'read.streaming.enabled'='false',
'changelog.enabled'='true',
'write.precombine'='false',
'write.precombine.field'='no_precombine',
'write.operation'='bulk_insert',
'read.tasks'='2',
'write.tasks'='2',
'index.type'='BUCKET',
'metadata.enabled'='false',
'hoodie.bucket.index.hash.field'='rid',
'hoodie.bucket.index.num.buckets'='2',
'index.global.enabled'='false'
);
{code}
And I got an exception:
!image-2023-05-08-18-24-47-583.png!
I guess the correct reason is “uuid” field is not in the table's schema.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
