【发布时间】:2018-12-31 18:19:41
【问题描述】:
我正在寻找如何在我的 scala 项目中的风暴 1.2.1 中从风暴螺栓中终止拓扑。
从这个answer,我写了下面的代码来做到这一点:
private def shutTopology(){
import org.apache.storm.utils.Utils
import org.apache.storm.utils.NimbusClient
val conf = Utils.readStormConfig
val nimbusClient =
NimbusClient.getConfiguredClient(conf).getClient
nimbusClient.deactivate(topology_name)
}
但它给出了以下错误:val conf = Utils.readStormConfig,如何解决这个问题?
错误:(46, 17) 包守护进程包含同名的对象和包:nimbus
其中一个需要从类路径中删除
val conf = Utils.readStormConfig
我通过sbt 和mvn 编译得到了上述错误。我看到了一些关于这个 here 的描述,但对于如何解决这个问题没有太多帮助。
编辑:
基于答案here,我能够使用以下scalac 选项在sbt 中编译它:
"-Yresolve-term-conflict:object"
我仍然无法完成此操作,如何在使用 maven 编译时解决此错误。
【问题讨论】:
标签: scala maven compiler-errors sbt apache-storm