今天,我在我的Storm拓扑生成器中遇到了一个奇怪而烦人的错误。
问题是当我提交我的jar文件到Storm集群时,它总是跳过传递给main方法的第二个参数。
public class ZMQTopology {
public static void main(String[] args) throws AlreadyAliveException,
InvalidTopologyException {
for(int i=0;i<(args.length);i++)
{ System.out.println("I=" +i+ " value="+args[i]);
}
这就是我提交罐子的方式。
E: \目标
输出
I=0值=值1
I=1值=值3
I=2 值=值4
I=3 值=值5
我尝试了所有的组合、参数的数量、参数的类型等,但它跳过了第二个参数
我想知道我错过了什么…
请帮帮我
经过一些调试,我发现这只发生在windows机器上。我能够在2个windows机器上重现错误。使用0.9.3和0.9.4版本的Storm。在Linux机器上,我可以看到命令行参数工作得很好。
Jira为此bug提出了罚单。https://issues.apache.org/jira/browse/STORM-745
更新:修正了稍后windows Storm的Bug。cmd版本。
Apache Kafka:分布式消息传递系统 Apache Storm:实时消息处理 我们如何在实时数据管道中使用这两种技术来处理事件数据? 在实时数据管道方面,我觉得两者做的工作是一样的。如何在数据管道上同时使用这两种技术?
我正在做一个学术项目,涉及传感器的流数据。我已经包围了苍鹭(Storm的接班人)和尼菲。两者都支持内置背压,这对我的项目至关重要。Apache Nifi和Heron之间的主要区别是什么? 哪款更适合物联网应用?
下面是我成功运行两三天后持续获得的异常的详细信息。有人能指导我吗?
我正在使用这两个实时数据流框架处理器。我找遍了所有的地方,但我找不到这两个框架之间有很大的区别。特别是,我想知道他们是如何工作的基础上的数据或拓扑等大小。
我在Apache Storm拓扑上运行了一个性能测试,并注意到kinesis-spout中的“failed”计数非常高(几乎占了元组的1/3)。这个数值是多少?