DebugFlow 2025.10.2.19¶
Bundle¶
org.apache.nifi | nifi-standard-nar
Beschreibung¶
The DebugFlow processor aids testing and debugging the FlowFile framework by allowing various responses to be explicitly triggered in response to the receipt of a FlowFile or a timer event without a FlowFile if using timer or cron based scheduling. It can force responses needed to exercise or test various failure modes that can occur when a processor runs.
Eingabeanforderung¶
Unterstützt sensible dynamische Eigenschaften¶
false
Eigenschaften¶
Eigenschaft |
Beschreibung |
|---|---|
@OnScheduled Pause Time |
Legt fest, wie lange der Prozessor bei der Methode @OnScheduled im Ruhezustand bleiben soll, sodass der Startvorgang des Prozessors absichtlich verzögert werden kann. |
@OnStopped Pause Time |
Legt fest, wie lange der Prozessor bei der Methode @OnStopped im Ruhezustand bleiben soll, sodass der Startvorgang des Prozessors absichtlich verzögert werden kann. |
@OnUnscheduled Pause Time |
Legt fest, wie lange der Prozessor bei der Methode @OnUnscheduled im Ruhezustand bleiben soll, sodass er absichtlich eine lange Antwortzeit hat, wenn der Benutzer auf „Stopp“ klickt. |
Content Size |
Die Anzahl der Bytes, die jedes Mal geschrieben werden, wenn in das Flowfile geschrieben wird. |
CustomValidate Pause Time |
Gibt an, wie lange der Prozessor in der Methode customValidate() im Ruhezustand bleiben soll. |
Fail When @OnScheduled called |
Gibt an, ob der Prozessor eine Ausnahme auslösen soll, wenn die mit @OnScheduled annotierten Methoden aufgerufen werden. |
Fail When @OnStopped called |
Gibt an, ob der Prozessor eine Ausnahme auslösen soll, wenn die mit @OnStopped annotierten Methoden aufgerufen werden. |
Fail When @OnUnscheduled called |
Gibt an, ob der Prozessor eine Ausnahme auslösen soll, wenn die mit @OnUnscheduled annotierten Methoden aufgerufen werden. |
FlowFile Exception Class |
Exception class to be thrown (must extend java.lang. RuntimeException). |
FlowFile Exception Iterations |
Anzahl der FlowFiles, die eine Ausnahme auslösen. |
FlowFile Failure Iterations |
Anzahl der FlowFiles zur Weiterleitung an die Beziehung „failure“ |
FlowFile Rollback Iterations |
Anzahl der FlowFiles, die zurückgesetzt (rollback) werden sollen (ohne Strafe). |
FlowFile Rollback Penalty Iterations |
Anzahl der FlowFiles, die mit einer Strafe zurückgesetzt (rollback) werden sollen. |
FlowFile Rollback Yield Iterations |
Anzahl der FlowFiles, die zurückgesetzt und freigegeben werden sollen. |
FlowFile Success Iterations |
Anzahl der FlowFiles, die an die Beziehung „success“ weitergeleitet werden sollen. |
Ignore Interrupts When Paused |
Wenn der/die Thread(s) des Prozessors schlafen (aufgrund einer der oben genannten „Pause Time“-Eigenschaften) und der Thread unterbrochen wird, gibt diese Einstellung an, ob der Prozessor die Unterbrechung ignorieren und im Ruhezustand verbleiben soll oder ob er die Unterbrechung zulassen soll. |
No FlowFile Exception Class |
Exception class to be thrown if no FlowFile (must extend java.lang. RuntimeException). |
No FlowFile Exception Iterations |
Anzahl der Auslösungen einer NPE-Ausnahme, wenn kein FlowFile vorhanden ist. |
No FlowFile Skip Iterations |
Anzahl der Ausführungen, bei denen „onTrigger“ übersprungen wird, wenn kein FlowFile vorhanden ist. |
No FlowFile Yield Iterations |
Anzahl der Ausführungen, wenn kein FlowFile vorhanden ist. |
OnTrigger Pause Time |
Legt fest, wie lange der Prozessor in der onTrigger()-Methode schlafen soll, im Ruhezustand bleiben soll, sodass die Ausführung seiner Aufgabe absichtlich verzögert wird. |
Write Iterations |
Anzahl der Schreibvorgänge in das FlowFile |
Beziehungen¶
Name |
Beschreibung |
|---|---|
failure |
FlowFiles, die nicht verarbeitet werden konnten. |
success |
FlowFiles, die erfolgreich verarbeitet wurden. |