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
'<EOF>' at line 1, column 0. Query:
org.apache.nifi.record.path.exception.RecordPathException: Unexpected token
'<EOF>' 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
