0

水路で作成したい2つの異なるログフローがあります。これらのフローにはさまざまなログメッセージが含まれているため、個別に処理すると便利です。

トポロジー

私の構成は次のようになります。

+----+    +-----+
| a0 | -> | dst |
+----+    +-----+
             ^
+----+       |
| a1 | ------+
+----+

a0ログが作成さa1れたソースです。

dstログエントリを（HDFSに）ログに記録する宛先です。

構成

flumeシェルからのノード構成は次のとおりです。

[flume localhost:35873:45678] getmappings
Master has the following mappings

Physical Node                  --> Logical Node(s)

a0.domain.local                --> [a0, a0.domain.local]
a1.domain.local                --> [a1, a1.domain.local]
dst.domain.local               --> [dst.domain.local, fooSink, barSink]

問題

ここで説明されているように新しい水路フローを作成しようとすると、次のエラーが発生します。

[flume localhost:35873:45678] exec config a0 fooFlow rpcSource(12345) agentE2ESink("dst")
Failed to run command 'exec config a0 fooFlow rpcSource(12345) agentE2ESink("dst")' due to null
12/03/13 14:06:05 ERROR util.FlumeShell: Failed to run command 'exec config a0 fooFlow rpcSource(12345) agentE2ESink("dst")'

ログには何もありません。このdue to nullエラーでは何もできません。

4

1 に答える 1

0

わかりました。ソースとシンクを引用する必要があります。

[flume localhost:35873:45678] exec config a0 fooFlow 'rpcSource(12345)' 'agentE2ESink("dst")'
[id: 35] Execing command : config
Command succeeded
于 2012-03-13T13:28:08.840 に答える