You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tinkerpop.apache.org by sp...@apache.org on 2020/01/09 11:47:59 UTC
[tinkerpop] 04/13: fixed a bug in Pipes.subscribe().
This is an automated email from the ASF dual-hosted git repository.
spmallette pushed a commit to branch 4.0-dev
in repository https://gitbox.apache.org/repos/asf/tinkerpop.git
commit 576f880e5918b0912fa8b9bdf531d24e116be3ba
Author: Marko A. Rodriguez <ok...@gmail.com>
AuthorDate: Tue Apr 23 06:54:50 2019 -0600
fixed a bug in Pipes.subscribe().
---
.../src/main/java/org/apache/tinkerpop/machine/processor/beam/Beam.java | 2 +-
.../main/java/org/apache/tinkerpop/machine/processor/pipes/Pipes.java | 1 -
2 files changed, 1 insertion(+), 2 deletions(-)
diff --git a/java/machine/processor/beam/src/main/java/org/apache/tinkerpop/machine/processor/beam/Beam.java b/java/machine/processor/beam/src/main/java/org/apache/tinkerpop/machine/processor/beam/Beam.java
index 20007c4..0bb39fe 100644
--- a/java/machine/processor/beam/src/main/java/org/apache/tinkerpop/machine/processor/beam/Beam.java
+++ b/java/machine/processor/beam/src/main/java/org/apache/tinkerpop/machine/processor/beam/Beam.java
@@ -89,7 +89,7 @@ public class Beam<C, S, E> implements Processor<C, S, E> {
@Override
public void stop() {
try {
- if (null != this.pipelineResult)
+ if (this.isRunning())
this.pipelineResult.cancel();
} catch (final IOException e) {
throw new RuntimeException(e.getMessage(), e);
diff --git a/java/machine/processor/pipes/src/main/java/org/apache/tinkerpop/machine/processor/pipes/Pipes.java b/java/machine/processor/pipes/src/main/java/org/apache/tinkerpop/machine/processor/pipes/Pipes.java
index 317659f..cc5a4cf 100644
--- a/java/machine/processor/pipes/src/main/java/org/apache/tinkerpop/machine/processor/pipes/Pipes.java
+++ b/java/machine/processor/pipes/src/main/java/org/apache/tinkerpop/machine/processor/pipes/Pipes.java
@@ -115,7 +115,6 @@ public final class Pipes<C, S, E> implements Processor<C, S, E> {
if (this.isRunning())
throw Processor.Exceptions.processorIsCurrentlyRunning(this);
- this.alive.set(Boolean.TRUE);
new Thread(() -> {
final Iterator<Traverser<C, E>> iterator = this.iterator(starts);
while (iterator.hasNext()) {