Skip to content

State

Reset State of All Flows

reset(
  resolvedGraph: DataflowGraph,
  env: PipelineUpdateContext): Seq[Input]
reset(
  flow: ResolvedFlow,
  env: PipelineUpdateContext,
  graph: DataflowGraph): Unit // (1)!
  1. A private method

reset finds ResolvedFlows to reset in the given DataflowGraph (and the PipelineUpdateContext).

Info

reset handles ResolvedFlows only.

reset prints out the following INFO message to the logs:

Clearing out state for flow [displayName]

reset creates a FlowSystemMetadata.

For no checkpoint directory available for the ResolvedFlow, reset prints out the following INFO message to the logs and exits.

Skipping resetting flow [identifier]
since its destination not been previously materialized
and we can't find the checkpoint location.

Otherwise, when there is a checkpoint directory available, reset creates a new checkpoint directory (by incrementing the checkpoint number) and prints out the following INFO message to the logs:

Created new checkpoint for stream [displayName] at [checkpoint_path].

reset is used when: