0

このリンクで提供されている例を使用して計画を作成しようとしました実行計画を作成しましたが、次のエラーが発生しました。

ストリーム 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{ を定義できませんname='searchKey', type=STRING}]}

クエリの一部への挿入を別の名前に変更すると問題なく動作しますが、エクスポートされたストリーム名と挿入先が同じでない場合に問題が発生する可能性があるのではないかと心配しています。実行計画を作成する前に、org.foo.data.search.stats と org.foo.data.out.stats の両方を作成しました。これはバグですか、それとも何か間違っていますか? また、独自のテストケースでも同じエラーが発生します。リンク: EventFlowTestCase

4

1 に答える 1

4

最初のストリームには Attribute{name='requestCount', type=LONG} があり、2 番目のストリームには Attribute{name='searchKey', type=STRING} があります。

あなたの状況でのこのエラーは、「定義されたストリームの 4 番目の属性が、入力/出力/その他のストリームの 4 番目の属性と同じではない」ことを意味します。

覚えておいてください、名前、タイプ、順序は重要です。

于 2015-02-12T12:50:24.183 に答える