Reading flink hive_sync.table ClassNotFoundException

[hudi-bot]

flink 1.13.0

hudi 0.10.1

hive 3.1.2

 

!image-2022-03-31-19-25-05-540.png!

JIRA info

• Link: https://issues.apache.org/jira/browse/HUDI-3759
• Type: Bug
• Affects version(s):
  • 0.10.1
• Attachment(s):
  • 31/Mar/22 11:25;yangs;image-2022-03-31-19-25-05-540.png;https://issues.apache.org/jira/secure/attachment/13041843/image-2022-03-31-19-25-05-540.png

---

Comments

31/Mar/22 11:27;yangs;重现方法：
{code:java}
//代码占位符
CREATE TABLE t8(
  uuid INT PRIMARY KEY NOT ENFORCED,
  name VARCHAR(10),
  age int,
  ts TIMESTAMP(3)
)
PARTITIONED BY (name)
WITH (
  'connector' = 'hudi',
  'path' = 'hdfs://localhost:9000/user/hudi/t8',
  'hive_sync.enable' = 'true',
  'hive_sync.table' = 't10',
  'hive_sync.mode' = 'hms',
  'hive_sync.metastore.uris' = 'thrift://127.0.0.1:9083',
  'table.type' = 'MERGE_ON_READ' -- this creates a MERGE_ON_READ table, by default is COPY_ON_WRITE
);

CREATE TABLE datagen_source (
 uuid int,
 name STRING,
 age int,
 ts AS localtimestamp,
 partition int 
) WITH (
 'connector' = 'datagen',
 'rows-per-second'='1',
 'fields.uuid.min'='1',
 'fields.uuid.max'='100',
 'fields.age.min'='20',
 'fields.age.max'='30',
 'fields.partition.min'='1',
 'fields.partition.max'='4',
 'fields.name.length'='5'
); 

insert into t8 select uuid, name, age, ts  from datagen_source;
select * from t8;{code};;;

[hudi-bot]

Linked PR(s)

• [HUDI-3759] hive-exec shade is lost in flink-bundle-jar #5188