我尝试使用此链接创建执行计划中提供的示例创建计划,但出现以下错误。
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