tzulitai opened a new pull request #58: [FLINK-16254] Support -p / --parallelism command option URL: https://github.com/apache/flink-statefun/pull/58 This PR adds support for specifying parallelism for Stateful Function applications using the `-p / --parallelism` command. The new behaviour as as follows: - If `-p` is defined in the command line, then that value is always used as the parallelism. - Otherwise, the `parallelism.default` value in `flink-conf.yaml` is used, which by default is 1 if not present. --- ### Changelog - 27e7abc Adds parsing logic of the parallelism option from the command line, and adds the property to `StatefulFunctionsClusterConfiguration`. - 07c8dd2 Resolves the parallelism to use in `StatefulFunctionsJobGraphRetriever`, and uses the resolved value to create the JobGraph. - ee61047 Adapt the E2E tests, so that they use the `-p` command to specify parallelism. --- ### Verfying The changes to the E2E tests in ee61047 verifies this change: `mvn clean verify -Prun-e2e-tests`
---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
