Anomaly detection in Apache Spark and Flink with Machine Learning Libraries
Cloning the repository
git clone https://github.com/etkinpinar/anomaly-detection
cd anomaly-detection
Running Spark container
cd spark
docker-compose up -d
Installing numpy into masternode via pip
docker exec masternode pip install numpy
Running Flink container
cd ../flink
docker-compose up --scale taskmanager=2 -d
cd ../web-ui
pip install flask
python main.py