There needs to be a Flink session cluster available to the SQL client on which it can run the jobs created by your queries. See the Getting Started [1] section of the SQL Client documentation for more information:
The SQL Client is bundled in the regular Flink distribution and thus runnable out-of-the-box. It requires only a running Flink cluster where table programs can be executed. For more information about setting up a Flink cluster see the Cluster & Deployment part [2]. If you simply want to try out the SQL Client, you can also start a local cluster with one worker using the following command: ./bin/start-cluster.sh [1] https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/sqlClient.html#getting-started [2] https://ci.apache.org/projects/flink/flink-docs-stable/deployment/resource-providers/standalone Regards, David On Fri, Mar 26, 2021 at 9:50 AM Yik San Chan <evan.chanyik...@gmail.com> wrote: > The question is cross-posted in Stack Overflow > https://stackoverflow.com/questions/66813644/flink-sql-client-select-hello-world-throws-error-could-not-execute-sql-stat > . > > I am following Flink SQL client docs > https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/sqlClient.html#dependencies. > Opening the Flink SQL client looks fine, but `SELECT 'hello world'` doesn't > work. > > ``` > $ /data/apache/flink/flink-1.12.0/bin/sql-client.sh embedded > SLF4J: Class path contains multiple SLF4J bindings. > SLF4J: Found binding in > [jar:file:/data/apache/flink/flink-1.12.0/lib/log4j-slf4j-impl-2.12.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] > SLF4J: Found binding in > [jar:file:/data/apache/hadoop/hadoop-2.7.3/share/hadoop/common/lib/slf4j-log4j12-1.7.10.jar!/org/slf4j/impl/StaticLoggerBinder.class] > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an > explanation. > SLF4J: Actual binding is of type > [org.apache.logging.slf4j.Log4jLoggerFactory] > No default environment specified. > Searching for > '/data/apache/flink/flink-1.12.0/conf/sql-client-defaults.yaml'...found. > Reading default environment from: > file:/data/apache/flink/flink-1.12.0/conf/sql-client-defaults.yaml > No session environment specified. > > Command history file path: /data/home/pal-flink/.flink-sql-history > ▒▓██▓██▒ > ▓████▒▒█▓▒▓███▓▒ > ▓███▓░░ ▒▒▒▓██▒ ▒ > ░██▒ ▒▒▓▓█▓▓▒░ ▒████ > ██▒ ░▒▓███▒ ▒█▒█▒ > ░▓█ ███ ▓░▒██ > ▓█ ▒▒▒▒▒▓██▓░▒░▓▓█ > █░ █ ▒▒░ ███▓▓█ ▒█▒▒▒ > ████░ ▒▓█▓ ██▒▒▒ ▓███▒ > ░▒█▓▓██ ▓█▒ ▓█▒▓██▓ ░█░ > ▓░▒▓████▒ ██ ▒█ █▓░▒█▒░▒█▒ > ███▓░██▓ ▓█ █ █▓ ▒▓█▓▓█▒ > ░██▓ ░█░ █ █▒ ▒█████▓▒ ██▓░▒ > ███░ ░ █░ ▓ ░█ █████▒░░ ░█░▓ ▓░ > ██▓█ ▒▒▓▒ ▓███████▓░ ▒█▒ ▒▓ ▓██▓ > ▒██▓ ▓█ █▓█ ░▒█████▓▓▒░ ██▒▒ █ ▒ ▓█▒ > ▓█▓ ▓█ ██▓ ░▓▓▓▓▓▓▓▒ ▒██▓ ░█▒ > ▓█ █ ▓███▓▒░ ░▓▓▓███▓ ░▒░ ▓█ > ██▓ ██▒ ░▒▓▓███▓▓▓▓▓██████▓▒ ▓███ █ > ▓███▒ ███ ░▓▓▒░░ ░▓████▓░ ░▒▓▒ █▓ > █▓▒▒▓▓██ ░▒▒░░░▒▒▒▒▓██▓░ █▓ > ██ ▓░▒█ ▓▓▓▓▒░░ ▒█▓ ▒▓▓██▓ ▓▒ ▒▒▓ > ▓█▓ ▓▒█ █▓░ ░▒▓▓██▒ ░▓█▒ ▒▒▒░▒▒▓█████▒ > ██░ ▓█▒█▒ ▒▓▓▒ ▓█ █░ ░░░░ ░█▒ > ▓█ ▒█▓ ░ █░ ▒█ █▓ > █▓ ██ █░ ▓▓ ▒█▓▓▓▒█░ > █▓ ░▓██░ ▓▒ ▓█▓▒░░░▒▓█░ ▒█ > ██ ▓█▓░ ▒ ░▒█▒██▒ ▓▓ > ▓█▒ ▒█▓▒░ ▒▒ █▒█▓▒▒░░▒██ > ░██▒ ▒▓▓▒ ▓██▓▒█▒ ░▓▓▓▓▒█▓ > ░▓██▒ ▓░ ▒█▓█ ░░▒▒▒ > ▒▓▓▓▓▓▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒░░▓▓ ▓░▒█░ > > ______ _ _ _ _____ ____ _ _____ _ _ _ > BETA > | ____| (_) | | / ____|/ __ \| | / ____| (_) | | > | |__ | |_ _ __ | | __ | (___ | | | | | | | | |_ ___ _ __ | > |_ > | __| | | | '_ \| |/ / \___ \| | | | | | | | | |/ _ \ '_ \| > __| > | | | | | | | | < ____) | |__| | |____ | |____| | | __/ | | | > |_ > |_| |_|_|_| |_|_|\_\ |_____/ \___\_\______| \_____|_|_|\___|_| > |_|\__| > > Welcome! Enter 'HELP;' to list all available commands. 'QUIT;' to > exit. > > > Flink SQL> SELECT 'Hello World'; > [ERROR] Could not execute SQL statement. Reason: > org.apache.flink.runtime.client.JobSubmissionException: Failed to submit > JobGraph. > ``` > > Any help? Thanks. > > Best, > Yik San >
