DebugFlow 2025.10.2.19¶
Pacote¶
org.apache.nifi | nifi-standard-nar
Descrição¶
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.
Requisito de entrada¶
Oferece suporte a propriedades dinâmicas confidenciais¶
falso
Propriedades¶
Propriedade |
Descrição |
|---|---|
Tempo de pausa @OnScheduled |
Especifica por quanto tempo o processador deve ficar em espera no método @OnScheduled, de modo que o processador possa ser forçado a levar um longo tempo para iniciar |
Tempo de pausa @OnStopped |
Especifica por quanto tempo o processador deve ficar em espera no método @OnStopped, de modo que o processador possa ser forçado a levar muito tempo para ser desligado |
Tempo de pausa @OnUnscheduled |
Especifica por quanto tempo o processador deve ficar em espera no método @OnUnscheduled, de modo que o processador possa ser forçado a demorar muito tempo para responder quando o usuário clicar em parar |
Tamanho do conteúdo |
O número de bytes a serem gravados sempre que o FlowFile for gravado |
Tempo de pausa CustomValidate |
Especifica por quanto tempo o processador deve ficar em espera no método customValidate() |
Falhar quando @OnScheduled for chamado |
Especifica se o processador deve ou não gerar uma exceção quando os métodos anotados com @OnScheduled forem chamados |
Falhar quando @OnStopped for chamado |
Especifica se o processador deve ou não gerar uma exceção quando os métodos anotados com @OnStopped forem chamados |
Falhar quando @OnUnscheduled for chamado |
Especifica se o processador deve ou não gerar uma exceção quando os métodos anotados com @OnUnscheduled forem chamados |
Classe de exceção de FlowFile |
Exception class to be thrown (must extend java.lang. RuntimeException). |
Iterações de exceção de FlowFile |
Número de FlowFiles para lançar a exceção. |
Iterações de falha de FlowFile |
Número de FlowFiles para encaminhar ao relacionamento de falha. |
Iterações de reversão de FlowFile |
Número de FlowFiles para reverter (sem penalidade). |
Iterações de penalidade de reversão de FlowFile |
Número de FlowFiles para reverter com penalidade. |
Iterações de rendimento de reversão de FlowFile |
Número de FlowFiles para reverter e adiar. |
Iterações de sucesso de FlowFile |
Número de FlowFiles para encaminhar à relação de sucesso. |
Ignorar interrupções quando em pausa |
Se o(s) thread(s) do processador estiver(em) em espera (devido a uma das propriedades de “Tempo de pausa” acima) e o thread for interrompido, isso indica se o processador deve ignorar a interrupção e continuar dormindo ou se deve se permitir ser interrompido. |
Classe de exceção sem FlowFile |
Exception class to be thrown if no FlowFile (must extend java.lang. RuntimeException). |
Iterações de exceção sem FlowFile |
Número de vezes para gerar a exceção NPE se não houver FlowFile. |
Iterações ignoradas sem FlowFile |
Número de vezes para ignorar o onTrigger se não houver FlowFile. |
Iterações de adiamento sem FlowFile |
Número de vezes para adiar se não houver FlowFile. |
Tempo de pausa OnTrigger |
Especifica por quanto tempo o processador deve ficar em espera no método onTrigger(), de modo que o processador possa ser forçado a levar um longo tempo para executar sua tarefa |
Iterações de gravação |
Número de vezes para gravar no FlowFile |
Relações¶
Nome |
Descrição |
|---|---|
failure |
FlowFiles que não foram processados. |
success |
FlowFiles processados com sucesso. |