ionEnvironment();`
> >
> > or
> >
> > `StreamExecutionEnvironment env =
> > StreamExecutionEnvironment.getExecutionEnvironment();`
> > `env.setParallelism(2);`
> >
> > That should be equivalent from the perspective of codes.
> >
> >
> > On Wed, Jul 31, 2
to use StreamExecutionEnvironment.createLocalEnvironment(2,
>> customConfig); to increase resources.
>> this issue might also address the problem, it will be part of 1.9 release:
>> https://issues.apache.org/jira/browse/FLINK-12852
>>
>> Best,
>> Andrey
>>
>> On
Hi,
I am using Flink version: 1.7.1
I have a flink job that gets the execution environment as below and
executes the job.
StreamExecutionEnvironment env =
StreamExecutionEnvironment.getExecutionEnvironment();
When I run the code in cluster, it runs fine. But on local machine while
running the j
