Hello Samza !! - aqeuefemの日記

Apache Samaza を動かしてみる。

LinkedIn で使われてる Stream 処理だとか。

http://samza.incubator.apache.org/

最初っから、Storm との違いのページがあるあたり。
http://samza.incubator.apache.org/learn/documentation/0.7.0/comparisons/storm.html

Hello samza

とりあえずこれで動かすことができるらしいので、サンプルを動かしてみようかと。
http://samza.incubator.apache.org/startup/hello-samza/0.7.0/

ドキュメントに沿って実施

どこで動かすか、、と思ったら GMO VPS 借りてるの思い出した。

JAVA_HOME が無いって怒られる。

add-apt-repository ppa:webupd8team/java
apt-get update
apt-get install oracle-java6-installer

なんか License 同意求められたので同意。

export JAVA_HOME=...
リトライ

./gradlew -PscalaVersion=2.8.1 clean publishToMavenLocal
gradle だ、 yarn だ compileScala だ、、色々やってます。
BUILD SUCCESSFUL

お。

次。

git clone git://github.com/linkedin/hello-samza.git

これはディレクトリどこでやるんかな？？？
いままで親切に cd とか書いてあって今回はないのでそのまま incubator-samza で実施。

bin/grid 。。 bin ない。
cd hello-samza/　しなきゃだった。最初の git clone は cd incubator-samza してたのに、いきなり冷たくなって。。。

bin/grid

EXECUTING: install zookeeper
とか言い始めた。

EXECUTING: install kafka
とか言い始めた。
EXECUTING: start zookeeper
JMX enabled by default
Using config: .....incubator-samza/hello-samza/deploy/zookeeper/bin/../conf/zoo.cfg
Starting zookeeper ... STARTED
EXECUTING: start yarn
EXECUTING: start kafka

なんもしてないけど、 zookeeper, yarn, kafka 動いているらしい。
俺すごい！！

はい、次。

mvn clean package(@hello-samza)
mvn ない！ apt-get install！

はい、次。

Run a Samza Jobするぞと。

If you check the YARN UI, again, you'll see that all three jobs are now listed.

と言われたんで、8088 見たら job が３つになってた。

なんで、まぁいいかと。

bin/grid stop yarn
bin/grid stop kafka
bin/grid stop zookeeper

もう一回やるときはどこからやればいいんだろうか。