Re: UpdateRecord Unexpected EOF
Shawn, If you want to use Expression Language for the value, you have to set the "Replacement Value Strategy" to "Literal Value," not "RecordPath Value." Thanks -Mark > On Sep 26, 2019, at 9:08 AM, Bryan Bende wrote: > > Looks like // is valid and means find log_date wherever it is, rather > than /log_date which would mean it is at the first level. > > On Wed, Sep 25, 2019 at 6:25 PM Shawn Weeks wrote: >> >> I copied the //log_date from the NiFi Documentation so if your only supposed >> to use single slashes we might have a bug there. Turns out the EOF error is >> because I was Record Path mode instead of Literal Value. Something I missed >> from the documentation. >> >> Thanks >> Shawn Weeks >> >> From: Bryan Bende >> Sent: Wednesday, September 25, 2019 12:44 PM >> To: users@nifi.apache.org >> Subject: Re: UpdateRecord Unexpected EOF >> >> Not sure if this is reason but I believe record path would be >> /log_date instead of //log_date >> >> On Wed, Sep 25, 2019 at 1:14 PM Shawn Weeks >> wrote: >>> >>> Trying to figure out what's causing this issue. In a simple test of >>> UpdateRecord I'm getting an exception. This is on NiFi 1.9.2 >>> >>> 2019-09-25 11:59:55,462 ERROR [Timer-Driven Process Thread-10] >>> o.a.n.processors.standard.UpdateRecord >>> UpdateRecord[id=692c3fdc-016d-1000-1d1a-3f2c2a1a99bb] Failed to process >>> StandardFlowFileRecord[uuid=f27dad32-4c50-4c4b-80dd-475a440aa71a,claim=StandardContentClaim >>> [resourceClaim=StandardResourceClaim[id=1569426927954-5, >>> container=default, section=5], offset=638483, >>> length=4492],offset=0,name=20190925165348482.prod.hive_src_file_meta,size=4492]; >>> will route to failure: >>> org.apache.nifi.record.path.exception.RecordPathException: Unexpected token >>> '' at line 1, column 0. Query: >>> org.apache.nifi.record.path.exception.RecordPathException: Unexpected token >>> '' at line 1, column 0. Query: >>>at >>> org.apache.nifi.record.path.RecordPathParser.displayRecognitionError(RecordPathParser.java:120) >>>at >>> org.antlr.runtime.BaseRecognizer.reportError(BaseRecognizer.java:186) >>>at >>> org.apache.nifi.record.path.RecordPathParser.pathOrFunction(RecordPathParser.java:4328) >>>at >>> org.apache.nifi.record.path.RecordPathParser.pathExpression(RecordPathParser.java:4367) >>>at org.apache.nifi.record.path.RecordPath.compile(RecordPath.java:84) >>>at >>> com.github.benmanes.caffeine.cache.BoundedLocalCache$BoundedLocalLoadingCache.lambda$new$0(BoundedLocalCache.java:3366) >>>at >>> com.github.benmanes.caffeine.cache.BoundedLocalCache.lambda$doComputeIfAbsent$14(BoundedLocalCache.java:2039) >>>at >>> java.util.concurrent.ConcurrentHashMap.compute(ConcurrentHashMap.java:1853) >>>at >>> com.github.benmanes.caffeine.cache.BoundedLocalCache.doComputeIfAbsent(BoundedLocalCache.java:2037) >>>at >>> com.github.benmanes.caffeine.cache.BoundedLocalCache.computeIfAbsent(BoundedLocalCache.java:2020) >>>at >>> com.github.benmanes.caffeine.cache.LocalCache.computeIfAbsent(LocalCache.java:112) >>>at >>> com.github.benmanes.caffeine.cache.LocalLoadingCache.get(LocalLoadingCache.java:67) >>>at >>> org.apache.nifi.record.path.util.RecordPathCache.getCompiled(RecordPathCache.java:34) >>>at >>> org.apache.nifi.processors.standard.UpdateRecord.process(UpdateRecord.java:154) >>>at >>> org.apache.nifi.processors.standard.AbstractRecordProcessor$1.process(AbstractRecordProcessor.java:147) >>>at >>> org.apache.nifi.controller.repository.StandardProcessSession.write(StandardProcessSession.java:2887) >>>at >>> org.apache.nifi.processors.standard.AbstractRecordProcessor.onTrigger(AbstractRecordProcessor.java:122) >>>at >>> org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27) >>>at >>> org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1162) >>>at >>> org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java:209) >>>at >>> org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:117) >>>at org.apache
Re: UpdateRecord Unexpected EOF
Well, to clarify... If you want to use the Expression ${field.value} then
you'll want to use the Replacement Value Strategy of "Literal Value." When
you're doing is evaluating the RecordPath, getting the value as the variable
${field.value} and then attempting to evaluate that as a RecordPath. So if
//log_date evaluated to say "01/01/2019" then the way you have it configured,
it would be attempting to evaluate "01/01/2019" as a RecordPath, and that's why
it is failing. Changing the strategy to Literal Value means that you would set
the value "01/01/2019" as the value for the field (i.e., you would not be
changing anything).
Thanks
-Mark
> On Sep 26, 2019, at 10:00 AM, Mark Payne wrote:
>
> Shawn,
>
> If you want to use Expression Language for the value, you have to set the
> "Replacement Value Strategy" to "Literal Value," not "RecordPath Value."
>
> Thanks
> -Mark
>
>
>> On Sep 26, 2019, at 9:08 AM, Bryan Bende wrote:
>>
>> Looks like // is valid and means find log_date wherever it is, rather
>> than /log_date which would mean it is at the first level.
>>
>> On Wed, Sep 25, 2019 at 6:25 PM Shawn Weeks
>> wrote:
>>>
>>> I copied the //log_date from the NiFi Documentation so if your only
>>> supposed to use single slashes we might have a bug there. Turns out the EOF
>>> error is because I was Record Path mode instead of Literal Value. Something
>>> I missed from the documentation.
>>>
>>> Thanks
>>> Shawn Weeks
>>>
>>> From: Bryan Bende
>>> Sent: Wednesday, September 25, 2019 12:44 PM
>>> To: users@nifi.apache.org
>>> Subject: Re: UpdateRecord Unexpected EOF
>>>
>>> Not sure if this is reason but I believe record path would be
>>> /log_date instead of //log_date
>>>
>>> On Wed, Sep 25, 2019 at 1:14 PM Shawn Weeks
>>> wrote:
>>>>
>>>> Trying to figure out what's causing this issue. In a simple test of
>>>> UpdateRecord I'm getting an exception. This is on NiFi 1.9.2
>>>>
>>>> 2019-09-25 11:59:55,462 ERROR [Timer-Driven Process Thread-10]
>>>> o.a.n.processors.standard.UpdateRecord
>>>> UpdateRecord[id=692c3fdc-016d-1000-1d1a-3f2c2a1a99bb] Failed to process
>>>> StandardFlowFileRecord[uuid=f27dad32-4c50-4c4b-80dd-475a440aa71a,claim=StandardContentClaim
>>>> [resourceClaim=StandardResourceClaim[id=1569426927954-5,
>>>> container=default, section=5], offset=638483,
>>>> length=4492],offset=0,name=20190925165348482.prod.hive_src_file_meta,size=4492];
>>>> will route to failure:
>>>> org.apache.nifi.record.path.exception.RecordPathException: Unexpected
>>>> token '' at line 1, column 0. Query:
>>>> org.apache.nifi.record.path.exception.RecordPathException: Unexpected
>>>> token '' at line 1, column 0. Query:
>>>> at
>>>> org.apache.nifi.record.path.RecordPathParser.displayRecognitionError(RecordPathParser.java:120)
>>>> at
>>>> org.antlr.runtime.BaseRecognizer.reportError(BaseRecognizer.java:186)
>>>> at
>>>> org.apache.nifi.record.path.RecordPathParser.pathOrFunction(RecordPathParser.java:4328)
>>>> at
>>>> org.apache.nifi.record.path.RecordPathParser.pathExpression(RecordPathParser.java:4367)
>>>> at org.apache.nifi.record.path.RecordPath.compile(RecordPath.java:84)
>>>> at
>>>> com.github.benmanes.caffeine.cache.BoundedLocalCache$BoundedLocalLoadingCache.lambda$new$0(BoundedLocalCache.java:3366)
>>>> at
>>>> com.github.benmanes.caffeine.cache.BoundedLocalCache.lambda$doComputeIfAbsent$14(BoundedLocalCache.java:2039)
>>>> at
>>>> java.util.concurrent.ConcurrentHashMap.compute(ConcurrentHashMap.java:1853)
>>>> at
>>>> com.github.benmanes.caffeine.cache.BoundedLocalCache.doComputeIfAbsent(BoundedLocalCache.java:2037)
>>>> at
>>>> com.github.benmanes.caffeine.cache.BoundedLocalCache.computeIfAbsent(BoundedLocalCache.java:2020)
>>>> at
>>>> com.github.benmanes.caffeine.cache.LocalCache.computeIfAbsent(LocalCache.java:112)
>>>> at
>>>> com.github.benmanes.caffeine.cache.LocalLoadingCache.get(LocalLoadingCache.java:67)
>>>> at
>>>> org.apache.nifi.record.path.util.RecordPathCache.getCompiled
Re: UpdateRecord Unexpected EOF
Looks like // is valid and means find log_date wherever it is, rather than /log_date which would mean it is at the first level. On Wed, Sep 25, 2019 at 6:25 PM Shawn Weeks wrote: > > I copied the //log_date from the NiFi Documentation so if your only supposed > to use single slashes we might have a bug there. Turns out the EOF error is > because I was Record Path mode instead of Literal Value. Something I missed > from the documentation. > > Thanks > Shawn Weeks > > From: Bryan Bende > Sent: Wednesday, September 25, 2019 12:44 PM > To: users@nifi.apache.org > Subject: Re: UpdateRecord Unexpected EOF > > Not sure if this is reason but I believe record path would be > /log_date instead of //log_date > > On Wed, Sep 25, 2019 at 1:14 PM Shawn Weeks wrote: > > > > Trying to figure out what's causing this issue. In a simple test of > > UpdateRecord I'm getting an exception. This is on NiFi 1.9.2 > > > > 2019-09-25 11:59:55,462 ERROR [Timer-Driven Process Thread-10] > > o.a.n.processors.standard.UpdateRecord > > UpdateRecord[id=692c3fdc-016d-1000-1d1a-3f2c2a1a99bb] Failed to process > > StandardFlowFileRecord[uuid=f27dad32-4c50-4c4b-80dd-475a440aa71a,claim=StandardContentClaim > > [resourceClaim=StandardResourceClaim[id=1569426927954-5, > > container=default, section=5], offset=638483, > > length=4492],offset=0,name=20190925165348482.prod.hive_src_file_meta,size=4492]; > > will route to failure: > > org.apache.nifi.record.path.exception.RecordPathException: Unexpected token > > '' at line 1, column 0. Query: > > org.apache.nifi.record.path.exception.RecordPathException: Unexpected token > > '' at line 1, column 0. Query: > > at > > org.apache.nifi.record.path.RecordPathParser.displayRecognitionError(RecordPathParser.java:120) > > at > > org.antlr.runtime.BaseRecognizer.reportError(BaseRecognizer.java:186) > > at > > org.apache.nifi.record.path.RecordPathParser.pathOrFunction(RecordPathParser.java:4328) > > at > > org.apache.nifi.record.path.RecordPathParser.pathExpression(RecordPathParser.java:4367) > > at > > org.apache.nifi.record.path.RecordPath.compile(RecordPath.java:84) > > at > > com.github.benmanes.caffeine.cache.BoundedLocalCache$BoundedLocalLoadingCache.lambda$new$0(BoundedLocalCache.java:3366) > > at > > com.github.benmanes.caffeine.cache.BoundedLocalCache.lambda$doComputeIfAbsent$14(BoundedLocalCache.java:2039) > > at > > java.util.concurrent.ConcurrentHashMap.compute(ConcurrentHashMap.java:1853) > > at > > com.github.benmanes.caffeine.cache.BoundedLocalCache.doComputeIfAbsent(BoundedLocalCache.java:2037) > > at > > com.github.benmanes.caffeine.cache.BoundedLocalCache.computeIfAbsent(BoundedLocalCache.java:2020) > > at > > com.github.benmanes.caffeine.cache.LocalCache.computeIfAbsent(LocalCache.java:112) > > at > > com.github.benmanes.caffeine.cache.LocalLoadingCache.get(LocalLoadingCache.java:67) > > at > > org.apache.nifi.record.path.util.RecordPathCache.getCompiled(RecordPathCache.java:34) > > at > > org.apache.nifi.processors.standard.UpdateRecord.process(UpdateRecord.java:154) > > at > > org.apache.nifi.processors.standard.AbstractRecordProcessor$1.process(AbstractRecordProcessor.java:147) > > at > > org.apache.nifi.controller.repository.StandardProcessSession.write(StandardProcessSession.java:2887) > > at > > org.apache.nifi.processors.standard.AbstractRecordProcessor.onTrigger(AbstractRecordProcessor.java:122) > > at > > org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27) > > at > > org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1162) > > at > > org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java:209) > > at > > org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:117) > > at org.apache.nifi.engine.FlowEngine$2.run(FlowEngine.java:110) > > 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:1149) > > at > > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) > > at java.lang.Thread.run(Thread.java:748)
Re: UpdateRecord Unexpected EOF
I copied the //log_date from the NiFi Documentation so if your only supposed to use single slashes we might have a bug there. Turns out the EOF error is because I was Record Path mode instead of Literal Value. Something I missed from the documentation. Thanks Shawn Weeks From: Bryan Bende Sent: Wednesday, September 25, 2019 12:44 PM To: users@nifi.apache.org Subject: Re: UpdateRecord Unexpected EOF Not sure if this is reason but I believe record path would be /log_date instead of //log_date On Wed, Sep 25, 2019 at 1:14 PM Shawn Weeks wrote: > > Trying to figure out what's causing this issue. In a simple test of > UpdateRecord I'm getting an exception. This is on NiFi 1.9.2 > > 2019-09-25 11:59:55,462 ERROR [Timer-Driven Process Thread-10] > o.a.n.processors.standard.UpdateRecord > UpdateRecord[id=692c3fdc-016d-1000-1d1a-3f2c2a1a99bb] Failed to process > StandardFlowFileRecord[uuid=f27dad32-4c50-4c4b-80dd-475a440aa71a,claim=StandardContentClaim > [resourceClaim=StandardResourceClaim[id=1569426927954-5, container=default, > section=5], offset=638483, > length=4492],offset=0,name=20190925165348482.prod.hive_src_file_meta,size=4492]; > will route to failure: > org.apache.nifi.record.path.exception.RecordPathException: Unexpected token > '' at line 1, column 0. Query: > org.apache.nifi.record.path.exception.RecordPathException: Unexpected token > '' at line 1, column 0. Query: > at > org.apache.nifi.record.path.RecordPathParser.displayRecognitionError(RecordPathParser.java:120) > at > org.antlr.runtime.BaseRecognizer.reportError(BaseRecognizer.java:186) > at > org.apache.nifi.record.path.RecordPathParser.pathOrFunction(RecordPathParser.java:4328) > at > org.apache.nifi.record.path.RecordPathParser.pathExpression(RecordPathParser.java:4367) > at org.apache.nifi.record.path.RecordPath.compile(RecordPath.java:84) > at > com.github.benmanes.caffeine.cache.BoundedLocalCache$BoundedLocalLoadingCache.lambda$new$0(BoundedLocalCache.java:3366) > at > com.github.benmanes.caffeine.cache.BoundedLocalCache.lambda$doComputeIfAbsent$14(BoundedLocalCache.java:2039) > at > java.util.concurrent.ConcurrentHashMap.compute(ConcurrentHashMap.java:1853) > at > com.github.benmanes.caffeine.cache.BoundedLocalCache.doComputeIfAbsent(BoundedLocalCache.java:2037) > at > com.github.benmanes.caffeine.cache.BoundedLocalCache.computeIfAbsent(BoundedLocalCache.java:2020) > at > com.github.benmanes.caffeine.cache.LocalCache.computeIfAbsent(LocalCache.java:112) > at > com.github.benmanes.caffeine.cache.LocalLoadingCache.get(LocalLoadingCache.java:67) > at > org.apache.nifi.record.path.util.RecordPathCache.getCompiled(RecordPathCache.java:34) > at > org.apache.nifi.processors.standard.UpdateRecord.process(UpdateRecord.java:154) > at > org.apache.nifi.processors.standard.AbstractRecordProcessor$1.process(AbstractRecordProcessor.java:147) > at > org.apache.nifi.controller.repository.StandardProcessSession.write(StandardProcessSession.java:2887) > at > org.apache.nifi.processors.standard.AbstractRecordProcessor.onTrigger(AbstractRecordProcessor.java:122) > at > org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27) > at > org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1162) > at > org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java:209) > at > org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:117) > at org.apache.nifi.engine.FlowEngine$2.run(FlowEngine.java:110) > 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:1149) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) > at java.lang.Thread.run(Thread.java:748)
Re: UpdateRecord Unexpected EOF
Hello, Shawn. It seems to be related to the syntax of your custom fields. Check below the form that I use to perform such operations: [image: image.png] Em qua, 25 de set de 2019 às 14:14, Shawn Weeks escreveu: > Trying to figure out what's causing this issue. In a simple test of > UpdateRecord I'm getting an exception. This is on NiFi 1.9.2 > > 2019-09-25 11:59:55,462 ERROR [Timer-Driven Process Thread-10] > o.a.n.processors.standard.UpdateRecord > UpdateRecord[id=692c3fdc-016d-1000-1d1a-3f2c2a1a99bb] Failed to process > StandardFlowFileRecord[uuid=f27dad32-4c50-4c4b-80dd-475a440aa71a,claim=StandardContentClaim > [resourceClaim=StandardResourceClaim[id=1569426927954-5, container=default, > section=5], offset=638483, > length=4492],offset=0,name=20190925165348482.prod.hive_src_file_meta,size=4492]; > will route to failure: > org.apache.nifi.record.path.exception.RecordPathException: Unexpected token > '' at line 1, column 0. Query: > org.apache.nifi.record.path.exception.RecordPathException: Unexpected > token '' at line 1, column 0. Query: > at > org.apache.nifi.record.path.RecordPathParser.displayRecognitionError(RecordPathParser.java:120) > at > org.antlr.runtime.BaseRecognizer.reportError(BaseRecognizer.java:186) > at > org.apache.nifi.record.path.RecordPathParser.pathOrFunction(RecordPathParser.java:4328) > at > org.apache.nifi.record.path.RecordPathParser.pathExpression(RecordPathParser.java:4367) > at > org.apache.nifi.record.path.RecordPath.compile(RecordPath.java:84) > at > com.github.benmanes.caffeine.cache.BoundedLocalCache$BoundedLocalLoadingCache.lambda$new$0(BoundedLocalCache.java:3366) > at > com.github.benmanes.caffeine.cache.BoundedLocalCache.lambda$doComputeIfAbsent$14(BoundedLocalCache.java:2039) > at > java.util.concurrent.ConcurrentHashMap.compute(ConcurrentHashMap.java:1853) > at > com.github.benmanes.caffeine.cache.BoundedLocalCache.doComputeIfAbsent(BoundedLocalCache.java:2037) > at > com.github.benmanes.caffeine.cache.BoundedLocalCache.computeIfAbsent(BoundedLocalCache.java:2020) > at > com.github.benmanes.caffeine.cache.LocalCache.computeIfAbsent(LocalCache.java:112) > at > com.github.benmanes.caffeine.cache.LocalLoadingCache.get(LocalLoadingCache.java:67) > at > org.apache.nifi.record.path.util.RecordPathCache.getCompiled(RecordPathCache.java:34) > at > org.apache.nifi.processors.standard.UpdateRecord.process(UpdateRecord.java:154) > at > org.apache.nifi.processors.standard.AbstractRecordProcessor$1.process(AbstractRecordProcessor.java:147) > at > org.apache.nifi.controller.repository.StandardProcessSession.write(StandardProcessSession.java:2887) > at > org.apache.nifi.processors.standard.AbstractRecordProcessor.onTrigger(AbstractRecordProcessor.java:122) > at > org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27) > at > org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1162) > at > org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java:209) > at > org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:117) > at org.apache.nifi.engine.FlowEngine$2.run(FlowEngine.java:110) > 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:1149) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) > at java.lang.Thread.run(Thread.java:748) > -- Grato, Wesley C. Dias de Oliveira. Linux User nº 576838.
Re: UpdateRecord Unexpected EOF
Not sure if this is reason but I believe record path would be /log_date instead of //log_date On Wed, Sep 25, 2019 at 1:14 PM Shawn Weeks wrote: > > Trying to figure out what's causing this issue. In a simple test of > UpdateRecord I'm getting an exception. This is on NiFi 1.9.2 > > 2019-09-25 11:59:55,462 ERROR [Timer-Driven Process Thread-10] > o.a.n.processors.standard.UpdateRecord > UpdateRecord[id=692c3fdc-016d-1000-1d1a-3f2c2a1a99bb] Failed to process > StandardFlowFileRecord[uuid=f27dad32-4c50-4c4b-80dd-475a440aa71a,claim=StandardContentClaim > [resourceClaim=StandardResourceClaim[id=1569426927954-5, container=default, > section=5], offset=638483, > length=4492],offset=0,name=20190925165348482.prod.hive_src_file_meta,size=4492]; > will route to failure: > org.apache.nifi.record.path.exception.RecordPathException: Unexpected token > '' at line 1, column 0. Query: > org.apache.nifi.record.path.exception.RecordPathException: Unexpected token > '' at line 1, column 0. Query: > at > org.apache.nifi.record.path.RecordPathParser.displayRecognitionError(RecordPathParser.java:120) > at > org.antlr.runtime.BaseRecognizer.reportError(BaseRecognizer.java:186) > at > org.apache.nifi.record.path.RecordPathParser.pathOrFunction(RecordPathParser.java:4328) > at > org.apache.nifi.record.path.RecordPathParser.pathExpression(RecordPathParser.java:4367) > at org.apache.nifi.record.path.RecordPath.compile(RecordPath.java:84) > at > com.github.benmanes.caffeine.cache.BoundedLocalCache$BoundedLocalLoadingCache.lambda$new$0(BoundedLocalCache.java:3366) > at > com.github.benmanes.caffeine.cache.BoundedLocalCache.lambda$doComputeIfAbsent$14(BoundedLocalCache.java:2039) > at > java.util.concurrent.ConcurrentHashMap.compute(ConcurrentHashMap.java:1853) > at > com.github.benmanes.caffeine.cache.BoundedLocalCache.doComputeIfAbsent(BoundedLocalCache.java:2037) > at > com.github.benmanes.caffeine.cache.BoundedLocalCache.computeIfAbsent(BoundedLocalCache.java:2020) > at > com.github.benmanes.caffeine.cache.LocalCache.computeIfAbsent(LocalCache.java:112) > at > com.github.benmanes.caffeine.cache.LocalLoadingCache.get(LocalLoadingCache.java:67) > at > org.apache.nifi.record.path.util.RecordPathCache.getCompiled(RecordPathCache.java:34) > at > org.apache.nifi.processors.standard.UpdateRecord.process(UpdateRecord.java:154) > at > org.apache.nifi.processors.standard.AbstractRecordProcessor$1.process(AbstractRecordProcessor.java:147) > at > org.apache.nifi.controller.repository.StandardProcessSession.write(StandardProcessSession.java:2887) > at > org.apache.nifi.processors.standard.AbstractRecordProcessor.onTrigger(AbstractRecordProcessor.java:122) > at > org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27) > at > org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1162) > at > org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java:209) > at > org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:117) > at org.apache.nifi.engine.FlowEngine$2.run(FlowEngine.java:110) > 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:1149) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) > at java.lang.Thread.run(Thread.java:748)
UpdateRecord Unexpected EOF
Trying to figure out what's causing this issue. In a simple test of UpdateRecord I'm getting an exception. This is on NiFi 1.9.2 2019-09-25 11:59:55,462 ERROR [Timer-Driven Process Thread-10] o.a.n.processors.standard.UpdateRecord UpdateRecord[id=692c3fdc-016d-1000-1d1a-3f2c2a1a99bb] Failed to process StandardFlowFileRecord[uuid=f27dad32-4c50-4c4b-80dd-475a440aa71a,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1569426927954-5, container=default, section=5], offset=638483, length=4492],offset=0,name=20190925165348482.prod.hive_src_file_meta,size=4492]; will route to failure: org.apache.nifi.record.path.exception.RecordPathException: Unexpected token '' at line 1, column 0. Query: org.apache.nifi.record.path.exception.RecordPathException: Unexpected token '' at line 1, column 0. Query: at org.apache.nifi.record.path.RecordPathParser.displayRecognitionError(RecordPathParser.java:120) at org.antlr.runtime.BaseRecognizer.reportError(BaseRecognizer.java:186) at org.apache.nifi.record.path.RecordPathParser.pathOrFunction(RecordPathParser.java:4328) at org.apache.nifi.record.path.RecordPathParser.pathExpression(RecordPathParser.java:4367) at org.apache.nifi.record.path.RecordPath.compile(RecordPath.java:84) at com.github.benmanes.caffeine.cache.BoundedLocalCache$BoundedLocalLoadingCache.lambda$new$0(BoundedLocalCache.java:3366) at com.github.benmanes.caffeine.cache.BoundedLocalCache.lambda$doComputeIfAbsent$14(BoundedLocalCache.java:2039) at java.util.concurrent.ConcurrentHashMap.compute(ConcurrentHashMap.java:1853) at com.github.benmanes.caffeine.cache.BoundedLocalCache.doComputeIfAbsent(BoundedLocalCache.java:2037) at com.github.benmanes.caffeine.cache.BoundedLocalCache.computeIfAbsent(BoundedLocalCache.java:2020) at com.github.benmanes.caffeine.cache.LocalCache.computeIfAbsent(LocalCache.java:112) at com.github.benmanes.caffeine.cache.LocalLoadingCache.get(LocalLoadingCache.java:67) at org.apache.nifi.record.path.util.RecordPathCache.getCompiled(RecordPathCache.java:34) at org.apache.nifi.processors.standard.UpdateRecord.process(UpdateRecord.java:154) at org.apache.nifi.processors.standard.AbstractRecordProcessor$1.process(AbstractRecordProcessor.java:147) at org.apache.nifi.controller.repository.StandardProcessSession.write(StandardProcessSession.java:2887) at org.apache.nifi.processors.standard.AbstractRecordProcessor.onTrigger(AbstractRecordProcessor.java:122) at org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27) at org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1162) at org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java:209) at org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:117) at org.apache.nifi.engine.FlowEngine$2.run(FlowEngine.java:110) 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:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) nifi_example.json Description: nifi_example.json
