You need to enable JavaScript to run this app.
E-MapReduce

E-MapReduce

Copy page
Download PDF
Advanced usage
Use Iceberg in Dataleap
Copy page
Download PDF
Use Iceberg in Dataleap

Spark

It is necessary to modify the parameter spark.driver.extraClassPath in the console and add the path to the Spark jars, such as /usr/lib/emr/current/spark3/jars/* (please confirm that the path exists due to differences between versions). In addition, you need to add the relevant catalog parameters in spark-default.conf or use the set command (see Iceberg parameter configuration for details).

It is necessary to copy the Iceberg dependencies to the nodes in the cluster.

cd /usr/lib/emr/current/flink 
-- Copy the dependencies required by Iceberg
cp /usr/lib/emr/current/iceberg/lib/iceberg-flink-runtime-*.jar  lib
Last updated: 2026.06.01 16:22:16