You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Jing Ge (Jira)" <ji...@apache.org> on 2022/02/01 12:51:00 UTC

[jira] [Updated] (FLINK-25906) Remove the ExecutionEnvironment dependency in LocalStreamEnvironment

     [ 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)