问题描述
通过FlinkSQL创建Hudi表后，向表中插入数据报错：
[ERROR] Could not execute SQL statement. Reason:
java.lang.ClassNotFoundException: org.apache.hadoop.fs.FSDataInputStream
解决办法
向Hudi表中写入数据时，会调用Hadoop的Jar包，但是Flink的lib目录中没有该Jar包。
需要将hadoop目录中share/hadoop/mapreduce/hadoop-mapreduce-client-core-X.X.X.jar包拷贝到Flink的lib目录中。
然后重启Flink集群，stop-cluster.sh && start-cluster.sh
标签：lang,execute,Hudi,FlinkSQL,hadoop,ClassNotFoundException,报错,FSDataInputStream From： https://www.cnblogs.com/yeyuzhuanjia/p/18040308