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)