Hi Vasia
In that case, we might as well change it.
getExecutionEnvironment actually goes through the contextFactory, and it
then depends on this contextFactory how it generates new environments. For
example, all the Test Environments currently are shared, i.e., the factory
returns the same object
Hi Sachin,
I was actually under the impression that
ExecutionEnvironment.getExecutionEnvironment() returns the current
environment, if one has already been created.
I don't think that creating a second one is intentional there and if that's
the case, we should change it.
Cheers,
Vasia.
On 21 Aug
Hi
I was going through the two files VertexCentricIteration and
GatherSumApplyIteration, and noticed that when the graph is constructed
from the edge and vertex data set, a new execution environment is passed.
As in,
Graph graph =
Graph.fromDataSet(vertexDataSet, edgeDataSet,
ExecutionEnviro