#!/bin/bash export JAVA_HOME=/usr/local/jdk-11.0.20/ bin/sql-client.sh embedded -f kafka-user-credential-sink-dwd-user-info -l /data/soft/flink/flink-libs