You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@nifi.apache.org by "Sivaprasanna Sethuraman (JIRA)" <ji...@apache.org> on 2018/06/06 15:14:00 UTC

[jira] [Commented] (NIFI-5273) UpdateRecord does not yield as expected

    [ https://issues.apache.org/jira/browse/NIFI-5273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16503429#comment-16503429 ] 

Sivaprasanna Sethuraman commented on NIFI-5273:
-----------------------------------------------

[~ncerutti]

I'm afraid I don't understand it clearly. The issue summary and description seems to differ. Can you please tell what is the issue here?

> UpdateRecord does not yield as expected
> ---------------------------------------
>
>                 Key: NIFI-5273
>                 URL: https://issues.apache.org/jira/browse/NIFI-5273
>             Project: Apache NiFi
>          Issue Type: Bug
>          Components: Extensions
>    Affects Versions: 1.6.0
>            Reporter: nicolas cerutti
>            Priority: Major
>
> Hello,
> I have an UpdateRecord with the configuration defined
> _Record Reader -> Controller Service "Json TreeReader"_
> _Record Writer -> Controller Service "CSVRecordSetWriter"_
> _Replacement Value Strategy ->_ 
> _/stack_na (new property) -> ${field.value:replaceAll('<\d*>[A-Z]\{1}[a-z]\{2} \d\{2} \d\{2}:\d\{2}:\d\{2}.[^:]*:', '')}_
> _/timestamp (new property) -> ${field.value:toDate("yyyy-MM-dd'T'HH:mm:ss"):format("yyyy-MM-dd HH:mm:ss")}_
> A syntax error was set and we have the following error :
> *Stack Trace :* 
> 2018-06-06 15:15:22,124 ERROR [Timer-Driven Process Thread-3] o.a.n.processors.standard.UpdateRecord UpdateRecord[id=5df23125-c500-1508-bec2-062b7c4864c6] Failed to process StandardFlowFileRecord[uuid=fd24efd9-be57-4449-a700-774e93f8ea5e,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1528211253276-28, container=default, section=28], offset=259115, length=2824064],offset=0,name=metrics_20180605172848_132.haas.socgen.log,size=2824064]: org.apache.nifi.attribute.expression.language.exception.IllegalAttributeException: Cannot parse attribute value as a date; date format: MMM dd HH:mm:ss; attribute value: 2018-06-01T00:21:01
> org.apache.nifi.attribute.expression.language.exception.IllegalAttributeException: Cannot parse attribute value as a date; date format: MMM dd HH:mm:ss; attribute value: 2018-06-01T00:21:01
>         at org.apache.nifi.attribute.expression.language.evaluation.functions.StringToDateEvaluator.evaluate(StringToDateEvaluator.java:65)
>         at org.apache.nifi.attribute.expression.language.evaluation.functions.FormatEvaluator.evaluate(FormatEvaluator.java:45)
>         at org.apache.nifi.attribute.expression.language.Query.evaluate(Query.java:587)
>         at org.apache.nifi.attribute.expression.language.Query.evaluateExpression(Query.java:393)
>         at org.apache.nifi.attribute.expression.language.StandardPreparedQuery.evaluateExpressions(StandardPreparedQuery.java:48)
>         at org.apache.nifi.attribute.expression.language.StandardPropertyValue.evaluateAttributeExpressions(StandardPropertyValue.java:160)
>         at org.apache.nifi.attribute.expression.language.StandardPropertyValue.evaluateAttributeExpressions(StandardPropertyValue.java:148)
>         at org.apache.nifi.attribute.expression.language.StandardPropertyValue.evaluateAttributeExpressions(StandardPropertyValue.java:138)
>         at org.apache.nifi.processors.standard.UpdateRecord.lambda$process$1(UpdateRecord.java:174)
>         at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:184)
>         at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
>         at java.util.stream.Streams$StreamBuilderImpl.forEachRemaining(Streams.java:419)
>         at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:481)
>         at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:471)
>         at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:151)
>         at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:174)
>         at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
>         at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:418)
>         at org.apache.nifi.processors.standard.UpdateRecord.process(UpdateRecord.java:168)
>         at org.apache.nifi.processors.standard.AbstractRecordProcessor$1.process(AbstractRecordProcessor.java:129)
>         at org.apache.nifi.controller.repository.StandardProcessSession.write(StandardProcessSession.java:2785)
>         at org.apache.nifi.processors.standard.AbstractRecordProcessor.onTrigger(AbstractRecordProcessor.java:118)
>         at org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27)
>         at org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1118)
>         at org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:147)
>         at org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:47)
>         at org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:132)
>         at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
>         at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
>         at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
>         at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
>         at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
>         at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
>         at java.lang.Thread.run(Thread.java:748)
>  
>  
> Thanks for your help on this bug
>  
> Nicolas C.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)