[jira] [Created] (FLINK-18297) SQL client: setting execution.type to invalid value shuts down the session

[Shang Yuanchun (Jira)]

David Anderson created FLINK-18297:
--------------------------------------

             Summary: SQL client: setting execution.type to invalid value shuts down the session
                 Key: FLINK-18297
                 URL: https://issues.apache.org/jira/browse/FLINK-18297
             Project: Flink
          Issue Type: Bug
          Components: Table SQL / Client
    Affects Versions: 1.10.0
            Reporter: David Anderson


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.



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