[
https://issues.apache.org/jira/browse/FLINK-18297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17148655#comment-17148655
]
Leonard Xu edited comment on FLINK-18297 at 6/30/20, 1:07 PM:
--------------------------------------------------------------
Hello, [~alpinegizmo]
Looks like this issue has been fixed in FLINK-16217 , you can try 1.10.2,
1.11.0, 1.12.0
Flink SQL> SET execution.type=foo;
[ERROR] Could not execute SQL statement. Reason:
org.apache.flink.table.api.ValidationException: Unknown value for property
'type'.
Supported values are [streaming, batch] but was: foo
Flink SQL>
I close this ticket, please feel free to reopen if you have any question ^_^
was (Author: leonard xu):
Hello, [~alpinegizmo]
Looks like this issue has been fixed in FLINK-16217 , you can try 1.10.2,
1.11.0, 1.12.0
Flink SQL> SET execution.type=foo;
[ERROR] Could not execute SQL statement. Reason:
org.apache.flink.table.api.ValidationException: Unknown value for property
'type'.
Supported values are [streaming, batch] but was: foo
Flink SQL>
> 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
> Priority: Major
>
> 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.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
