[
https://issues.apache.org/jira/browse/HUDI-7136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
陈磊 updated HUDI-7136:
---------------------
Description:
in the dfs catalog scenario, solve the problem of Primary key definition is
missing
demo:
{code:java}
// sql
CREATE CATALOG hudi_catalog WITH(
'type' = 'hudi',
'catalog.path' = 'file:///Users/x/x/others/data/hudi-warehouse/',
'mode' = 'dfs'
);
CREATE TABLE IF NOT EXISTS hudi_catalog.tmp.ctn4
(
f1 string,
f2 string,
primary key (f1) not enforced
) WITH (
'connector' = 'hudi',
'path' = 'file:///Users/x/x/others/data/hudi-warehouse/ctn4',
'table.type' = 'MERGE_ON_READ',
'write.operation' = 'upsert',
'hoodie.datasource.write.recordkey.field' = 'f1'
) ;
{code}
exception：
{code:java}
Primary key definition is missing {code}
was:
in the dfs catalog scenario, solve the problem of Primary key definition is
missing
demo:
{code:java}
// sql
CREATE CATALOG hudi_catalog WITH(
'type' = 'hudi',
'catalog.path' =
'file:///Users/chenlei677/chenlei677/others/data/hudi-warehouse/',
'mode' = 'dfs'
);
CREATE TABLE IF NOT EXISTS hudi_catalog.tmp.ctn4
(
f1 string,
f2 string,
primary key (f1) not enforced
) WITH (
'connector' = 'hudi',
'path' =
'file:///Users/chenlei677/chenlei677/others/data/hudi-warehouse/ctn4',
'table.type' = 'MERGE_ON_READ',
'write.operation' = 'upsert',
'hoodie.datasource.write.recordkey.field' = 'f1'
) ;
{code}
exception：
> in the dfs catalog scenario, solve the problem of Primary key definition is
> missing
> -----------------------------------------------------------------------------------
>
> Key: HUDI-7136
> URL: https://issues.apache.org/jira/browse/HUDI-7136
> Project: Apache Hudi
> Issue Type: Bug
> Reporter: 陈磊
> Priority: Major
>
> in the dfs catalog scenario, solve the problem of Primary key definition is
> missing
> demo:
> {code:java}
> // sql
> CREATE CATALOG hudi_catalog WITH(
> 'type' = 'hudi',
> 'catalog.path' = 'file:///Users/x/x/others/data/hudi-warehouse/',
> 'mode' = 'dfs'
> );
> CREATE TABLE IF NOT EXISTS hudi_catalog.tmp.ctn4
> (
> f1 string,
> f2 string,
> primary key (f1) not enforced
> ) WITH (
> 'connector' = 'hudi',
> 'path' = 'file:///Users/x/x/others/data/hudi-warehouse/ctn4',
> 'table.type' = 'MERGE_ON_READ',
> 'write.operation' = 'upsert',
> 'hoodie.datasource.write.recordkey.field' = 'f1'
> ) ;
> {code}
> exception：
> {code:java}
> Primary key definition is missing {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
