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

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.10.0
• Fix Version/s: 1.10.2, 1.11.0, 1.12.0
• Component/s: Table SQL / Client
• Assignee: Unassigned
• Reporter: David Anderson
• Created: 15/Jun/20 09:25
• Updated: 30/Jun/20 13:07
• Resolved: 30/Jun/20 13:07

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.

Issue Links

• is related to: FLINK-16217 SQL Client crashed when any uncatched exception is thrown