[jira] [Created] (FLINK-22795) flink sql 1.13 通过 -f 执行位于hdfs上的SQL文件失败。

[Shang Yuanchun (Jira)]

manguozhi created FLINK-22795:
---------------------------------

             Summary: flink sql 1.13 通过 -f 执行位于hdfs上的SQL文件失败。
                 Key: FLINK-22795
                 URL: https://issues.apache.org/jira/browse/FLINK-22795
             Project: Flink
          Issue Type: Bug
          Components: Table SQL / Client
    Affects Versions: 1.13.0
         Environment: flink 1.13

hadoop2.6.0
            Reporter: manguozhi


hi, all

我在flink 1.13 sql cli 中执行

bin/sql-client.sh -f hdfs:/user/test.sql

 

产生以下错误

 

Exception in thread "main" org.apache.flink.table.client.SqlClientException: Unexpected exception. This is a bug. Please consider filing an issue.
 at org.apache.flink.table.client.SqlClient.startClient(SqlClient.java:201)
 at org.apache.flink.table.client.SqlClient.main(SqlClient.java:161)
 Caused by: org.apache.flink.table.client.gateway.SqlExecutionException: Fail to read content from the /opt/flink-1.13.0/hdfs:/user/test.sql.
 at org.apache.flink.table.client.SqlClient.readFromURL(SqlClient.java:250)
 at org.apache.flink.table.client.SqlClient.readExecutionContent(SqlClient.java:239)
 at org.apache.flink.table.client.SqlClient.openCli(SqlClient.java:153)
 at org.apache.flink.table.client.SqlClient.start(SqlClient.java:95)
 at org.apache.flink.table.client.SqlClient.startClient(SqlClient.java:187)
 ... 1 more
 Caused by: java.io.FileNotFoundException: /opt/flink-1.13.0/hdfs:/user/test.sql (No such file or directory)
 at java.io.FileInputStream.open0(Native Method)
 at java.io.FileInputStream.open(FileInputStream.java:195)
 at java.io.FileInputStream.<init>(FileInputStream.java:138)
 at java.io.FileInputStream.<init>(FileInputStream.java:93)
 at sun.net.www.protocol.file.FileURLConnection.connect(FileURLConnection.java:90)
 at sun.net.www.protocol.file.FileURLConnection.getInputStream(FileURLConnection.java:188)
 at java.net.URL.openStream(URL.java:1045)
 at org.apache.commons.io.IOUtils.toString(IOUtils.java:2764)
 at org.apache.flink.table.client.SqlClient.readFromURL(SqlClient.java:247)
 ... 5 more

 Shutting down the session...
 done.

 

经与commiter沟通发现 -f 命令目前只支持本地系统，可以考虑支持例如hdfs等文件系统吗？



--
This message was sent by Atlassian Jira
(v8.3.4#803005)