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)
