陈磊 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)