izhangzhihao / Real-time-Data-Warehouse

Real-time Data Warehouse with Apache Flink & Apache Kafka & Apache Hudi
109 stars 42 forks source link

Error when try to insert with flink: HoodieTableFactory not a subtype #4

Open Soufraz opened 2 years ago

Soufraz commented 2 years ago

Hello again.

All containers running and without errors. Installation without errors. The jars of base-image available in container. But when I am trying to run the statement below with docker-compose exec sql-client ./sql-client-submit.sh, I got this error:

INSERT INTO t1 VALUES
  ('id1','Danny',23,TIMESTAMP '1970-01-01 00:00:01','par1'),
  ('id2','Stephen',33,TIMESTAMP '1970-01-01 00:00:02','par1'),
  ('id3','Julian',53,TIMESTAMP '1970-01-01 00:00:03','par2'),
  ('id4','Fabian',31,TIMESTAMP '1970-01-01 00:00:04','par2'),
  ('id5','Sophia',18,TIMESTAMP '1970-01-01 00:00:05','par3'),
  ('id6','Emma',20,TIMESTAMP '1970-01-01 00:00:06','par3'),
  ('id7','Bob',44,TIMESTAMP '1970-01-01 00:00:07','par4'),
  ('id8','Han',56,TIMESTAMP '1970-01-01 00:00:08','par4');

I got this error:

[ERROR] Could not execute SQL statement. Reason:
java.util.ServiceConfigurationError: org.apache.flink.table.factories.Factory: org.apache.hudi.table.HoodieTableFactory not a subtype

But curiously, after create the table I got a success message: [INFO] Table has been created.

I would appreciate a little more help here. 😬

HarjeetSinghGoldy commented 1 year ago

I am also getting the same error, Are you able to fix thsi?