Cluster benchmarking

Dockerfile.pyflink

@@ -0,0 +1,24 @@
+FROM flink:1.20.0-scala_2.12
+
+# Install Python 3.11.11
+RUN apt-get update && apt-get install -y \
+    software-properties-common && \
+    add-apt-repository ppa:deadsnakes/ppa && \
+    apt-get update && \
+    apt-get install -y python3.11 python3.11-venv python3.11-dev && \
+    ln -sf /usr/bin/python3.11 /usr/bin/python && \
+    ln -sf /usr/bin/python3.11 /usr/bin/python3 && \
+    rm -rf /var/lib/apt/lists/*
+
+# Install pip
+RUN python3.11 -m ensurepip --upgrade && \
+    ln -sf /usr/local/bin/pip3 /usr/bin/pip && \
+    ln -sf /usr/local/bin/pip3 /usr/bin/pip3
+
+# Copy requirements file
+COPY requirements.txt /requirements.txt
+
+# Install Python dependencies
+RUN pip install --no-cache-dir -r /requirements.txt
+
+CMD ["bash"]

README.md

@@ -1,5 +1,90 @@
 # Cascade
 
+## Benchmarking
+
+Requirements:
+- Docker
+- Conda
+- Local flink client
+
+1. First create the conda environment with:
+
+```
+conda env create -f environment.yml
+```
+
+2. Activate the environment with:
+
+```
+conda activate cascade_env
+```
+
+3. Start the Kafka and Pyflink local clusters
+
+```
+docker compose up
+```
+
+This will launch:
+
+- a Kafka broker at `localhost:9092` (`kafka:9093` for inter-docker communication!) and,
+- a [Kafbat UI](https://github.com/kafbat/kafka-ui) at http://localhost:8080
+- a local Flink cluster with `PyFlink` and all requirements, with a ui at http://localhost:8081
+
+By default the flink cluster will run with 16 task slots. This can be changed
+setting the `TASK_SLOTS` enviroment variable, for example:
+
+```
+TASK_SLOTS=32 docker compose up
+```
+
+You could also scale up the number of taskmanagers, each with the same defined
+number of task slots (untested):
+
+```
+docker compose up --scale taskmanager=3
+```
+
+Once everything has started (for example, you can see the web UIs running), you 
+can upload the benchmark job to the cluster. Note that the Kafka topics must be
+emptied first, otherwise the job will immediately start consuming old events. 
+You can use the Kafbat UI for this, for example by deleting topics or purging
+messages. To start the job, first navigate to the cascade repo directory e.g. 
+`cd /path/to/cascade`. Then run the following command, where `X` is the default 
+parallelism desired:
+
+```
+flink run --pyFiles /path/to/cascade/src,/path/to/cascade --pyModule deathstar_movie_review.demo -p X
+```
+
+> This command runs `FlinkRuntime.init`, which requires the location of a 
+> flink-python jarfile.
+> The location is currently hardcoded in `src/cascade/runtime/flink_runtime` and 
+> should be changed based on your environment. The jar file is included as part
+> of the flink installation itself, at https://flink.apache.org/downloads/ (1.20.1).
+
+Once the job is submitted, you can start the benchmark. Open another terminal in
+the same directory (and conda environment) and run:
+
+```
+python -m deathstar_movie_review.start_benchmark
+```
+
+This will start the benchmark by sending events to Kafka. The first phase will
+initialise the state required for the benchmark, and is not measured. The second
+phase starts the actual becnhmark.
+
+
+### Notes
+
+Currently trying to scale up higher than `-p 16`, however I ran into the 
+following issue on `-p 64` with `TASK_SLOTS=128`, more configuration might be required? 
+
+```
+Caused by: java.io.IOException: Insufficient number of network buffers: required 65, but only 38 available. The total number of network buffers is currently set to 4096 of 32768 bytes each. You can increase this number by setting the configuration keys 'taskmanager.memory.network.fraction', 'taskmanager.memory.network.min', and 'taskmanager.memory.network.max'.
+```
+
+
 ## Development
 
 Cascade should work with Python 3.10 / 3.11 although other versions could work. Dependencies should first be installed with:
@@ -8,7 +93,7 @@ Cascade should work with Python 3.10 / 3.11 although other versions could work.
 pip install -r requirements.txt
 ```
 
-## Testing
+## (old) Testing
 
 The `pip install` command should have installed a suitable version of `pytest`.