当前位置: 首页 > 知识库问答 >
问题:

Datstax Cassandra装船机

章鸿光
2023-03-14

我正在尝试使用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

    }

  }

}

共有1个答案

卞俊贤
2023-03-14

它似乎希望运行在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数十次,但是没有任何效