Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-21568

Navigating in SQL client can lead to SqlExecutionException

    XMLWordPrintableJSON

Details

    Description

      Pressing 'p' in the SQL CLI's result browser before any result is available will result in the following exception being thrown:

      2021-03-02 18:27:05,153 WARN  org.apache.flink.table.client.cli.CliClient                  [] - Could not execute SQL statement.
      org.apache.flink.table.client.gateway.SqlExecutionException: Invalid page '1'.
      	at org.apache.flink.table.client.gateway.local.result.MaterializedCollectStreamResult.retrievePage(MaterializedCollectStreamResult.java:177) ~[flink-sql-client_2.12-1.12.1.jar:1.12.1]
      	at org.apache.flink.table.client.gateway.local.LocalExecutor.retrieveResultPage(LocalExecutor.java:415) ~[flink-sql-client_2.12-1.12.1.jar:1.12.1]
      	at org.apache.flink.table.client.cli.CliTableResultView.updatePage(CliTableResultView.java:293) ~[flink-sql-client_2.12-1.12.1.jar:1.12.1]
      	at org.apache.flink.table.client.cli.CliTableResultView.gotoPreviousPage(CliTableResultView.java:381) ~[flink-sql-client_2.12-1.12.1.jar:1.12.1]
      	at org.apache.flink.table.client.cli.CliTableResultView.evaluate(CliTableResultView.java:183) ~[flink-sql-client_2.12-1.12.1.jar:1.12.1]
      	at org.apache.flink.table.client.cli.CliTableResultView.evaluate(CliTableResultView.java:50) ~[flink-sql-client_2.12-1.12.1.jar:1.12.1]
      	at org.apache.flink.table.client.cli.CliView.open(CliView.java:125) ~[flink-sql-client_2.12-1.12.1.jar:1.12.1]
      	at org.apache.flink.table.client.cli.CliClient.callSelect(CliClient.java:675) ~[flink-sql-client_2.12-1.12.1.jar:1.12.1]
      	at org.apache.flink.table.client.cli.CliClient.callCommand(CliClient.java:323) ~[flink-sql-client_2.12-1.12.1.jar:1.12.1]
      	at java.util.Optional.ifPresent(Optional.java:159) [?:1.8.0_282]
      	at org.apache.flink.table.client.cli.CliClient.open(CliClient.java:214) [flink-sql-client_2.12-1.12.1.jar:1.12.1]
      	at org.apache.flink.table.client.SqlClient.openCli(SqlClient.java:144) [flink-sql-client_2.12-1.12.1.jar:1.12.1]
      	at org.apache.flink.table.client.SqlClient.start(SqlClient.java:115) [flink-sql-client_2.12-1.12.1.jar:1.12.1]
      	at org.apache.flink.table.client.SqlClient.main(SqlClient.java:201) [flink-sql-client_2.12-1.12.1.jar:1.12.1]
      

      Attachments

        Activity

          People

            Unassigned Unassigned
            nkruber Nico Kruber
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated: