Akhil
Akhil

Reputation: 646

Why is Flowfile Being Cloned?

I was wondering why some processors are cloning the flow file before routing it to next processor.

For example, QueryDatabaseTable processor always clones the flow file before passing it to the ContentAvrotoORC processor.

Why is there a need to clone the Flowfile ?

Example NiFi Flow

Event List

Upvotes: 1

Views: 709

Answers (1)

Bryan Bende
Bryan Bende

Reputation: 18660

I think the clone event represents the fact that the same flow is being transferred to two different destinations (LogMessage and ConvertAvroToORC). So there is one flow file created by QueryDatabaseTable, then when the framework sees that success goes two places, it has to clone the flow file.

Upvotes: 4

Related Questions