Vitor Leal
05/26/2023, 5:16 PMflink-sqlclient
, which sends SQL queries to Apache Flink (init script):
flink-jobmanager:
build:
dockerfile: ./apache-flink/Dockerfile
ports:
- '8081:8081'
command: jobmanager
environment:
- |
FLINK_PROPERTIES=
jobmanager.rpc.address: flink-jobmanager
flink-taskmanager:
build:
dockerfile: ./apache-flink/Dockerfile
depends_on:
- flink-jobmanager
command: taskmanager
environment:
- |
FLINK_PROPERTIES=
jobmanager.rpc.address: flink-jobmanager
taskmanager.numberOfTaskSlots: 2
flink-sqlclient:
build:
dockerfile: ./apache-flink/Dockerfile
command: bin/sql-client.sh -f init.sql
depends_on:
- flink-taskmanager
environment:
- |
FLINK_PROPERTIES=
jobmanager.rpc.address: flink-jobmanager
rest.address: flink-jobmanager
it says "Execute statement succeed" for each statement in init.sql
but nothing is actually created? Also if I change
jobmanager.rpc.address: flink-jobmanager
rest.address: flink-jobmanager
to gibberish:
jobmanager.rpc.address: adsasd
rest.address: asdasdf
it still works somehow