Zeppelin初体验

Zepplin是一个很有意思的笔记本，支持众多interpreter，包括Flink。在网上找了很多资料，发现直接使用二进制包，或者从源码编译，均无法向Flink 1.7.1提交作业。0.81和0.9.0-SNAPHOST都试过。跟同事咨询了一下，找到一个Zeppelin+Blink的镜像，体验特别好。

$ docker run -d -p 8085:8085 -p 8091:8091 zjffdu/zeppelin-blink:latest                                                                                                         <java:1.8>
Unable to find image 'zjffdu/zeppelin-blink:latest' locally
latest: Pulling from zjffdu/zeppelin-blink
7b722c1070cd: Already exists 
5fbf74db61f1: Already exists 
ed41cb72e5c9: Already exists 
7ea47a67709e: Already exists 
a3e223183687: Downloading [=========>                                         ]  26.18MB/131.6MB
a3e223183687: Downloading [===========>                                       ]  30.42MB/131.6MB
a3e223183687: Downloading [===========>                                       ]  30.95MB/131.6MB
a3e223183687: Pull complete 
c5d0ab79487e: Pull complete 
6f8bf201347f: Pull complete 
87b8ed2447d8: Pull complete 
d936882fbddf: Retrying in 1 second 
a10468c16960: Download complete 
d936882fbddf: Pull complete 
a10468c16960: Pull complete 
c4e684b5d1fd: Pull complete 
c4f07b559f6c: Pull complete 
8d4b18067b2f: Pull complete 
a2a59686ecc4: Pull complete 
c1f2871b7ec0: Pull complete 
Digest: sha256:b33cf27bf48a1ca5f268bcb3f4ad82558270c721a2a11655a55779bff3e4c6fb
Status: Downloaded newer image for zjffdu/zeppelin-blink:latest
036598ac615eb9df58ab0a7ed43c43c85f2c94ecc9835ca38f1cb92b71a7b9dc

进入Zeppelin控制台：http://localhost:8085，选择Flink Stream Tutorial。先运行Configure Flink Interpreter，初始化好Flink Interpreter。接着运行Register a Stream DataSource to simulate web log，此时Blink集群会启动。Blink控制台：http://localhost:8091/#/overview。

image.png image.png

有日志之后就可以运行后面的Stream SQL了。可以看到动态更新的图表。

image.png

Zeppelin目前并不支持SQL。如果支持SQL的话，加上Scala，是一个非常好的练手工具。

参考资料

1. Flink interpreter for Apache Zeppelin
2. Rocking with Flink on a Zeppelin