README.md

Coin Analyst

Flink based coin analysis

How to Run?

Flink application

Build fink application

cd coinanalyst
mvn clean install -DskipTests
cp coinanalyst/target/coinanalyst-1.0-SNAPSHOT.jar ./ 

Flink cluster

Build docker & run

docker build -t flink .
docker run -d -p 8081:8081 flink

You have to bind port on 8081 for flink web ui

Start flink cluster

docker exec <FLINK-CONTAINER-ID> ./bin/start-cluster.sh

Submit flink job

docker exec <FLINK-CONTAINER-ID> ./bin/flink run coinanalyst-1.0-SNAPSHOT.jar

Access web UI

You can access flink web UI

Reference

Arache Flink Documentation