陈磊 created HUDI-7135:
------------------------

             Summary: Spark reads hudi table error when flink creates the table 
without preCombine fields by catalog or factory
                 Key: HUDI-7135
                 URL: https://issues.apache.org/jira/browse/HUDI-7135
             Project: Apache Hudi
          Issue Type: Bug
            Reporter: 陈磊


Create a table through dfs catalog, hms catalog, or sink ddl, and then query 
the data of the table through spark, and an exception occurs:
Java. util. NoSuchElementException: key not found: ts

demo:
 1. create a table through hms catalog:

{panel:title=hms catalog create table}
CREATE CATALOG hudi_catalog WITH(
    'type' = 'hudi',
    'mode' = 'hms'
);

CREATE TABLE hudi_catalog.`default`.ct1
(
        f1 string,
        f2 string
) WITH (
        'connector' = 'hudi',
        'path' = 'file:///Users/x/x/others/data/hudi-warehouse/ct1',
        'table.type' = 'COPY_ON_WRITE',
        'write.operation' = 'insert'
);
{panel}

2. spark query

{panel:title=spark query}
select * from ct1
{panel}

3. exception

{panel:title=exception}
java.util.NoSuchElementException: key not found: ts
{panel}






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

Reply via email to