我正在尝试使用JMX BulkLoader将数据从远程节点ETL到集群的Cassandra中
https://github.com/patrickcallaghan/datastax-analytics-example/blob/master/src/main/java/com/datastax/jmxloader/jmxbulkloader.java
但是在成功建立JMX连接之后,它似乎无法进行大容量加载。
注意,大容量装载是从远程节点发出到cassandra集群的。
它似乎希望运行在cassandra集群的本地(即cassandra集群的本地主机)
我错过什么了吗。有谁能给我出个主意吗
class JmxBulkLoader(host: String, port: Int) {
private var connector: JMXConnector = _
private var storageBean: StorageServiceMBean = _
private var timer: Timer = new Timer()
connect("http://hostip , 7199)
private def connect(host: String, port: Int) {
val jmxUrl = new JMXServiceURL("service:jmx:rmi:///jndi/rmi://%s:%d/jmxrmi".format(host,
port))
Logger.info(" Connected to JMX Entity " + jmxUrl)
val env = new HashMap[String, Any]()
connector = JMXConnectorFactory.connect(jmxUrl, env)
val mbeanServerConn = connector.getMBeanServerConnection
val name = new ObjectName("org.apache.cassandra.db:type=StorageService")
storageBean = JMX.newMBeanProxy(mbeanServerConn, name, classOf[StorageServiceMBean])
}
def close() {
connector.close()
}
def bulkLoad(path: String): Boolean = {
try {
val timer = new Stopwatch().start
val result = storageBean.bulkLoadAsync(path)
timer.stop
Logger.info("Async Result of Bulk Load " + result)
Logger.info("Bulk load took " + timer.getElapsedTime + "millsecs.")
true
} catch {
case e: Exception =>
Logger.error("Error in Bulk Loading " + e.printStackTrace())
false
}
}
}
它似乎希望运行在cassandra集群的本地(即cassandra集群的本地主机)
不完全是。但是请考虑一下:您正在使用字符串参数调用Cassandra节点的mbean函数。此调用由您正在调用的Cassandra进程执行(即,连接到的)。该参数指定要连接到的节点一侧的路径。
您必须确保该路径存在于目标上,并且保存了所需的数据(例如,通过共享存储或预先复制文件)。
我在从测试中剔除条纹时遇到了一些麻烦 卡特顿。ts EndUserExperience.spec.js 当我点击周围它仍然重定向我。所以存根似乎没有起作用... 尝试@RichardMatsen建议的以下解决方案 测验规格js 但它仍然重定向我并显示错误
摘星船是一个非常简单的小游戏,使用上下方向键控制飞船躲避陨石的同时多吃星星。 游戏内容很简单,但这是 WebAssembly 的游戏 Demo ,展示了 WebAssembly 编写使用 Web 渲染的游戏的能力。
本文向大家介绍甲、乙、丙三艘船共运货9400箱,甲船比乙船多运300箱,丙船比乙船少运200箱。求三艘船各运多少箱货?相关面试题,主要包含被问及甲、乙、丙三艘船共运货9400箱,甲船比乙船多运300箱,丙船比乙船少运200箱。求三艘船各运多少箱货?时的应答技巧和注意事项,需要的朋友参考一下 答案: 根据已知甲船比乙船多运30O箱,假设甲船同乙船运的一样多,那么甲船就要比原来少运300箱,结果三船运
我正在尝试使用JMX BulkLoader将ETL数据从远程节点传输到集群上的Cassandra https://github.com/PatrickCallaghan/datastax-analytics-example/blob/master/src/main/java/com/datastax/jmxloader/JmxBulkLoader.java 但是,在成功建立JMX连接后,它似乎无法
问题内容: 我们在Jetty 9.0.3服务器上部署了一个应用程序REST网关.apache commons- httpclient3.1负责对部署在jetty中的服务进行身份验证和授权。当有大量并发线程访问Rest网关时,REST网关计算机中会堆积很多CLOSE_WAIT。通过调用apache commons的releaseConnections方法可以正确关闭为发送请求到启动器(END POI
问题内容: 我正在使用scapy用python编写的网络工具。 作为IDE,我正在使用Pycharm。 我的代码有效。因此,如果我运行它,一切都会按预期进行。 我的问题是PyCharm给我一些错误。 它标志着每次使用的,,,…如 我的代码的相关部分如下所示 我尝试了很多使用google找到的东西,例如将src文件夹添加为源根目录,刷新了所有可以找到的缓存并重启了PyCharm数十次,但是没有任何效