[jira] [Created] (FLINK-1986) Group by fails on iterative data streams
Daniel Bali created FLINK-1986:
--
Summary: Group by fails on iterative data streams
Key: FLINK-1986
URL: https://issues.apache.org/jira/browse/FLINK-1986
Project: Flink
Issue Type: Bug
Components: Streaming
Reporter: Daniel Bali
Hello!
When I try to run a `groupBy` on an IterativeDataStream I get a
NullPointerException. Here is the code that reproduces the issue:
{code}
public Test() throws Exception {
StreamExecutionEnvironment env =
StreamExecutionEnvironment.createLocalEnvironment();
DataStreamTuple2Long, Long edges = env
.generateSequence(0, 7)
.map(new MapFunctionLong, Tuple2Long, Long() {
@Override
public Tuple2Long, Long map(Long v) throws Exception {
return new Tuple2(v, (v + 1));
}
});
IterativeDataStreamTuple2Long, Long iteration = edges.iterate();
SplitDataStreamTuple2Long, Long step = iteration.groupBy(1)
.map(new MapFunctionTuple2Long, Long, Tuple2Long, Long() {
@Override
public Tuple2Long, Long map(Tuple2Long, Long tuple) throws
Exception {
return tuple;
}
})
.split(new OutputSelectorTuple2Long, Long() {
@Override
public IterableString select(Tuple2Long, Long tuple) {
ListString output = new ArrayList();
output.add(iterate);
return output;
}
});
iteration.closeWith(step.select(iterate));
env.execute(Sandbox);
}
{code}
Moving the groupBy before the iteration solves the issue. e.g. this works:
{code}
... iteration = edges.groupBy(1).iterate();
iteration.map(...)
{code}
Here is the stack trace:
{code}
Exception in thread main java.lang.NullPointerException
at
org.apache.flink.streaming.api.graph.StreamGraph.addIterationTail(StreamGraph.java:207)
at
org.apache.flink.streaming.api.datastream.IterativeDataStream.closeWith(IterativeDataStream.java:72)
at org.apache.flink.graph.streaming.example.Test.init(Test.java:73)
at org.apache.flink.graph.streaming.example.Test.main(Test.java:79)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:601)
at com.intellij.rt.execution.application.AppMain.main(AppMain.java:134)
{code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
[jira] [Updated] (FLINK-1956) Runtime context not initialized in RichWindowMapFunction
[
https://issues.apache.org/jira/browse/FLINK-1956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Bali updated FLINK-1956:
---
Description:
Trying to access the runtime context in a rich window map function results in
an exception. The following snippet demonstrates the bug:
{{
env.generateSequence(0, 1000)
.window(Count.of(10))
.mapWindow(new RichWindowMapFunctionLong, Tuple2Long, Long() {
@Override
public void mapWindow(IterableLong input, CollectorTuple2Long,
Long out) throws Exception {
long self = getRuntimeContext().getIndexOfThisSubtask();
for (long value : input) {
out.collect(new Tuple2(self, value));
}
}
}).flatten().print();
}}
was:
Trying to access the runtime context in a rich window map function results in
an exception. The following snippet demonstrates the bug:
env.generateSequence(0, 1000)
.window(Count.of(10))
.mapWindow(new RichWindowMapFunctionLong, Tuple2Long, Long() {
@Override
public void mapWindow(IterableLong input, CollectorTuple2Long,
Long out) throws Exception {
long self = getRuntimeContext().getIndexOfThisSubtask();
for (long value : input) {
out.collect(new Tuple2(self, value));
}
}
}).flatten().print();
Runtime context not initialized in RichWindowMapFunction
Key: FLINK-1956
URL: https://issues.apache.org/jira/browse/FLINK-1956
Project: Flink
Issue Type: Bug
Components: Streaming
Reporter: Daniel Bali
Assignee: Marton Balassi
Labels: context, runtime, streaming, window
Trying to access the runtime context in a rich window map function results in
an exception. The following snippet demonstrates the bug:
{{
env.generateSequence(0, 1000)
.window(Count.of(10))
.mapWindow(new RichWindowMapFunctionLong, Tuple2Long, Long() {
@Override
public void mapWindow(IterableLong input, CollectorTuple2Long,
Long out) throws Exception {
long self = getRuntimeContext().getIndexOfThisSubtask();
for (long value : input) {
out.collect(new Tuple2(self, value));
}
}
}).flatten().print();
}}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
[jira] [Updated] (FLINK-1956) Runtime context not initialized in RichWindowMapFunction
[
https://issues.apache.org/jira/browse/FLINK-1956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Bali updated FLINK-1956:
---
Description:
Trying to access the runtime context in a rich window map function results in
an exception. The following snippet demonstrates the bug:
{quote}
env.generateSequence(0, 1000)
.window(Count.of(10))
.mapWindow(new RichWindowMapFunctionLong, Tuple2Long, Long() {
@Override
public void mapWindow(IterableLong input, CollectorTuple2Long,
Long out) throws Exception {
long self = getRuntimeContext().getIndexOfThisSubtask();
for (long value : input) {
out.collect(new Tuple2(self, value));
}
}
}).flatten().print();
{quote}
was:
Trying to access the runtime context in a rich window map function results in
an exception. The following snippet demonstrates the bug:
env.generateSequence(0, 1000)
.window(Count.of(10))
.mapWindow(new RichWindowMapFunctionLong, Tuple2Long, Long() {
@Override
public void mapWindow(IterableLong input, CollectorTuple2Long,
Long out) throws Exception {
long self = getRuntimeContext().getIndexOfThisSubtask();
for (long value : input) {
out.collect(new Tuple2(self, value));
}
}
}).flatten().print();
Runtime context not initialized in RichWindowMapFunction
Key: FLINK-1956
URL: https://issues.apache.org/jira/browse/FLINK-1956
Project: Flink
Issue Type: Bug
Components: Streaming
Reporter: Daniel Bali
Assignee: Marton Balassi
Labels: context, runtime, streaming, window
Trying to access the runtime context in a rich window map function results in
an exception. The following snippet demonstrates the bug:
{quote}
env.generateSequence(0, 1000)
.window(Count.of(10))
.mapWindow(new RichWindowMapFunctionLong, Tuple2Long, Long() {
@Override
public void mapWindow(IterableLong input, CollectorTuple2Long,
Long out) throws Exception {
long self = getRuntimeContext().getIndexOfThisSubtask();
for (long value : input) {
out.collect(new Tuple2(self, value));
}
}
}).flatten().print();
{quote}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
[jira] [Updated] (FLINK-1956) Runtime context not initialized in RichWindowMapFunction
[
https://issues.apache.org/jira/browse/FLINK-1956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Bali updated FLINK-1956:
---
Description:
Trying to access the runtime context in a rich window map function results in
an exception. The following snippet demonstrates the bug:
env.generateSequence(0, 1000)
.window(Count.of(10))
.mapWindow(new RichWindowMapFunctionLong, Tuple2Long, Long() {
@Override
public void mapWindow(IterableLong input, CollectorTuple2Long,
Long out) throws Exception {
long self = getRuntimeContext().getIndexOfThisSubtask();
for (long value : input) {
out.collect(new Tuple2(self, value));
}
}
}).flatten().print();
was:
Trying to access the runtime context in a rich window map function results in
an exception. The following snippet demonstrates the bug:
{{
env.generateSequence(0, 1000)
.window(Count.of(10))
.mapWindow(new RichWindowMapFunctionLong, Tuple2Long, Long() {
@Override
public void mapWindow(IterableLong input, CollectorTuple2Long,
Long out) throws Exception {
long self = getRuntimeContext().getIndexOfThisSubtask();
for (long value : input) {
out.collect(new Tuple2(self, value));
}
}
}).flatten().print();
}}
Runtime context not initialized in RichWindowMapFunction
Key: FLINK-1956
URL: https://issues.apache.org/jira/browse/FLINK-1956
Project: Flink
Issue Type: Bug
Components: Streaming
Reporter: Daniel Bali
Assignee: Marton Balassi
Labels: context, runtime, streaming, window
Trying to access the runtime context in a rich window map function results in
an exception. The following snippet demonstrates the bug:
env.generateSequence(0, 1000)
.window(Count.of(10))
.mapWindow(new RichWindowMapFunctionLong, Tuple2Long, Long() {
@Override
public void mapWindow(IterableLong input, CollectorTuple2Long,
Long out) throws Exception {
long self = getRuntimeContext().getIndexOfThisSubtask();
for (long value : input) {
out.collect(new Tuple2(self, value));
}
}
}).flatten().print();
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
[jira] [Created] (FLINK-1956) Runtime context not initialized in RichWindowMapFunction
Daniel Bali created FLINK-1956:
--
Summary: Runtime context not initialized in RichWindowMapFunction
Key: FLINK-1956
URL: https://issues.apache.org/jira/browse/FLINK-1956
Project: Flink
Issue Type: Bug
Components: Streaming
Reporter: Daniel Bali
Assignee: Marton Balassi
Trying to access the runtime context in a rich window map function results in
an exception. The following snippet demonstrates the bug:
env.generateSequence(0, 1000)
.window(Count.of(10))
.mapWindow(new RichWindowMapFunctionLong, Tuple2Long, Long() {
@Override
public void mapWindow(IterableLong input, CollectorTuple2Long,
Long out) throws Exception {
long self = getRuntimeContext().getIndexOfThisSubtask();
for (long value : input) {
out.collect(new Tuple2(self, value));
}
}
}).flatten().print();
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
[jira] [Updated] (FLINK-1956) Runtime context not initialized in RichWindowMapFunction
[
https://issues.apache.org/jira/browse/FLINK-1956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Bali updated FLINK-1956:
---
Description:
Trying to access the runtime context in a rich window map function results in
an exception. The following snippet demonstrates the bug:
env.generateSequence(0, 1000)
.window(Count.of(10))
.mapWindow(new RichWindowMapFunctionLong, Tuple2Long, Long() {
@Override
public void mapWindow(IterableLong input, CollectorTuple2Long,
Long out) throws Exception {
long self = getRuntimeContext().getIndexOfThisSubtask();
for (long value : input) {
out.collect(new Tuple2(self, value));
}
}
}).flatten().print();
was:
Trying to access the runtime context in a rich window map function results in
an exception. The following snippet demonstrates the bug:
env.generateSequence(0, 1000)
.window(Count.of(10))
.mapWindow(new RichWindowMapFunctionLong, Tuple2Long, Long() {
@Override
public void mapWindow(IterableLong input, CollectorTuple2Long,
Long out) throws Exception {
long self = getRuntimeContext().getIndexOfThisSubtask();
for (long value : input) {
out.collect(new Tuple2(self, value));
}
}
}).flatten().print();
Runtime context not initialized in RichWindowMapFunction
Key: FLINK-1956
URL: https://issues.apache.org/jira/browse/FLINK-1956
Project: Flink
Issue Type: Bug
Components: Streaming
Reporter: Daniel Bali
Assignee: Marton Balassi
Labels: context, runtime, streaming, window
Trying to access the runtime context in a rich window map function results in
an exception. The following snippet demonstrates the bug:
env.generateSequence(0, 1000)
.window(Count.of(10))
.mapWindow(new RichWindowMapFunctionLong, Tuple2Long, Long() {
@Override
public void mapWindow(IterableLong input, CollectorTuple2Long,
Long out) throws Exception {
long self = getRuntimeContext().getIndexOfThisSubtask();
for (long value : input) {
out.collect(new Tuple2(self, value));
}
}
}).flatten().print();
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
[jira] [Commented] (FLINK-1522) Add tests for the library methods and examples
[ https://issues.apache.org/jira/browse/FLINK-1522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14386869#comment-14386869 ] Daniel Bali commented on FLINK-1522: Yeah, I'm not working on this right now. Add tests for the library methods and examples -- Key: FLINK-1522 URL: https://issues.apache.org/jira/browse/FLINK-1522 Project: Flink Issue Type: New Feature Components: Gelly Reporter: Vasia Kalavri Assignee: Daniel Bali Labels: easyfix, test The current tests in gelly test one method at a time. We should have some tests for complete applications. As a start, we could add one test case per example and this way also make sure that our graph library methods actually give correct results. I'm assigning this to [~andralungu] because she has already implemented the test for SSSP, but I will help as well. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-1628) Strange behavior of where function during a join
[ https://issues.apache.org/jira/browse/FLINK-1628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14343619#comment-14343619 ] Daniel Bali commented on FLINK-1628: It also occurs when using tuple positions for both inputs. Also, when I change the order of the joined DataSets, it's the `equalTo` that fails when using tuple positions. Strange behavior of where function during a join -- Key: FLINK-1628 URL: https://issues.apache.org/jira/browse/FLINK-1628 Project: Flink Issue Type: Bug Affects Versions: 0.9 Reporter: Daniel Bali Labels: batch Hello! If I use the `where` function with a field list during a join, it exhibits strange behavior. Here is the sample code that triggers the error: https://gist.github.com/balidani/d9789b713e559d867d5c This example joins a DataSet with itself, then counts the number of rows. If I use `.where(0, 1)` the result is (22), which is not correct. If I use `EdgeKeySelector`, I get the correct result (101). When I pass a field list to the `equalTo` function (but not `where`), everything works again. If I don't include the `groupBy` and `reduceGroup` parts, everything works. Also, when working with large DataSets, passing a field list to `where` makes it incredibly slow, even though I don't see any exceptions in the log (in DEBUG mode). Does anybody know what might cause this problem? Thanks! -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (FLINK-1594) DataStreams don't support self-join
Daniel Bali created FLINK-1594:
--
Summary: DataStreams don't support self-join
Key: FLINK-1594
URL: https://issues.apache.org/jira/browse/FLINK-1594
Project: Flink
Issue Type: Bug
Components: Streaming
Affects Versions: 0.9
Environment: flink-0.9.0-SNAPSHOT
Reporter: Daniel Bali
Trying to join a DataSets with itself will result in exceptions. I get the
following stack trace:
{noformat}
java.lang.Exception: Error setting up runtime environment: Union buffer
reader must be initialized with at least two individual buffer readers
at
org.apache.flink.runtime.execution.RuntimeEnvironment.init(RuntimeEnvironment.java:173)
at
org.apache.flink.runtime.taskmanager.TaskManager.org$apache$flink$runtime$taskmanager$TaskManager$$submitTask(TaskManager.scala:419)
at
org.apache.flink.runtime.taskmanager.TaskManager$$anonfun$receiveWithLogMessages$1.applyOrElse(TaskManager.scala:261)
at
scala.runtime.AbstractPartialFunction$mcVL$sp.apply$mcVL$sp(AbstractPartialFunction.scala:33)
at
scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:33)
at
scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:25)
at
org.apache.flink.runtime.ActorLogMessages$$anon$1.apply(ActorLogMessages.scala:44)
at
org.apache.flink.runtime.ActorLogMessages$$anon$1.apply(ActorLogMessages.scala:30)
at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:118)
at
org.apache.flink.runtime.ActorLogMessages$$anon$1.applyOrElse(ActorLogMessages.scala:30)
at akka.actor.Actor$class.aroundReceive(Actor.scala:465)
at
org.apache.flink.runtime.taskmanager.TaskManager.aroundReceive(TaskManager.scala:89)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516)
at akka.actor.ActorCell.invoke(ActorCell.scala:487)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254)
at akka.dispatch.Mailbox.run(Mailbox.scala:221)
at akka.dispatch.Mailbox.exec(Mailbox.scala:231)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at
scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Caused by: java.lang.IllegalArgumentException: Union buffer reader must be
initialized with at least two individual buffer readers
at
org.apache.flink.shaded.com.google.common.base.Preconditions.checkArgument(Preconditions.java:125)
at
org.apache.flink.runtime.io.network.api.reader.UnionBufferReader.init(UnionBufferReader.java:69)
at
org.apache.flink.streaming.api.streamvertex.CoStreamVertex.setConfigInputs(CoStreamVertex.java:101)
at
org.apache.flink.streaming.api.streamvertex.CoStreamVertex.setInputsOutputs(CoStreamVertex.java:63)
at
org.apache.flink.streaming.api.streamvertex.StreamVertex.registerInputOutput(StreamVertex.java:65)
at
org.apache.flink.runtime.execution.RuntimeEnvironment.init(RuntimeEnvironment.java:170)
... 20 more
{noformat}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
[jira] [Updated] (FLINK-1594) DataStreams don't support self-join
[
https://issues.apache.org/jira/browse/FLINK-1594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Bali updated FLINK-1594:
---
Description:
Trying to join a DataSet with itself will result in exceptions. I get the
following stack trace:
{noformat}
java.lang.Exception: Error setting up runtime environment: Union buffer
reader must be initialized with at least two individual buffer readers
at
org.apache.flink.runtime.execution.RuntimeEnvironment.init(RuntimeEnvironment.java:173)
at
org.apache.flink.runtime.taskmanager.TaskManager.org$apache$flink$runtime$taskmanager$TaskManager$$submitTask(TaskManager.scala:419)
at
org.apache.flink.runtime.taskmanager.TaskManager$$anonfun$receiveWithLogMessages$1.applyOrElse(TaskManager.scala:261)
at
scala.runtime.AbstractPartialFunction$mcVL$sp.apply$mcVL$sp(AbstractPartialFunction.scala:33)
at
scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:33)
at
scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:25)
at
org.apache.flink.runtime.ActorLogMessages$$anon$1.apply(ActorLogMessages.scala:44)
at
org.apache.flink.runtime.ActorLogMessages$$anon$1.apply(ActorLogMessages.scala:30)
at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:118)
at
org.apache.flink.runtime.ActorLogMessages$$anon$1.applyOrElse(ActorLogMessages.scala:30)
at akka.actor.Actor$class.aroundReceive(Actor.scala:465)
at
org.apache.flink.runtime.taskmanager.TaskManager.aroundReceive(TaskManager.scala:89)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516)
at akka.actor.ActorCell.invoke(ActorCell.scala:487)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254)
at akka.dispatch.Mailbox.run(Mailbox.scala:221)
at akka.dispatch.Mailbox.exec(Mailbox.scala:231)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at
scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Caused by: java.lang.IllegalArgumentException: Union buffer reader must be
initialized with at least two individual buffer readers
at
org.apache.flink.shaded.com.google.common.base.Preconditions.checkArgument(Preconditions.java:125)
at
org.apache.flink.runtime.io.network.api.reader.UnionBufferReader.init(UnionBufferReader.java:69)
at
org.apache.flink.streaming.api.streamvertex.CoStreamVertex.setConfigInputs(CoStreamVertex.java:101)
at
org.apache.flink.streaming.api.streamvertex.CoStreamVertex.setInputsOutputs(CoStreamVertex.java:63)
at
org.apache.flink.streaming.api.streamvertex.StreamVertex.registerInputOutput(StreamVertex.java:65)
at
org.apache.flink.runtime.execution.RuntimeEnvironment.init(RuntimeEnvironment.java:170)
... 20 more
{noformat}
was:
Trying to join a DataSets with itself will result in exceptions. I get the
following stack trace:
{noformat}
java.lang.Exception: Error setting up runtime environment: Union buffer
reader must be initialized with at least two individual buffer readers
at
org.apache.flink.runtime.execution.RuntimeEnvironment.init(RuntimeEnvironment.java:173)
at
org.apache.flink.runtime.taskmanager.TaskManager.org$apache$flink$runtime$taskmanager$TaskManager$$submitTask(TaskManager.scala:419)
at
org.apache.flink.runtime.taskmanager.TaskManager$$anonfun$receiveWithLogMessages$1.applyOrElse(TaskManager.scala:261)
at
scala.runtime.AbstractPartialFunction$mcVL$sp.apply$mcVL$sp(AbstractPartialFunction.scala:33)
at
scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:33)
at
scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:25)
at
org.apache.flink.runtime.ActorLogMessages$$anon$1.apply(ActorLogMessages.scala:44)
at
org.apache.flink.runtime.ActorLogMessages$$anon$1.apply(ActorLogMessages.scala:30)
at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:118)
at
org.apache.flink.runtime.ActorLogMessages$$anon$1.applyOrElse(ActorLogMessages.scala:30)
at akka.actor.Actor$class.aroundReceive(Actor.scala:465)
at
org.apache.flink.runtime.taskmanager.TaskManager.aroundReceive(TaskManager.scala:89)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516)
at akka.actor.ActorCell.invoke(ActorCell.scala:487)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254)
at akka.dispatch.Mailbox.run(Mailbox.scala:221)
at akka.dispatch.Mailbox.exec(Mailbox.scala:231)
at
[jira] [Commented] (FLINK-1522) Add tests for the library methods and examples
[ https://issues.apache.org/jira/browse/FLINK-1522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14324237#comment-14324237 ] Daniel Bali commented on FLINK-1522: Hi Andra! Vasia said you have other issues to work on, so I'd happily continue the work on this one. Add tests for the library methods and examples -- Key: FLINK-1522 URL: https://issues.apache.org/jira/browse/FLINK-1522 Project: Flink Issue Type: New Feature Components: Gelly Reporter: Vasia Kalavri Assignee: Andra Lungu Labels: easyfix, test The current tests in gelly test one method at a time. We should have some tests for complete applications. As a start, we could add one test case per example and this way also make sure that our graph library methods actually give correct results. I'm assigning this to [~andralungu] because she has already implemented the test for SSSP, but I will help as well. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Issue Comment Deleted] (FLINK-1522) Add tests for the library methods and examples
[ https://issues.apache.org/jira/browse/FLINK-1522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Bali updated FLINK-1522: --- Comment: was deleted (was: Hi Andra! Vasia said you have other issues to work on, so I'd happily continue the work on this one.) Add tests for the library methods and examples -- Key: FLINK-1522 URL: https://issues.apache.org/jira/browse/FLINK-1522 Project: Flink Issue Type: New Feature Components: Gelly Reporter: Vasia Kalavri Assignee: Andra Lungu Labels: easyfix, test The current tests in gelly test one method at a time. We should have some tests for complete applications. As a start, we could add one test case per example and this way also make sure that our graph library methods actually give correct results. I'm assigning this to [~andralungu] because she has already implemented the test for SSSP, but I will help as well. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-1522) Add tests for the library methods and examples
[ https://issues.apache.org/jira/browse/FLINK-1522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14324238#comment-14324238 ] Daniel Bali commented on FLINK-1522: Hi Andra! Vasia said you have other issues to work on, so I'd happily continue the work on this one. Add tests for the library methods and examples -- Key: FLINK-1522 URL: https://issues.apache.org/jira/browse/FLINK-1522 Project: Flink Issue Type: New Feature Components: Gelly Reporter: Vasia Kalavri Assignee: Andra Lungu Labels: easyfix, test The current tests in gelly test one method at a time. We should have some tests for complete applications. As a start, we could add one test case per example and this way also make sure that our graph library methods actually give correct results. I'm assigning this to [~andralungu] because she has already implemented the test for SSSP, but I will help as well. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Assigned] (FLINK-1522) Add tests for the library methods and examples
[ https://issues.apache.org/jira/browse/FLINK-1522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Bali reassigned FLINK-1522: -- Assignee: Daniel Bali (was: Andra Lungu) Add tests for the library methods and examples -- Key: FLINK-1522 URL: https://issues.apache.org/jira/browse/FLINK-1522 Project: Flink Issue Type: New Feature Components: Gelly Reporter: Vasia Kalavri Assignee: Daniel Bali Labels: easyfix, test The current tests in gelly test one method at a time. We should have some tests for complete applications. As a start, we could add one test case per example and this way also make sure that our graph library methods actually give correct results. I'm assigning this to [~andralungu] because she has already implemented the test for SSSP, but I will help as well. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-1522) Add tests for the library methods and examples
[ https://issues.apache.org/jira/browse/FLINK-1522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14324239#comment-14324239 ] Daniel Bali commented on FLINK-1522: Hi Andra! Vasia said you have other issues to work on, so I'd happily continue the work on this one. Add tests for the library methods and examples -- Key: FLINK-1522 URL: https://issues.apache.org/jira/browse/FLINK-1522 Project: Flink Issue Type: New Feature Components: Gelly Reporter: Vasia Kalavri Assignee: Andra Lungu Labels: easyfix, test The current tests in gelly test one method at a time. We should have some tests for complete applications. As a start, we could add one test case per example and this way also make sure that our graph library methods actually give correct results. I'm assigning this to [~andralungu] because she has already implemented the test for SSSP, but I will help as well. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
