mehdid93 opened a new pull request, #644: URL: https://github.com/apache/flink-kubernetes-operator/pull/644
## What is the purpose of the change This pull request adds a new feature to take in account `SET` statements in the SQL Runner example. ## Brief change log - Adding support of SET statements to set parameters to the context for eg. parallelism ## Verifying this change This change can be verified 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, with the changes in the PR, the error `The main method caused an error: Unsupported SQL query! executeSql() only accepts a single SQL statement of type [...]` does not happen anymore and the Flink job is executed with parallelism at 2. ## Does this pull request potentially affect one of the following parts: - Dependencies (does it add or upgrade a dependency): (yes / no) **no** - The public API, i.e., is any changes to the `CustomResourceDescriptors`: (yes / no) **no** - Core observer or reconciler logic that is regularly executed: (yes / no) **no** ## Documentation - Does this pull request introduce a new feature? (yes / no) **yes** - If yes, how is the feature documented? (not applicable / docs / JavaDocs / not documented) **not applicable but it may be worth mentioning it in the release notes of the future operator version** -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
