[
https://issues.apache.org/jira/browse/FLINK-25906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17492565#comment-17492565
]
Fabian Paul commented on FLINK-25906:
-------------------------------------
Merged in master: daff5dfa8d9218b33f811611b3209508f2ae3bd7
> 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
> Labels: pull-request-available
>
> 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)
