Stream and Batch Processing
Apache Flink
Profiles: flink-lite, flink-full. Stack flink, defined in compose-flink.yml.
flink-lite
Depends on: catalog. odctl up flink-lite also starts: catalog, deps, postgres, storage.
| Service | Image | Host:container ports | Memory limit |
|---|---|---|---|
jobmanager |
flink:2.2-java17 |
8082:8081 |
1500m |
taskmanager-a |
flink:2.2-java17 |
none | 3500m |
sql-gateway |
flink:2.2-java17 |
8084:8083 |
1g |
flink-full
Depends on: catalog. odctl up flink-full also starts: catalog, deps, postgres, storage.
| Service | Image | Host:container ports | Memory limit |
|---|---|---|---|
jobmanager |
flink:2.2-java17 |
8082:8081 |
1500m |
taskmanager-a |
flink:2.2-java17 |
none | 3500m |
taskmanager-b |
flink:2.2-java17 |
none | 3500m |
taskmanager-c |
flink:2.2-java17 |
none | 3500m |
sql-gateway |
flink:2.2-java17 |
8084:8083 |
1g |
Apache Spark
Profiles: spark-lite, spark-full. Stack spark, defined in compose-spark.yml.
spark-lite
Depends on: catalog. odctl up spark-lite also starts: catalog, deps, postgres, storage.
| Service | Image | Host:container ports | Memory limit |
|---|---|---|---|
spark-master |
ghcr.io/jaehyeon-kim/odctl/spark:<CLI version> |
9080:8080, 7077:7077 |
1g |
spark-worker-1 |
ghcr.io/jaehyeon-kim/odctl/spark:<CLI version> |
9081:8081 |
2g |
spark-history |
ghcr.io/jaehyeon-kim/odctl/spark:<CLI version> |
18080:18080 |
1g |
spark-full
Depends on: catalog. odctl up spark-full also starts: catalog, deps, postgres, storage.
| Service | Image | Host:container ports | Memory limit |
|---|---|---|---|
spark-master |
ghcr.io/jaehyeon-kim/odctl/spark:<CLI version> |
9080:8080, 7077:7077 |
1g |
spark-worker-1 |
ghcr.io/jaehyeon-kim/odctl/spark:<CLI version> |
9081:8081 |
2g |
spark-worker-2 |
ghcr.io/jaehyeon-kim/odctl/spark:<CLI version> |
9082:8081 |
2g |
spark-worker-3 |
ghcr.io/jaehyeon-kim/odctl/spark:<CLI version> |
9083:8081 |
2g |
spark-history |
ghcr.io/jaehyeon-kim/odctl/spark:<CLI version> |
18080:18080 |
1g |