This is an automated email from the ASF dual-hosted git repository.
enjoyyin pushed a commit to branch dev-1.0.3
in repository https://gitbox.apache.org/repos/asf/incubator-linkis.git
The following commit(s) were added to refs/heads/dev-1.0.3 by this push:
new c2b0622 streamExecEnv is not initialized, resulting in null pointer
exception
new 91b224d Merge pull request #1270 from Zosimer/flink_streamenvisnull
c2b0622 is described below
commit c2b0622ad6e9b54ff2511da7dfae3846403ad2d6
Author: e <[email protected]>
AuthorDate: Tue Jan 4 21:13:18 2022 +0800
streamExecEnv is not initialized, resulting in null pointer exception
in class ClusterDescriptorAdapter ，this line on
configuration = (Configuration)
method.invoke(executionContext.getStreamExecutionEnvironment()) ，this code
’executionContext.getStreamExecutionEnvironment()‘ return null，beacause
streamExecEnv is not initialized, resulting in null pointer exception
---
.../engineconnplugin/flink/client/context/ExecutionContext.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
diff --git
a/linkis-engineconn-plugins/engineconn-plugins/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/context/ExecutionContext.java
b/linkis-engineconn-plugins/engineconn-plugins/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/context/ExecutionContext.java
index 1dbf6e7..f22943b 100644
---
a/linkis-engineconn-plugins/engineconn-plugins/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/context/ExecutionContext.java
+++
b/linkis-engineconn-plugins/engineconn-plugins/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/client/context/ExecutionContext.java
@@ -128,11 +128,12 @@ public class ExecutionContext {
LOG.info("flinkConfig config: {}", flinkConfig);
clusterClientFactory = new LinkisYarnClusterClientFactory();
}
-
- public StreamExecutionEnvironment getStreamExecutionEnvironment() {
+ public StreamExecutionEnvironment getStreamExecutionEnvironment()
throws SqlExecutionException{
+ if(streamExecEnv == null) {
+ getTableEnvironment();
+ }
return streamExecEnv;
}
-
public void setString(String key, String value) {
this.flinkConfig.setString(key, value);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
