You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Chen Zun (JIRA)" <ji...@apache.org> on 2019/02/01 11:00:00 UTC

[jira] [Commented] (FLINK-11506) In the Windows environment, through sql-client, execute the SQL statement for a few minutes after the client interrupt exit, reported IO exception

    [ https://issues.apache.org/jira/browse/FLINK-11506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16758217#comment-16758217 ] 

Chen Zun commented on FLINK-11506:
----------------------------------

I have uploaded my configuration file: sql-client-config.yaml

The file path of TaxiRides and TaxiFares is modified to be my local data file path.

> In the Windows environment, through sql-client, execute the SQL statement for a few minutes after the client interrupt exit, reported IO exception
> --------------------------------------------------------------------------------------------------------------------------------------------------
>
>                 Key: FLINK-11506
>                 URL: https://issues.apache.org/jira/browse/FLINK-11506
>             Project: Flink
>          Issue Type: Bug
>          Components: Table API &amp; SQL
>    Affects Versions: 1.7.1
>         Environment: windows7
> cygwin64
>  java -version
> java version "1.8.0_101"
> Java(TM) SE Runtime Environment (build 1.8.0_101-b13)
> Java HotSpot(TM) 64-Bit Server VM (build 25.101-b13, mixed mode)
>            Reporter: Chen Zun
>            Priority: Major
>         Attachments: sql-client-config.yaml
>
>
>  When I executed SQL statements using sql-client: select * from TaixFares; Report the following Exception:
> {code:java}
> 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.main(SqlClient.java:199) Caused by: java.io.IOError: java.io.InterruptedIOException: Command interrupted at org.jline.terminal.impl.AbstractPosixTerminal.setAttributes(AbstractPosixTerminal.java:54) at org.apache.flink.table.client.cli.CliView.restoreTerminal(CliView.java:398) at org.apache.flink.table.client.cli.CliView.open(CliView.java:143) at org.apache.flink.table.client.cli.CliClient.callSelect(CliClient.java:401) at org.apache.flink.table.client.cli.CliClient.callCommand(CliClient.java:261) at java.util.Optional.ifPresent(Optional.java:159) at org.apache.flink.table.client.cli.CliClient.open(CliClient.java:193) at org.apache.flink.table.client.SqlClient.openCli(SqlClient.java:121) at org.apache.flink.table.client.SqlClient.start(SqlClient.java:105) at org.apache.flink.table.client.SqlClient.main(SqlClient.java:187) Caused by: java.io.InterruptedIOException: Command interrupted at org.jline.utils.ExecHelper.exec(ExecHelper.java:46) at org.jline.terminal.impl.ExecPty.doGetConfig(ExecPty.java:175) at org.jline.terminal.impl.ExecPty.getAttr(ExecPty.java:87) at org.jline.terminal.impl.ExecPty.doSetAttr(ExecPty.java:93) at org.jline.terminal.impl.AbstractPty.setAttr(AbstractPty.java:21) at org.jline.terminal.impl.AbstractPosixTerminal.setAttributes(AbstractPosixTerminal.java:52) ... 9 more Caused by: java.lang.InterruptedException at java.lang.ProcessImpl.waitFor(ProcessImpl.java:451) at org.jline.utils.ExecHelper.waitAndCapture(ExecHelper.java:66) at org.jline.utils.ExecHelper.exec(ExecHelper.java:36) ... 14 more Shutting down executor...done.{code}



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)