Skip to content

Signal on collect on delivery can make the memory consumption explode. #141

@pstutz

Description

@pstutz

It's a cool policy for TripleRush, but it has to be customisable, because for PageRank it leads to a nuclear explosion of signals.

Relevant code:
Line 146 in WorkerImplementation:
if (vertex.scoreSignal > signalThreshold) {
//vertexStore.toSignal.put(vertex)
// TODO: Unify scheduling related code. The policy here should be pluggable and the same as
// the one in AkkaWorker.executeOperations.
executeSignalOperationOfVertex(vertex)
}

Metadata

Metadata

Assignees

No one assigned

    Labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions