如何通过 eclipse 在本地集群/模式下调试 Apache Storm

2023-12-06

使用以下问答,我设法通过 Apache Storm 集群(本地运行)上的 eclipse 启用调试。如何在 Eclipse 中调试 Apache Storm?

My conf/storm.yaml有以下行可以在工作节点上启用调试:

worker.childopts: "-agentlib:jdwp=transport=dt_socket,address=8000,server=y,suspend=y"

当我向storm提交拓扑以运行(在集群中)时,我可以在编辑器中设置断点并查看变量。

但是当我尝试在本地运行它时(在本地模式),我似乎无法通过 eclipse 连接(连接被拒绝)。

# I'm using storm crawler, I submit a topology like so:
storm jar target/storm-crawler-core-10.6-SNAPSHOT-jar-with-dependencies.jar \
 com.digitalpebble.storm.crawler.CrawlTopology \
-conf crawler-conf.yaml \
-local

# ^ The `-local` runs it in a `LocalCluster`
# If I submit it to my actual cluster (without -local), I can debug it through eclipse.

# View the pastebin for all the output : http://pastebin.com/PEdA7fH0

我已将上述命令的所有输出包含到 Pastebin 中。点这里观看

有关 Storm Crawler 如何启动 LocalCluster 的更多信息。

我希望能够在本地模式下进行调试,这样我就可以在命令行中看到输出(当我通过我设置的断点时)并快速进行更改并重新运行,基本上是为了加快我的开发流程。


在 LocalCluster 中运行 Apache Storm 时如何通过 eclipse 调试器调试代码(本地模式)?


如果以本地模式运行,则不涉及工作 JVM,即不会启动任何工作进程。因此,你的worker.childopts设置没有任何影响。

在 Eclipse 中调试的最简单方法是在 Eclipse 中提交/启动拓扑,而不是命令行。你的班CrawlTopology has a main方法,因此您可以直接在 Eclipse 中执行它(当然是在调试模式下)。您不需要指定 jar 文件名。只需指定您的选项-conf crawler-conf.yaml -local在您的 Eclipse 运行配置中。

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

如何通过 eclipse 在本地集群/模式下调试 Apache Storm 的相关文章

  • 使用 Android 发送 HTTP Post 请求

    我一直在尝试从 SO 和其他网站上的大量示例中学习 但我无法弄清楚为什么我编写的示例不起作用 我正在构建一个小型概念验证应用程序 它可以识别语音并将其 文本 作为 POST 请求发送到 node js 服务器 我已确认语音识别有效 并且服务
  • INSERT..RETURNING 在 JOOQ 中不起作用

    我有一个 MariaDB 数据库 我正在尝试在表中插入一行users 它有一个生成的id我想在插入后得到它 我见过this http www jooq org doc 3 8 manual sql building sql statemen
  • Android MediaExtractor seek() 对 MP3 音频文件的准确性

    我在使用 Android 时无法在eek 上获得合理的准确度MediaExtractor 对于某些文件 例如this one http www archive org download emma solo librivox emma 01
  • 如何针对 Node.js 中发生的每个错误发送电子邮件?

    假设我的 node js 应用程序正在运行 如果出现错误 我的意思是所有错误 不仅仅是网络错误 如果出现错误 则很重要 我如何调用函数向我发送电子邮件 基本上 在我希望它写入 err out 之前 我希望向我发送一封电子邮件 我正在使用no
  • JavaMail 只获取新邮件

    我想知道是否有一种方法可以在javamail中只获取新消息 例如 在初始加载时 获取收件箱中的所有消息并存储它们 然后 每当应用程序再次加载时 仅获取新消息 而不是再次重新加载它们 javamail 可以做到这一点吗 它是如何工作的 一些背
  • 无法解析插件 Java Spring

    我正在使用 IntelliJ IDEA 并且我尝试通过 maven 安装依赖项 但它给了我这些错误 Cannot resolve plugin org apache maven plugins maven clean plugin 3 0
  • 从 127.0.0.1 到 2130706433,然后再返回

    使用标准 Java 库 从 IPV4 地址的点分字符串表示形式获取的最快方法是什么 127 0 0 1 到等效的整数表示 2130706433 相应地 反转所述操作的最快方法是什么 从整数开始2130706433到字符串表示形式 127 0
  • Android Studio 0.4.3 Eclipse项目没有gradle

    在此版本之前 在 Android Studio 中按原样打开 Eclipse 项目似乎很容易 无需任何转换 我更喜欢 Android Studio 环境 但我正在开发一个使用 eclipse 作为主要 IDE 的项目 我不想只为这个项目下载
  • JRE 系统库 [WebSphere v6.1 JRE](未绑定)

    将项目导入 Eclipse 后 我的构建路径中出现以下错误 JRE System Library WebSphere v6 1 JRE unbound 谁知道怎么修它 右键单击项目 特性 gt Java 构建路径 gt 图书馆 gt JRE
  • 错误:在根项目“projectName”中找不到项目“app”

    我有一个在 Eclipse 中开发的旧应用程序 现在尝试将其迁移到 Android Studio 我更新了库并遵循了基本步骤 现在 我收到此错误 Error Project app not found in root project pro
  • 如何在 javadoc 中使用“<”和“>”而不进行格式化?

    如果我写
  • AWS 无法从 START_OBJECT 中反序列化 java.lang.String 实例

    我创建了一个 Lambda 函数 我想在 API 网关的帮助下通过 URL 访问它 我已经把一切都设置好了 我还创建了一个application jsonAPI Gateway 中的正文映射模板如下所示 input input params
  • Google App Engine 如何预编译 Java?

    App Engine 对应用程序的 Java 字节码使用 预编译 过程 以增强应用程序在 Java 运行时环境中的性能 预编译代码的功能与原始字节码相同 有没有详细的信息这是做什么的 我在一个中找到了这个谷歌群组消息 http groups
  • 无法捆绑适用于 Mac 的 Java 应用程序 1.8

    我正在尝试将我的 Java 应用程序导出到 Mac 该应用程序基于编译器合规级别 1 7 我尝试了不同的方法来捆绑应用程序 1 日食 我可以用来在 Eclipse 上导出的最新 JVM 版本是 1 6 2 马文 看来Maven上也存在同样的
  • 如何从泛型类调用静态方法?

    我有一个包含静态创建方法的类 public class TestClass public static
  • 在activity_main.xml中注释

    我是安卓新手 据我所知 XML 中的注释与 HTML 中的注释相同 使用 形式 我想在 Android 项目的 Activity main xml 配置文件中写一些注释 但它给了我错误 值得注意的是 我使用的是 Eclipse 但目前 我直
  • Firebase 添加新节点

    如何将这些节点放入用户节点中 并创建另一个节点来存储帖子 我的数据库参考 databaseReference child user getUid setValue userInformations 您需要使用以下代码 databaseRef
  • 有没有办法为Java的字符集名称添加别名

    我收到一个异常 埋藏在第 3 方库中 消息如下 java io UnsupportedEncodingException BIG 5 我认为发生这种情况是因为 Java 没有定义这个名称java nio charset Charset Ch
  • 节拍匹配算法

    我最近开始尝试创建一个移动应用程序 iOS Android 它将自动击败比赛 http en wikipedia org wiki Beatmatching http en wikipedia org wiki Beatmatching 两
  • 使用 xpath 和 vtd-xml 以字符串形式获取元素的子节点和文本

    这是我的 XML 的一部分

随机推荐

  • Amazon s3 Elastic Transcoder 错误:找不到指定的管道

    我正在使用 aws sdk php 集成 Amazon s3 Elastic Transcoder 我用http elastictranscoding blogspot in 链接来完成我的任务 在实现时我面临以下错误 致命错误 未捕获的
  • 如何从命令输出中获取第二列?

    我的命令的输出类似于 1540 A B 6 C 119 D 第一列始终是一个数字 后跟一个空格 然后是一个双引号字符串 我的目的是只获取第二列 例如 A B C D 我打算使用
  • Twitter bootstrap - 图像未显示

    我的网站在 Google Chrome 中运行良好 但在其他浏览器 Firefox Safari 中运行不佳 我的以下代码部分有问题 div class span2 img src images ads karaoke png br br
  • 如何将 Spring 数据查询记录到 Couchbase 数据库

    In my Spring Boot应用程序我们有一个Spring Data存储库连接到Couchbase server 我知道 当连接到 SQL Server 时 可以通过添加到属性文件行 例如这一行 来查看发送到数据库的实际查询 正如这里
  • 检查 python 列表中的重复项

    我见过这个问题的很多变体 从简单的删除重复项到查找和列出重复项 即使尝试从这些例子中提取一些片段也无法得到我的结果 我的问题是如何检查我的列表是否有重复的条目 更好的是 我的列表是否有非零重复项 我有几个想法 empty list myLi
  • 我还可以在哪里声明 angular-cli 中包含的脚本?

    In angular cli json I have polyfills polyfills ts scripts script1 ts 我想添加另一个 polyfill 脚本ie11具体来说 我可以在最终构建时将其包含在条件注释中 以减少
  • 日语字符串上的explode()

    我必须对日语文本使用explode 函数 但它不起作用 这是我所拥有的一个例子 string 私 人 string explode string print r string 那打印 Array 0 gt 私 人 代替 Array 0 gt
  • 启动画面就像点击复仇 3

    感谢您花时间阅读此消息 我希望你能够回答我的问题 我想在现有项目中添加一个类似于 点按复仇 3 的启动画面 它基本上显示一个屏幕 2 秒 然后另一个屏幕 2 秒 然后立即显示菜单 谁能告诉我如何才能创造出这样的东西 谢谢 显然 对于启动画面
  • Sparql 查询某个类的子代、孙子等

    我有一个在 Protege 中构建的 owl 文件 什么是 sparql 查询 它将选择一个类的所有子类以及这些子类的所有子类 依此类推 广度优先搜索排序方式 这可能会被回答Sparql 查询子类或等效项 但是这个问题及其答案包含了比您在这
  • 检测到 POSIX 系统上的日志文件已被删除或截断?

    假设一个长时间运行的进程写入日志文件 假设日志文件无限期地保持打开状态 假设粗心的系统管理员删除了该日志文件 程序能检测到这种情况发生了吗 可以安全地假设fstat 会报告已删除文件的链接计数为零吗 在我看来 截断有点棘手 在某种程度上 这
  • 找不到符号错误:Lombok 1.18.6 不适用于 Gradle 5.2.1、JDK 10

    使用 Gradle 5 2 1 和 Lombok 1 18 6 依赖项进行的构建在 JDK 10 中失败 Lombok 注释似乎没有得到正确处理 我在源代码中的各种 Java 文件中不断收到 找不到符号 错误 对于为什么会发生这种情况有什么
  • 如何从使用 write.table 创建的 CSV 文件中删除尾随空白或换行符?

    我想将 R 中的数据帧写入 CSV 文件 考虑下面的玩具示例 df lt data frame ID c 1 2 3 X c a b c Y c 1 2 NA df which is na df Y 1 write table t df f
  • 最小最大值二维数组javascript

    我发现了很多类似的帖子 但还没有一个完全满足这个问题 如何从 javascript 中的以下 2D 数组中获取最小值和最大值 1 2 3 4 5 6 7 8 9 即返回 1 和 9 this问题不完全是我想要的 因为用户想忽略第 0 列 并
  • Prolog:将列表拆分为两个列表(唯一项/重复项)

    我一直在尝试将给定列表拆分为两个不同的列表 唯一列表和重复列表 例如 如果我们有列表 1 1 2 3 3 4 5 我希望唯一列表是 2 4 5 并复制为 1 3 我不希望列表中的所有 1 都出现在重复列表中 我只需要其中之一 我现在拥有的代
  • HTML5 画布中最简单的幻灯片,canvas.context.clearRect 不适用于 setTimeout

    这是一个非常简单的幻灯片的代码 应在 4 秒内显示 4 张图像 每秒一张图像 相反 我得到了 4 秒的延迟 然后所有图像都绘制在彼此之上 我究竟做错了什么
  • 谷歌地图只加载了一半

    查看上面的图片并尝试 URL gt http domainsoutlook com s site stackoverflow com html并转到服务器信息选项卡 我注意到的荒谬之处是 如果我加载http domainsoutlook c
  • 仅在一台机器上出现 HTML 对齐问题(均为 IE8)

    我有以下 HTML 和 CSS 代码 一机在IE8下运行良好 但在第二台机器上与 IE8 不一致 为了纠正它需要改变什么 注意 未对齐是针对 Logout 文本 注 图像尺寸为214 X 57 注意 两个系统都具有相同的分辨率和 100 缩
  • 在 D3 中加载 TopoJSON 文件时的随机行

    我正在尝试显示意大利制图形状文件 例如这个 使用D3 js 我可以加载 Zip 文件地图塑造者 查看地图 将其简化并导出为 TopoJSON 我可以在 MapShaper 中加载 TopoJSON 它看起来仍然没问题 但是当我尝试使用 D3
  • 如何用Swing制作画布?

    我正在尝试用 Java 制作一个绘画编辑器 其中有一个工具栏 其中包含我想要粘贴到画布中的对象 我使用 Swing 组件来制作 GUI 但是当我寻找制作画布的方法时 我只找到了 AWT 中的类画布 有没有办法用Swing制作类似canvas
  • 如何通过 eclipse 在本地集群/模式下调试 Apache Storm

    使用以下问答 我设法通过 Apache Storm 集群 本地运行 上的 eclipse 启用调试 如何在 Eclipse 中调试 Apache Storm My conf storm yaml有以下行可以在工作节点上启用调试 worker