[ 
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/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:

  was:
in the dfs catalog scenario, solve the problem of Primary key definition is 
missing

demo:


> 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/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:



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to