Skip to content
Permalink
Browse files
[FLINK-25934] Use apache/flink-statefun-playground image in docker-co…
…mpose.ymls
  • Loading branch information
tillrohrmann committed Feb 7, 2022
1 parent e956104 commit 1529f87048fba52c9f287bbfa002abc4d935e0ea
Showing 9 changed files with 41 additions and 202 deletions.
@@ -33,31 +33,15 @@ services:
# StateFun runtime
###############################################################

statefun-manager:
image: apache/flink-statefun:3.2.0
expose:
- "6123"
statefun:
image: apache/flink-statefun-playground:3.2.0
ports:
- "8081:8081"
environment:
ROLE: master
MASTER_HOST: statefun-manager
volumes:
- ./module.yaml:/opt/statefun/modules/greeter/module.yaml

statefun-worker:
image: apache/flink-statefun:3.2.0
expose:
- "6121"
- "6122"
depends_on:
- statefun-manager
- kafka
environment:
ROLE: worker
MASTER_HOST: statefun-manager
- functions
volumes:
- ./module.yaml:/opt/statefun/modules/greeter/module.yaml
- ./module.yaml:/module.yaml

###############################################################
# Kafka for ingress and egress
@@ -90,7 +74,7 @@ services:
image: ververica/statefun-playground-producer:latest
depends_on:
- kafka
- statefun-worker
- statefun
environment:
APP_PATH: /mnt/input-example.json
APP_KAFKA_HOST: kafka:9092
@@ -23,28 +23,14 @@ services:
# StateFun runtime
###############################################################

statefun-manager:
image: apache/flink-statefun:3.2.0
expose:
- "6123"
statefun:
image: apache/flink-statefun-playground:3.2.0
ports:
- "8081:8081"
environment:
ROLE: master
MASTER_HOST: statefun-manager
volumes:
- ./module.yaml:/opt/statefun/modules/greeter/module.yaml

statefun-worker:
image: apache/flink-statefun:3.2.0
expose:
- "6121"
- "6122"
environment:
ROLE: worker
MASTER_HOST: statefun-manager
depends_on:
- kafka
volumes:
- ./module.yaml:/opt/statefun/modules/greeter/module.yaml
- ./module.yaml:/module.yaml

###############################################################
# Kafka for ingress and egress
@@ -34,36 +34,15 @@ services:
# StateFun runtime
###############################################################

statefun-manager:
image: apache/flink-statefun:3.2.0-java11
expose:
- "6123"
statefun:
image: apache/flink-statefun-playground:3.2.0
ports:
- "8081:8081"
environment:
ROLE: master
MASTER_HOST: statefun-manager
volumes:
- ./module.yaml:/opt/statefun/modules/connected-components/module.yaml

statefun-worker:
image: apache/flink-statefun:3.2.0-java11
expose:
- "6121"
- "6122"
depends_on:
- statefun-manager
- kafka
- connected-components-functions
links:
- "statefun-manager:statefun-manager"
- "kafka:kafka"
- "connected-components-functions:connected-components-functions"
environment:
ROLE: worker
MASTER_HOST: statefun-manager
volumes:
- ./module.yaml:/opt/statefun/modules/connected-components/module.yaml
- ./module.yaml:/module.yaml

###############################################################
# Kafka for ingress and egress
@@ -82,8 +61,6 @@ services:
- "9092:9092"
depends_on:
- zookeeper
links:
- "zookeeper:zookeeper"
environment:
KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka:9092
@@ -98,9 +75,7 @@ services:
image: ververica/statefun-playground-producer:latest
depends_on:
- kafka
- statefun-worker
links:
- "kafka:kafka"
- statefun
environment:
APP_PATH: /mnt/vertices.txt
APP_KAFKA_HOST: kafka:9092
@@ -34,36 +34,15 @@ services:
# StateFun runtime
###############################################################

statefun-manager:
image: apache/flink-statefun:3.2.0-java11
expose:
- "6123"
statefun:
image: apache/flink-statefun-playground:3.2.0
ports:
- "8081:8081"
environment:
ROLE: master
MASTER_HOST: statefun-manager
volumes:
- ./module.yaml:/opt/statefun/modules/greeter/module.yaml

statefun-worker:
image: apache/flink-statefun:3.2.0-java11
expose:
- "6121"
- "6122"
depends_on:
- statefun-manager
- kafka
- greeter-functions
links:
- "statefun-manager:statefun-manager"
- "kafka:kafka"
- "greeter-functions:greeter-functions"
environment:
ROLE: worker
MASTER_HOST: statefun-manager
volumes:
- ./module.yaml:/opt/statefun/modules/greeter/module.yaml
- ./module.yaml:/module.yaml

###############################################################
# Kafka for ingress and egress
@@ -98,9 +77,7 @@ services:
image: ververica/statefun-playground-producer:latest
depends_on:
- kafka
- statefun-worker
links:
- "kafka:kafka"
- statefun
environment:
APP_PATH: /mnt/user-logins.txt
APP_KAFKA_HOST: kafka:9092
@@ -34,36 +34,15 @@ services:
# StateFun runtime
###############################################################

statefun-manager:
image: apache/flink-statefun:3.2.0-java11
expose:
- "6123"
statefun:
image: apache/flink-statefun-playground:3.2.0
ports:
- "8081:8081"
environment:
ROLE: master
MASTER_HOST: statefun-manager
volumes:
- ./module.yaml:/opt/statefun/modules/shopping-cart/module.yaml

statefun-worker:
image: apache/flink-statefun:3.2.0-java11
expose:
- "6121"
- "6122"
depends_on:
- statefun-manager
- kafka
- shopping-cart-functions
links:
- "statefun-manager:statefun-manager"
- "kafka:kafka"
- "shopping-cart-functions:shopping-cart-functions"
environment:
ROLE: worker
MASTER_HOST: statefun-manager
volumes:
- ./module.yaml:/opt/statefun/modules/shopping-cart/module.yaml
- ./module.yaml:/module.yaml

###############################################################
# Kafka for ingress and egress
@@ -82,8 +61,6 @@ services:
- "9092:9092"
depends_on:
- zookeeper
links:
- "zookeeper:zookeeper"
environment:
KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka:9092
@@ -33,31 +33,15 @@ services:
# StateFun runtime
###############################################################

statefun-manager:
image: apache/flink-statefun:3.2.0-java11
expose:
- "6123"
statefun:
image: apache/flink-statefun-playground:3.2.0
ports:
- "8081:8081"
environment:
ROLE: master
MASTER_HOST: statefun-manager
volumes:
- ./module.yaml:/opt/statefun/modules/greeter/module.yaml

statefun-worker:
image: apache/flink-statefun:3.2.0-java11
expose:
- "6121"
- "6122"
depends_on:
- statefun-manager
- kafka
environment:
ROLE: worker
MASTER_HOST: statefun-manager
- functions
volumes:
- ./module.yaml:/opt/statefun/modules/greeter/module.yaml
- ./module.yaml:/module.yaml

###############################################################
# Kafka for ingress and egress
@@ -90,7 +74,7 @@ services:
image: ververica/statefun-playground-producer:latest
depends_on:
- kafka
- statefun-worker
- statefun
environment:
APP_PATH: /mnt/input-example.json
APP_KAFKA_HOST: kafka:9092
@@ -23,28 +23,14 @@ services:
# StateFun runtime
###############################################################

statefun-manager:
image: apache/flink-statefun:3.2.0-java11
expose:
- "6123"
statefun:
image: apache/flink-statefun-playground:3.2.0
ports:
- "8081:8081"
environment:
ROLE: master
MASTER_HOST: statefun-manager
volumes:
- ./module.yaml:/opt/statefun/modules/greeter/module.yaml

statefun-worker:
image: apache/flink-statefun:3.2.0-java11
expose:
- "6121"
- "6122"
environment:
ROLE: worker
MASTER_HOST: statefun-manager
depends_on:
- kafka
volumes:
- ./module.yaml:/opt/statefun/modules/greeter/module.yaml
- ./module.yaml:/module.yaml

###############################################################
# Kafka for ingress and egress
@@ -33,31 +33,15 @@ services:
# StateFun runtime
###############################################################

statefun-manager:
image: apache/flink-statefun:3.2.0-java11
expose:
- "6123"
statefun:
image: apache/flink-statefun-playground:3.2.0
ports:
- "8081:8081"
environment:
ROLE: master
MASTER_HOST: statefun-manager
volumes:
- ./module.yaml:/opt/statefun/modules/greeter/module.yaml

statefun-worker:
image: apache/flink-statefun:3.2.0-java11
expose:
- "6121"
- "6122"
depends_on:
- statefun-manager
- kafka
environment:
ROLE: worker
MASTER_HOST: statefun-manager
- functions
volumes:
- ./module.yaml:/opt/statefun/modules/greeter/module.yaml
- ./module.yaml:/module.yaml

###############################################################
# Kafka for ingress and egress
@@ -90,7 +74,7 @@ services:
image: ververica/statefun-playground-producer:latest
depends_on:
- kafka
- statefun-worker
- statefun
environment:
APP_PATH: /mnt/input-example.json
APP_KAFKA_HOST: kafka:9092
@@ -23,28 +23,14 @@ services:
# StateFun runtime
###############################################################

statefun-manager:
image: apache/flink-statefun:3.2.0-java11
expose:
- "6123"
statefun:
image: apache/flink-statefun-playground:3.2.0
ports:
- "8081:8081"
environment:
ROLE: master
MASTER_HOST: statefun-manager
volumes:
- ./module.yaml:/opt/statefun/modules/greeter/module.yaml

statefun-worker:
image: apache/flink-statefun:3.2.0-java11
expose:
- "6121"
- "6122"
environment:
ROLE: worker
MASTER_HOST: statefun-manager
depends_on:
- kafka
volumes:
- ./module.yaml:/opt/statefun/modules/greeter/module.yaml
- ./module.yaml:/module.yaml

###############################################################
# Kafka for ingress and egress

0 comments on commit 1529f87

Please sign in to comment.