3

我想配置 zeppeline spark 解释器。我想--conf "spark.cassandra.connection.host=<ip>" --conf "spark.cassandra.input.split.size_in_mb=32" and --jars $(echo /home/sysadmin/ApacheSpark/jar/*.jar | tr ' ' ',')通过我的 zeppelin ui 解释器传递选项来触发提交。

我怎样才能通过它们？由于我有很多 cassandra 机器，我想创建多个 spark 解释器，因此不想在 zeppelin-env 文件中添加配置，如此处所述。

4

1 回答 1

1

您可以使用内联配置来完成非常简单和直观的操作。

例如

%spark.conf

spark.jars. jar1,jar2
spark.cassandra.connection.host <ip>
spark.cassandra.input.split.size_in_mb 32
于 2020-05-09T14:37:32.220 回答