Mark Payne wrote
> I've not seen this issue, but I created a JIRA [1] to address it. Will try
> to replicate it locally and see
> if I can understand what is happening. When this happens, do you see the
> processor continually
> spewing this Exception, rolling back, and trying again?
Thank you. I do see the same exception many times, repeatedly. And it
finally failed like this:
2017-01-11 14:06:47,157 INFO [StandardProcessScheduler Thread-8]
o.a.n.c.r.WriteAheadFlowFileRepository Successfully swapped out 10000
FlowFiles from
FlowFileQueue[id=536e3794-0157-1000-8f4b-303d154b73eb] to Swap File
/app_2/runtime/nifi/./flowfile_repository/swap/1484165206865-536e3794-0157-1000-8f
4b-303d154b73eb-3b22b90e-a691-4e8b-9474-64159092d8a7.swap
2017-01-11 14:06:47,291 INFO [StandardProcessScheduler Thread-6]
o.a.n.c.r.WriteAheadFlowFileRepository Successfully swapped out 10000
FlowFiles from
FlowFileQueue[id=e6af072c-fda8-4596-3baa-67a4f0dd0691] to Swap File
/app_2/runtime/nifi/./flowfile_repository/swap/1484165207150-e6af072c-fda8-4596-3b
aa-67a4f0dd0691-e7e015d9-b13a-4542-acb9-c143dfafc1eb.swap
2017-01-11 14:06:47,334 INFO [StandardProcessScheduler Thread-8]
o.a.n.c.r.WriteAheadFlowFileRepository Successfully swapped out 10000
FlowFiles from
FlowFileQueue[id=536e3794-0157-1000-8f4b-303d154b73eb] to Swap File
/app_2/runtime/nifi/./flowfile_repository/swap/1484165207232-536e3794-0157-1000-8f4b-303d154b73eb-6fb35722-ef7f-44b6-b930-b875831b6407.swap
2017-01-11 14:06:47,449 INFO [pool-1-thread-1]
o.apache.nifi.controller.FlowController Controller has been terminated
successfully.
2017-01-11 14:06:47,456 INFO [pool-1-thread-1]
o.a.n.w.c.ApplicationStartupContextListener Flow service termination
completed.
2017-01-11 14:06:47,457 INFO [pool-1-thread-1] /nifi-api Closing Spring root
WebApplicationContext
2017-01-11 14:06:47,465 ERROR [StandardProcessScheduler Thread-6]
org.apache.nifi.util.ReflectionUtils Failed while invoking annotated method
'public final void org.apache.nifi.processor.util.bin.BinFiles.resetState()'
with arguments '[]'.
java.lang.reflect.InvocationTargetException: null
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
~[na:1.8.0_65]
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
~[na:1.8.0_65]
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
~[na:1.8.0_65]
at java.lang.reflect.Method.invoke(Method.java:497) ~[na:1.8.0_65]
at
org.apache.nifi.util.ReflectionUtils.invokeMethodsWithAnnotations(ReflectionUtils.java:137)
[nifi-framework-core-1.1.0.jar:1.1.0]
at
org.apache.nifi.util.ReflectionUtils.invokeMethodsWithAnnotations(ReflectionUtils.java:125)
[nifi-framework-core-1.1.0.jar:1.1.0]
at
org.apache.nifi.util.ReflectionUtils.quietlyInvokeMethodsWithAnnotations(ReflectionUtils.java:233)
[nifi-framework-core-1.1.0.jar:1.1.0]
at
org.apache.nifi.util.ReflectionUtils.quietlyInvokeMethodsWithAnnotation(ReflectionUtils.java:85)
[nifi-framework-core-1.1.0.jar:1.1.0]
at
org.apache.nifi.controller.StandardProcessorNode$2.run(StandardProcessorNode.java:1373)
[nifi-framework-core-1.1.0.jar:1.1.0]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
[na:1.8.0_65]
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
[na:1.8.0_65]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
[na:1.8.0_65]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
[na:1.8.0_65]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
[na:1.8.0_65]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
[na:1.8.0_65]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_65]
Caused by: java.lang.IllegalStateException: Partition is closed
at
org.wali.MinimalLockingWriteAheadLog$Partition.update(MinimalLockingWriteAheadLog.java:945)
~[nifi-write-ahead-log-1.1.0.jar:1.1.0]
at
org.wali.MinimalLockingWriteAheadLog.update(MinimalLockingWriteAheadLog.java:238)
~[nifi-write-ahead-log-1.1.0.jar:1.1.0]
at
org.apache.nifi.controller.repository.WriteAheadFlowFileRepository.swapFlowFilesOut(WriteAheadFlowFileRepository.java:318)
~[nifi-framework-core-1.1.0.jar:1.1.0]
at
org.apache.nifi.controller.FileSystemSwapManager.swapOut(FileSystemSwapManager.java:135)
~[nifi-framework-core-1.1.0.jar:1.1.0]
at
org.apache.nifi.controller.StandardFlowFileQueue.writeSwapFilesIfNecessary(StandardFlowFileQueue.java:582)
~[nifi-framework-core-1.1.0.jar:1.1.0]
at
org.apache.nifi.controller.StandardFlowFileQueue.put(StandardFlowFileQueue.java:282)
~[nifi-framework-core-1.1.0.jar:1.1.0]
at
org.apache.nifi.controller.repository.StandardProcessSession.rollback(StandardProcessSession.java:959)
~[nifi-framework-core-1.1.0.jar:1.1.0]
at
org.apache.nifi.controller.repository.StandardProcessSession.rollback(StandardProcessSession.java:882)
~[nifi-framework-core-1.1.0.jar:1.1.0]
at
org.apache.nifi.controller.repository.StandardProcessSession.rollback(StandardProcessSession.java:877)
~[nifi-framework-core-1.1.0.jar:1.1.0]
at
org.apache.nifi.processor.util.bin.BinManager.purge(BinManager.java:65)
~[nifi-processor-utils-1.1.0.jar:1.1.0]
at
org.apache.nifi.processor.util.bin.BinFiles.resetState(BinFiles.java:111)
~[nifi-processor-utils-1.1.0.jar:1.1.0]
... 16 common frames omitted
--
View this message in context:
http://apache-nifi-developer-list.39713.n7.nabble.com/MergeContent-error-on-restart-not-the-most-recent-flow-file-in-this-session-tp14436p14439.html
Sent from the Apache NiFi Developer List mailing list archive at Nabble.com.
