java - 如何创建执行计划，其中导出的流和 siddhi 查询插入具有相同的名称？

Question

我尝试使用此链接 Create execution Plan 中提供的示例创建计划但我收到以下错误。

Stream OutStats is already defined as StreamDefinition{streamId='OutStats', attributeList=[Attribute{name='meta_ip', type=STRING}, Attribute{name='userName', type=STRING}, Attribute{name='requestCount', type=LONG}]}, hence cannot define StreamDefinition{streamId='OutStats', attributeList=[Attribute{name='meta_ip', type=STRING}, Attribute{name='userName', type=STRING}, Attribute{name='searchKey', type=STRING}]}

如果我将查询的插入部分更改为其他名称，它可以正常工作，但我担心如果导出的流名称和插入不相同，可能会产生问题。在创建执行计划之前，我创建了 org.foo.data.search.stats 和 org.foo.data.out.stats。这是一个错误还是我做错了什么？他们自己的测试用例也给出了同样的错误。链接:EventFlowTestCase

Answer 1

在第一个流中，您有 Attribute{name='requestCount', type=LONG}并在第二个流中添加 Attribute{name='searchKey', type=STRING}。

您的情况中的此错误意味着“定义流中的第四个属性与输入/输出/其他等流中的第四个属性不同”。

请记住，名称、类型和顺序很重要。