[FLINK-32772] Add support of SET statements in the SQL Runner example

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: kubernetes-operator-1.5.0
• Fix Version/s: kubernetes-operator-1.7.0
• Component/s: Kubernetes Operator
• Labels: pull-request-available
• External issue URL: https://github.com/apache/flink-kubernetes-operator/pull/644
• Assignee: Mehdi
• Reporter: Mehdi
• Created: 07/Aug/23 13:14
• Updated: 11/Aug/23 09:26
• Resolved: 11/Aug/23 06:54

Description

When having a script containing `SET` statement the SQL Runner example execute it as an SQL query and is not setting the environment config instead.

How to reproduce

This issue can be reproduced as follows:

• Add SET 'parallelism.default' = '2'; on top of the SQL statements in https://github.com/apache/flink-kubernetes-operator/blob/main/examples/flink-sql-runner-example/sql-scripts/statement-set.sql
• Build and execute the example, and verify that the error The main method caused an error: Unsupported SQL query! executeSql() only accepts a single SQL statement of type [...] is happening in the pod log

Issue Links

• links to: GitHub Pull Request #644
• links to: GitHub Pull Request #650