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

SQL client: setting execution.type to invalid value shuts down the session

    XMLWordPrintableJSON

    Details

      Description

      It's annoying to lose all of one's work in a session because of a typo.

       

      Flink SQL> SET execution.type=foo;

      Exception in thread "main" org.apache.flink.table.client.SqlClientException: Invalid configuration entry.

      at org.apache.flink.table.client.config.entries.ConfigEntry.<init>(ConfigEntry.java:41)

      at org.apache.flink.table.client.config.entries.ExecutionEntry.<init>(ExecutionEntry.java:112)

      at org.apache.flink.table.client.config.entries.ExecutionEntry.enrich(ExecutionEntry.java:375)

      at org.apache.flink.table.client.config.Environment.enrich(Environment.java:295)

      at org.apache.flink.table.client.gateway.local.LocalExecutor.setSessionProperty(LocalExecutor.java:284)

      at org.apache.flink.table.client.cli.CliClient.callSet(CliClient.java:370)

      at org.apache.flink.table.client.cli.CliClient.callCommand(CliClient.java:262)

      at java.util.Optional.ifPresent(Optional.java:159)

      at org.apache.flink.table.client.cli.CliClient.open(CliClient.java:200)

      at org.apache.flink.table.client.SqlClient.openCli(SqlClient.java:125)

      at org.apache.flink.table.client.SqlClient.start(SqlClient.java:104)

      at org.apache.flink.table.client.SqlClient.main(SqlClient.java:178)

      Caused by: org.apache.flink.table.api.ValidationException: Unknown value for property 'type'.

      Supported values are [streaming, batch] but was: foo

      at org.apache.flink.table.descriptors.DescriptorProperties.lambda$validateEnum$34(DescriptorProperties.java:1254)

      at org.apache.flink.table.descriptors.DescriptorProperties.validateOptional(DescriptorProperties.java:1520)

      at org.apache.flink.table.descriptors.DescriptorProperties.validateEnum(DescriptorProperties.java:1247)

      at org.apache.flink.table.descriptors.DescriptorProperties.validateEnumValues(DescriptorProperties.java:1266)

      at org.apache.flink.table.client.config.entries.ExecutionEntry.validate(ExecutionEntry.java:123)

      at org.apache.flink.table.client.config.entries.ConfigEntry.<init>(ConfigEntry.java:39)

      ... 11 more

       

      Shutting down the session...

      done.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                Unassigned
                Reporter:
                alpinegizmo David Anderson
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: