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

["nicolas cerutti (JIRA)" <ji...@apache.org>]

nicolas cerutti created NIFI-5273:
-------------------------------------

             Summary: 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


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)