This is an automated email from the ASF dual-hosted git repository.
peacewong pushed a commit to branch dev-1.3.2
in repository https://gitbox.apache.org/repos/asf/linkis.git
The following commit(s) were added to refs/heads/dev-1.3.2 by this push:
new 6fc3ed57d fix: flinkconn start no value present bug (#4121)
6fc3ed57d is described below
commit 6fc3ed57d62a2377b91901a17e19e2a9f734053d
Author: Jack Xu <[email protected]>
AuthorDate: Tue Jan 17 14:42:19 2023 +0800
fix: flinkconn start no value present bug (#4121)
---
.../engineconnplugin/flink/client/context/ExecutionContext.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/linkis-engineconn-plugins/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/context/ExecutionContext.java
b/linkis-engineconn-plugins/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/context/ExecutionContext.java
index 87262be5d..47cb6c539 100644
---
a/linkis-engineconn-plugins/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/context/ExecutionContext.java
+++
b/linkis-engineconn-plugins/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/context/ExecutionContext.java
@@ -490,7 +490,7 @@ public class ExecutionContext {
private ExecutionEnvironment createExecutionEnvironment() {
final ExecutionEnvironment execEnv =
ExecutionEnvironment.getExecutionEnvironment();
execEnv.setRestartStrategy(environment.getExecution().getRestartStrategy());
- execEnv.setParallelism(environment.getExecution().getParallelism().get());
+
execEnv.setParallelism(environment.getExecution().getParallelism().orElse(1));
return execEnv;
}
@@ -500,7 +500,7 @@ public class ExecutionContext {
final StreamExecutionEnvironment env =
StreamExecutionEnvironment.getExecutionEnvironment(flinkConfig);
env.setRestartStrategy(environment.getExecution().getRestartStrategy());
- env.setParallelism(environment.getExecution().getParallelism().get());
+ env.setParallelism(environment.getExecution().getParallelism().orElse(1));
env.setMaxParallelism(environment.getExecution().getMaxParallelism());
env.setStreamTimeCharacteristic(environment.getExecution().getTimeCharacteristic());
if (env.getStreamTimeCharacteristic() == TimeCharacteristic.EventTime) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
