E-MapReduce
需要在控制台修改参数spark.driver.extraClassPath,添加 Spark jars 的路径, 如/usr/lib/emr/current/spark3/jars/*(由于不同版本因素请先确认下路径存在)。 此外需要在 spark-default.conf 中添加相关 catalog 参数或者使用 set 命令(详见Iceberg 参数配置)
需要在集群的节点上拷贝 Iceberg 依赖
cd /usr/lib/emr/current/flink -- 拷贝Iceberg需要的依赖 cp /usr/lib/emr/current/iceberg/lib/iceberg-flink-runtime-*.jar lib