Re: Graph.fromDataSet function calls: flink-gelly

2015-08-22 Thread Sachin Goel
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

Re: Graph.fromDataSet function calls: flink-gelly

2015-08-22 Thread Vasiliki Kalavri
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

Graph.fromDataSet function calls: flink-gelly

2015-08-21 Thread Sachin Goel
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