[
https://issues.apache.org/jira/browse/NIFI-1544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shekhar Bansal updated NIFI-1544:
---------------------------------
Description:
My workflow:
ListFiles
FetchFIles
SplitFIles
ExtractText - Extract "date" from records
MergeContent - Correlation Attribute=date
UpdateAttribute - outputDirecoty=/data/output/${date}
PutFile
Problem is date is not available in UpdateAttribute processor.
Since all the records in a particular flow have same date, it should be
available in UpdateAttribute processor.
Because of this issue I have to read merged flow again(only first record).
was:
My workflow:
ListFiles
FetchFIles
SplitFIles
ExtractText - Extract "date" from records
MergeContent - Correlation Attribute=${date}
UpdateAttribute - outputDirecoty=/data/output/${date}
PutFile
Problem is date is not available in UpdateAttribute processor.
Since all the records in a particular flow have same date, it should be
available in UpdateAttribute processor.
Because of this issue I have to read merged flow again(only first record).
> [MergeContent Processor] Correlation Attribute should be available to next
> processor
> ------------------------------------------------------------------------------------
>
> Key: NIFI-1544
> URL: https://issues.apache.org/jira/browse/NIFI-1544
> Project: Apache NiFi
> Issue Type: Bug
> Components: Extensions
> Affects Versions: 0.4.1
> Environment: unix, nifi-0.4.1 compiled with hadoop-2.4.0
> Reporter: Shekhar Bansal
> Priority: Minor
>
> My workflow:
> ListFiles
> FetchFIles
> SplitFIles
> ExtractText - Extract "date" from records
> MergeContent - Correlation Attribute=date
> UpdateAttribute - outputDirecoty=/data/output/${date}
> PutFile
> Problem is date is not available in UpdateAttribute processor.
> Since all the records in a particular flow have same date, it should be
> available in UpdateAttribute processor.
> Because of this issue I have to read merged flow again(only first record).
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
