Shunyang Li created FLINK-29578:
---
Summary: Multiple executions of `runVertexCentricIteration` cause
memory errors (flink gelly)
Key: FLINK-29578
URL: https://issues.apache.org/jira/browse/FLINK-29578
I'm pulling in Aljoscha, Klou and Tison who worked on this
> > feature. I believe they can propose a fix for the problem.
> >
> > [1] https://issues.apache.org/jira/browse/FLINK-15116
> >
> > On Sun, Aug 2, 2020 at 11:28 AM Xia Rui wrote:
> >
> >
Hello, everyone.
I am using Flink-Gelly. I got an error when running the example code of
Gelly-example. I have reported the problem in Stackoverflow, and this is
the
link
(
https://stackoverflow.com/questions/63211746/error-with-flink-gelly-lastjob
executionresult-is-null-for-executionenvironment
&
correctly. I'm pulling in Aljoscha, Klou and Tison who worked on this
feature. I believe they can propose a fix for the problem.
[1] https://issues.apache.org/jira/browse/FLINK-15116
On Sun, Aug 2, 2020 at 11:28 AM Xia Rui wrote:
> Hello, everyone.
>
> I am using Flink-Gelly. I got
Hello, everyone.
I am using Flink-Gelly. I got an error when running the example code of
Gelly-example. I have reported the problem in Stackoverflow, and this is the
link
(https://stackoverflow.com/questions/63211746/error-with-flink-gelly-lastjob
executionresult-is-null-for-executionenvironment
vinoyang created FLINK-10048:
Summary: Migrate module flink-gelly-examples to flink-examples and
rename it
Key: FLINK-10048
URL: https://issues.apache.org/jira/browse/FLINK-10048
Project: Flink
flora karniav created FLINK-8403:
Summary: Flink Gelly examples hanging without returning result
Key: FLINK-8403
URL: https://issues.apache.org/jira/browse/FLINK-8403
Project: Flink
Issue
FlorianFan created FLINK-6393:
-
Summary: Add Evenly Graph Generator to Flink Gelly
Key: FLINK-6393
URL: https://issues.apache.org/jira/browse/FLINK-6393
Project: Flink
Issue Type: New Feature
vishnu viswanath created FLINK-6372:
---
Summary: change-scala-version.sh does not change version for
flink-gelly-examples
Key: FLINK-6372
URL: https://issues.apache.org/jira/browse/FLINK-6372
Project
Jacek Laskowski created FLINK-6360:
--
Summary: Failed to create assembly for Scala 2.11 due to
tools/change-scala-version.sh not changing flink-gelly-examples_2.10
Key: FLINK-6360
URL: https://issues.apache.org
ot;
Betreff: Re: Re: Re: Flink Gelly
Hi,
the exception
> java.lang.RuntimeException: Memory ran out. Compaction failed.
says that the hash table ran out of memory. Gelly is implemented on top of
Flink's DataSet API.
So this would rather be a problem with DataSet than Gelly.
I think Vas
RAM by
> the JVM and it does not go beyond 3gb at all.
>
> I still don't think that the memory is the propblem. For me it looks like
> an internal
> problem with Gelly.
>
> Best,
> Dennis
>
>
> Gesendet: Freitag, 07. Oktober 2016 um 12:29 Uhr
> Von: "Vas
like an
internal
problem with Gelly.
Best,
Dennis
Gesendet: Freitag, 07. Oktober 2016 um 12:29 Uhr
Von: "Vasiliki Kalavri"
An: dev@flink.apache.org
Betreff: Re: Re: Flink Gelly
Hi Dennis,
On 7 October 2016 at 11:29, wrote:
> Hi Vasia,
>
> thanks for your reply.
>
>
}
> }
> }
> multiPaths.put(oriDest, tempList);
> }
>
>
> // The combined paths are also saved into a HashMap which is
> additionally set as a Vertex Value
> // Later the paths
exValue(testTuple3);
}
}
Let me know if you need any further information.
Thanks in advance.
All the best,
Dennis
Gesendet: Donnerstag, 06. Oktober 2016 um 15:22 Uhr
Von: "Vasiliki Kalavri"
An: dev@flink.apache.org
Betreff: Re: Flink Gelly
Hi Dennis,
can you give
Hi Dennis,
can you give us some details about your setup? e.g. where you are running
your job, your input size, the configured memory, etc. It would also be
helpful if you could share your code. Getting an out of memory error with
just 100 nodes seems weird.
Best,
-Vasia.
On 6 October 2016 at 13
Dear ladies and gentlemen,
I got a problem using Gelly in Flink. Currently I am loading a Virtuoso Graph
into
Flink's Gelly and I want to analyze it for the different paths one can take to
link
the different nodes. Therefore I am using the ScatterGatherIteration.
However, my code just works
Chesnay Schepler created FLINK-3819:
---
Summary: Replace Guava Preconditions usage in flink-gelly-scala
Key: FLINK-3819
URL: https://issues.apache.org/jira/browse/FLINK-3819
Project: Flink
Chesnay Schepler created FLINK-3818:
---
Summary: Remove Guava dependency from flink-gelly-examples
Key: FLINK-3818
URL: https://issues.apache.org/jira/browse/FLINK-3818
Project: Flink
Issue
Chesnay Schepler created FLINK-3815:
---
Summary: Replace Guava Preconditions usage in flink-gelly
Key: FLINK-3815
URL: https://issues.apache.org/jira/browse/FLINK-3815
Project: Flink
Issue
Till Rohrmann created FLINK-3532:
Summary: Flink-gelly-examples jar contains an underscore instead
of an hyphen
Key: FLINK-3532
URL: https://issues.apache.org/jira/browse/FLINK-3532
Project: Flink
Vasia Kalavri created FLINK-2941:
Summary: Implement a neo4j - Flink/Gelly connector
Key: FLINK-2941
URL: https://issues.apache.org/jira/browse/FLINK-2941
Project: Flink
Issue Type: New
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
25 matches
Mail list logo
