La séparation de la Buse flux

Question

J'ai deux journaux différents flux qui je voudrais créer dans la buse.Ces flux contiennent des différents messages du journal et ce serait formidable de les traiter séparément.

Topologie

Ma configuration ressemble à ceci:

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

a0 et a1 est une source, où les journaux créés.

dst c'est la destination, où les entrées de journal doit être connecté à HDFS).

Configuration

Là est le nœud de configuration de la buse shell:

[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]

Problème

Lorsque j'essaie de créer une nouvelle canalisation de flux comme il est décrit ici, J'obtiens l'erreur suivante:

[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")'

Il n'y a rien dans les logs, je ne peux rien faire avec ce due to null erreur.

Answer 1

Bon, je l'ai, les sources et les puits doivent être citées:

[flume localhost:35873:45678] exec config a0 fooFlow 'rpcSource(12345)' 'agentE2ESink("dst")'
[id: 35] Execing command : config
Command succeeded