spark-influx-sink:Spark指标下沉到InfluxDb

火花流入水槽 火花指标下沉到InfluxDb 为什么这有用？ 由于Spark具有分布式特性，因此很难从Apache Spark收集诊断指标。 当执行程序在任意数量的远程主机上运行时，轮询Spark执行程序进程或抓取日志将变得乏味。 相反，该软件包使用“推送”方法将指标发送到运行InfluxDb的中央主机，在该主机上可以进行集中分析。 如何部署 运行./gradlew build 将输出的JAR复制到Spark可以读取的路径，并将其与 （ ）一起添加到Spark的extraClassPath 。 将您的新接收器添加到Spark的conf/metrics.properties metrics.properties示例片段的示例： *.sink.influx.class=org.apache.spark.metrics.sink.InfluxDbSink *.sink.influx.