You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Xi (Jira)" <ji...@apache.org> on 2021/08/16 03:12:00 UTC
[jira] [Created] (FLINK-23788) sql-client.sh cannot run on Windows
10 PRO Edition
Xi created FLINK-23788:
--------------------------
Summary: sql-client.sh cannot run on Windows 10 PRO Edition
Key: FLINK-23788
URL: https://issues.apache.org/jira/browse/FLINK-23788
Project: Flink
Issue Type: Bug
Components: Client / Job Submission
Affects Versions: 1.13.2
Reporter: Xi
I'm trying to submit SQL task to my docker-desktop(docker-engine 20.10.8, Windows 10, git-bash 4.4.23 x86-64 ) based Kubernetes(1.21.3) cluster. My operations are as following:
# Download and extract 1.13.2 tar ball to get a directory named 'flink-1.13.2'
# Enter the subdirectory flink-1.13.2
# Execute `./bin/sql-client.sh` and I got following content:
{code:java}
//代码占位符
Error: Could not find or load main class org.apache.flink.table.client.SqlClient
Caused by: java.lang.ClassNotFoundException: org.apache.flink.table.client.SqlClient
{code}
After adding set -x to the head of ./bin/sqlclient.sh and re-execute the script I got this:
{code:java}
//代码占位符
+ exec 'C:\Program Files\Java\jdk-11.0.12/bin/java' -Dlog.file=/c/Users/yi/programs/flink-1.13.2/log/flink--sql-client-yi-station.log -Dlog4j.configuration=file:/c/Users/yi/programs/flink-1.13.2/conf/log4j-cli.properties -Dlog4j.configurationFile=file:/c/Users/yi/programs/flink-1.13.2/conf/log4j-cli.properties -Dlogback.configurationFile=file:/c/Users/yi/programs/flink-1.13.2/conf/logback.xml -classpath /c/Users/yi/programs/flink-1.13.2/lib/flink-csv-1.13.2.jar:/c/Users/yi/programs/flink-1.13.2/lib/flink-json-1.13.2.jar:/c/Users/yi/programs/flink-1.13.2/lib/flink-shaded-zookeeper-3.4.14.jar:/c/Users/yi/programs/flink-1.13.2/lib/flink-table-blink_2.12-1.13.2.jar:/c/Users/yi/programs/flink-1.13.2/lib/flink-table_2.12-1.13.2.jar:/c/Users/yi/programs/flink-1.13.2/lib/log4j-1.2-api-2.12.1.jar:/c/Users/yi/programs/flink-1.13.2/lib/log4j-api-2.12.1.jar:/c/Users/yi/programs/flink-1.13.2/lib/log4j-core-2.12.1.jar:/c/Users/yi/programs/flink-1.13.2/lib/log4j-slf4j-impl-2.12.1.jar:/c/Users/yi/programs/flink-1.13.2/lib/flink-dist_2.12-1.13.2.jar:/c/Users/yi/programs/flink-1.13.2/opt/flink-python_2.12-1.13.2.jar::::/c/Users/yi/programs/flink-1.13.2/opt/flink-sql-client_2.12-1.13.2.jar org.apache.flink.table.client.SqlClient --jar /c/Users/yi/programs/flink-1.13.2/opt/flink-sql-client_2.12-1.13.2.jar
Error: Could not find or load main class org.apache.flink.table.client.SqlClient
Caused by: java.lang.ClassNotFoundException: org.apache.flink.table.client.SqlClient
{code}
It seems like the appearance of multiple ":" (::::) that result in this failure. Then actually I changed the function 'manglePathList' located in './bin/config.sh' as following:
{code:java}
//代码占位符
72 manglePathList() {
73 UNAME=$(uname -s)
74 # a path list, for example a java classpath
75 if [ "${UNAME:0:6}" == "CYGWIN" ]; then
76 echo `cygpath -wp "$1"`|sed -E 's/:+/:/g'
77 else
78 echo $1|sed -E 's/:+/:/g'
79 fi
80 }
{code}
NOTE: just replace multiple ":" into single ":" separator.
Then the script can be started successfully(but with a failure to load log4j-cli.properties).
{code:java}
//代码占位符
+ exec 'C:\Program Files\Java\jdk-11.0.12/bin/java' -Dlog.file=/c/Users/yi/programs/flink-1.13.2/log/flink--sql-client-yi-station.log -Dlog4j.configuration=file:/c/Users/yi/programs/flink-1.13.2/conf/log4j-cli.properties -Dlog4j.configurationFile=file:/c/Users/yi/programs/flink-1.13.2/conf/log4j-cli.properties -Dlogback.configurationFile=file:/c/Users/yi/programs/flink-1.13.2/conf/logback.xml -classpath /c/Users/yi/programs/flink-1.13.2/lib/flink-csv-1.13.2.jar:/c/Users/yi/programs/flink-1.13.2/lib/flink-json-1.13.2.jar:/c/Users/yi/programs/flink-1.13.2/lib/flink-shaded-zookeeper-3.4.14.jar:/c/Users/yi/programs/flink-1.13.2/lib/flink-table-blink_2.12-1.13.2.jar:/c/Users/yi/programs/flink-1.13.2/lib/flink-table_2.12-1.13.2.jar:/c/Users/yi/programs/flink-1.13.2/lib/log4j-1.2-api-2.12.1.jar:/c/Users/yi/programs/flink-1.13.2/lib/log4j-api-2.12.1.jar:/c/Users/yi/programs/flink-1.13.2/lib/log4j-core-2.12.1.jar:/c/Users/yi/programs/flink-1.13.2/lib/log4j-slf4j-impl-2.12.1.jar:/c/Users/yi/programs/flink-1.13.2/lib/flink-dist_2.12-1.13.2.jar:/c/Users/yi/programs/flink-1.13.2/opt/flink-python_2.12-1.13.2.jar:/c/Users/yi/programs/flink-1.13.2/opt/flink-sql-client_2.12-1.13.2.jar org.apache.flink.table.client.SqlClient
ERROR StatusLogger Unable to access file:/c/Users/yi/programs/flink-1.13.2/conf/log4j-cli.properties
java.io.FileNotFoundException: \c\Users\yi\programs\flink-1.13.2\conf\log4j-cli.properties (The system cannot find the path specified)
at java.base/java.io.FileInputStream.open0(Native Method)
at java.base/java.io.FileInputStream.open(FileInputStream.java:219)
at java.base/java.io.FileInputStream.<init>(FileInputStream.java:157)
at java.base/java.io.FileInputStream.<init>(FileInputStream.java:112)
at java.base/sun.net.www.protocol.file.FileURLConnection.connect(FileURLConnection.java:86)
at java.base/sun.net.www.protocol.file.FileURLConnection.getInputStream(FileURLConnection.java:184)
at org.apache.logging.log4j.core.config.ConfigurationSource.fromUri(ConfigurationSource.java:321)
at org.apache.logging.log4j.core.config.ConfigurationFactory$Factory.getConfiguration(ConfigurationFactory.java:443)
at org.apache.logging.log4j.core.config.ConfigurationFactory$Factory.getConfiguration(ConfigurationFactory.java:385)
at org.apache.logging.log4j.core.config.ConfigurationFactory.getConfiguration(ConfigurationFactory.java:293)
at org.apache.logging.log4j.core.LoggerContext.reconfigure(LoggerContext.java:647)
at org.apache.logging.log4j.core.LoggerContext.reconfigure(LoggerContext.java:668)
at org.apache.logging.log4j.core.LoggerContext.start(LoggerContext.java:253)
at org.apache.logging.log4j.core.impl.Log4jContextFactory.getContext(Log4jContextFactory.java:153)
at org.apache.logging.log4j.core.impl.Log4jContextFactory.getContext(Log4jContextFactory.java:45)
at org.apache.logging.log4j.LogManager.getContext(LogManager.java:194)
at org.apache.logging.log4j.spi.AbstractLoggerAdapter.getContext(AbstractLoggerAdapter.java:138)
at org.apache.logging.slf4j.Log4jLoggerFactory.getContext(Log4jLoggerFactory.java:45)
at org.apache.logging.log4j.spi.AbstractLoggerAdapter.getLogger(AbstractLoggerAdapter.java:48)
at org.apache.logging.slf4j.Log4jLoggerFactory.getLogger(Log4jLoggerFactory.java:30)
at org.slf4j.LoggerFactory.getLogger(LoggerFactory.java:329)
at org.slf4j.LoggerFactory.getLogger(LoggerFactory.java:349)
at org.apache.flink.table.client.SqlClient.<clinit>(SqlClient.java:64)
ERROR StatusLogger Reconfiguration failed: No configuration found for '6659c656' at 'null' in 'null'
No default environment specified.
Searching for 'C:/Users/yi/programs/flink-1.13.2/conf/sql-client-defaults.yaml'...not found.
Command history file path: C:\Users\yi\flink-sql-history ?▒▒▒▒▒▒▒▒▒▒▒▒?
▒▒▒▒▒▒▒▒▒▒??▒▒▒▒?▒▒▒▒▒▒▒▒▒▒?
▒▒▒▒▒▒▒▒▒▒?? ???▒▒▒▒▒▒? ?
?▒▒▒▒? ??▒▒▒▒▒▒▒▒▒▒?? ?▒▒▒▒▒▒▒▒
▒▒▒▒? ??▒▒▒▒▒▒▒▒? ?▒▒?▒▒?
?▒▒▒▒ ▒▒▒▒▒▒ ▒▒??▒▒▒▒
▒▒▒▒ ?????▒▒▒▒▒▒▒▒???▒▒▒▒▒▒
▒▒? ▒▒ ??? ▒▒▒▒▒▒▒▒▒▒▒▒ ?▒▒???
▒▒▒▒▒▒▒▒? ?▒▒▒▒▒▒ ▒▒▒▒??? ▒▒▒▒▒▒▒▒?
??▒▒▒▒▒▒▒▒▒▒ ▒▒▒▒? ▒▒▒▒?▒▒▒▒▒▒▒▒ ?▒▒?
▒▒??▒▒▒▒▒▒▒▒▒▒? ▒▒▒▒ ?▒▒ ▒▒▒▒??▒▒???▒▒?
▒▒▒▒▒▒▒▒?▒▒▒▒▒▒ ▒▒▒▒ ▒▒ ▒▒▒▒ ?▒▒▒▒▒▒▒▒▒▒?
?▒▒▒▒▒▒ ?▒▒? ▒▒ ▒▒? ?▒▒▒▒▒▒▒▒▒▒▒▒? ▒▒▒▒▒▒??
▒▒▒▒▒▒? ? ▒▒? ▒▒ ?▒▒ ▒▒▒▒▒▒▒▒▒▒??? ?▒▒?▒▒ ▒▒?
▒▒▒▒▒▒▒▒ ??▒▒? ▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒? ?▒▒? ?▒▒ ▒▒▒▒▒▒▒▒
?▒▒▒▒▒▒ ▒▒▒▒ ▒▒▒▒▒▒ ??▒▒▒▒▒▒▒▒▒▒▒▒▒▒?? ▒▒▒▒?? ▒▒ ? ▒▒▒▒?
▒▒▒▒▒▒ ▒▒▒▒ ▒▒▒▒▒▒ ?▒▒▒▒▒▒▒▒▒▒▒▒▒▒? ?▒▒▒▒▒▒ ?▒▒?
▒▒▒▒ ▒▒ ▒▒▒▒▒▒▒▒▒▒?? ?▒▒▒▒▒▒▒▒▒▒▒▒▒▒ ??? ▒▒▒▒
▒▒▒▒▒▒ ▒▒▒▒? ??▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒? ▒▒▒▒▒▒▒▒ ▒▒
▒▒▒▒▒▒▒▒? ▒▒▒▒▒▒ ?▒▒▒▒??? ?▒▒▒▒▒▒▒▒▒▒▒▒? ??▒▒? ▒▒▒▒
▒▒▒▒??▒▒▒▒▒▒▒▒ ??????????▒▒▒▒▒▒▒▒? ▒▒▒▒
▒▒▒▒ ▒▒??▒▒ ▒▒▒▒▒▒▒▒??? ?▒▒▒▒ ?▒▒▒▒▒▒▒▒▒▒ ▒▒? ??▒▒
▒▒▒▒▒▒ ▒▒?▒▒ ▒▒▒▒? ??▒▒▒▒▒▒▒▒? ?▒▒▒▒? ??????▒▒▒▒▒▒▒▒▒▒▒▒?
▒▒▒▒? ▒▒▒▒?▒▒? ?▒▒▒▒? ▒▒▒▒ ▒▒? ???? ?▒▒?
▒▒▒▒ ?▒▒▒▒ ? ▒▒? ?▒▒ ▒▒▒▒
▒▒▒▒ ▒▒▒▒ ▒▒? ▒▒▒▒ ?▒▒▒▒▒▒▒▒?▒▒?
▒▒▒▒ ?▒▒▒▒▒▒? ▒▒? ▒▒▒▒▒▒?????▒▒▒▒? ?▒▒
▒▒▒▒ ▒▒▒▒▒▒? ? ??▒▒?▒▒▒▒? ▒▒▒▒
▒▒▒▒? ?▒▒▒▒?? ?? ▒▒?▒▒▒▒?????▒▒▒▒
?▒▒▒▒? ?▒▒▒▒? ▒▒▒▒▒▒▒▒?▒▒? ?▒▒▒▒▒▒▒▒?▒▒▒▒
?▒▒▒▒▒▒? ▒▒? ?▒▒▒▒▒▒ ?????
?▒▒▒▒▒▒▒▒▒▒?????????????????????????▒▒▒▒ ▒▒??▒▒? ______ _ _ _ _____ ____ _ _____ _ _ _ BETA
| ____| (_) | | / ____|/ __ \| | / ____| (_) | |
| |__ | |_ _ __ | | __ | (___ | | | | | | | | |_ ___ _ __ | |_
| __| | | | '_ \| |/ / \___ \| | | | | | | | | |/ _ \ '_ \| __|
| | | | | | | | < ____) | |__| | |____ | |____| | | __/ | | | |_
|_| |_|_|_| |_|_|\_\ |_____/ \___\_\______| \_____|_|_|\___|_| |_|\__| Welcome! Enter 'HELP;' to list all available commands. 'QUIT;' to exit.
Flink SQL>
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)