0

我尝试使用此链接创建执行计划中提供的示例创建计划,但出现以下错误。

Stream OutStats 已经定义为 StreamDefinition{streamId='OutStats', attributeList=[Attribute{name='meta_ip', type=STRING}, Attribute{name='userName', type=STRING}, Attribute{name='requestCount' , type=LONG}]}, 因此不能定义 StreamDefinition{streamId='OutStats', attributeList=[Attribute{name='meta_ip', type=STRING}, Attribute{name='userName', type=STRING}, Attribute{名称='searchKey',类型=STRING}]}

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

4

1 回答 1

4

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

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

请记住,名称、类型和顺序确实很重要。

于 2015-02-12T12:50:24.183 回答