Load docker schemas into registry docker exec -it schemas /venv/bin/python3.9 python/importer.py Load the recon schema go/transform/register.sh Enter the Flink SQL Shell docker exec -it jobmanager ./bin/sql-client.sh create