Commit c382562f authored by sbalev's avatar sbalev

Fix #62

parent b65ee66f
...@@ -743,7 +743,17 @@ public class ConnectedComponents extends SinkAdapter implements ...@@ -743,7 +743,17 @@ public class ConnectedComponents extends SinkAdapter implements
*/ */
@Override @Override
public void graphCleared(String graphId, long timeId) { public void graphCleared(String graphId, long timeId) {
terminate(); // terminate();
if (started) {
connectedComponents = 0;
ids.clear();
ids.add("");
components.clear();
components.add(new ConnectedComponent(0));
connectedComponentsMap.clear();
connectedComponentsSize.clear();
}
} }
/* /*
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment