[
https://issues.apache.org/jira/browse/FLINK-25906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge updated FLINK-25906:
----------------------------
Description:
Rebuild the check that only depends on StreamExecutionEnvironment.
{code:java}
if (!ExecutionEnvironment.areExplicitEnvironmentsAllowed()) {
throw new InvalidProgramException(
"The LocalStreamEnvironment cannot be used when submitting a program
through a client, "
+ "or running in a TestEnvironment context.");
} {code}
[https://github.com/apache/flink/blob/8ddfd590ebba7fc727e79db41b82d3d40a02b56a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/LocalStreamEnvironment.java#L56]
was:
Rebuild the check that only depends on StreamExecutionEnvironment.
https://github.com/apache/flink/blob/8ddfd590ebba7fc727e79db41b82d3d40a02b56a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/LocalStreamEnvironment.java#L56
> Remove the ExecutionEnvironment dependency in LocalStreamEnvironment
> --------------------------------------------------------------------
>
> Key: FLINK-25906
> URL: https://issues.apache.org/jira/browse/FLINK-25906
> Project: Flink
> Issue Type: Improvement
> Reporter: Jing Ge
> Assignee: Jing Ge
> Priority: Minor
>
> Rebuild the check that only depends on StreamExecutionEnvironment.
> {code:java}
> if (!ExecutionEnvironment.areExplicitEnvironmentsAllowed()) {
> throw new InvalidProgramException(
> "The LocalStreamEnvironment cannot be used when submitting a program
> through a client, "
> + "or running in a TestEnvironment context.");
> } {code}
>
> [https://github.com/apache/flink/blob/8ddfd590ebba7fc727e79db41b82d3d40a02b56a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/LocalStreamEnvironment.java#L56]
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
