I am using Zeppelin 0.8 on hdp 3.0.In ambari Zeppelin is shown as started but when I try to access Zeppelin UI it shows HTTP ERROR 503 Problem accessing /. Reason: Service Unavailable   Powered by Jetty:// 9.4.11.v20180605   Have checked the permissions on Webapps folder it is fine, even cleared the contents of notebook folder and tried again but with no success. Even deleted the service and reinstalled it on another host but no effect Please help @Shelton  Contents of log : MultiException stack 1 of 1 com.google.gson.JsonSyntaxException: duplicate key: colWidth at com.google.gson.internal.bind.MapTypeAdapterFactory$Adapter.read(MapTypeAdapterFactory.java:191) at com.google.gson.internal.bind.MapTypeAdapterFactory$Adapter.read(MapTypeAdapterFactory.java:146) at com.google.gson.internal.bind.ReflectiveTypeAdapterFactory$1.read(ReflectiveTypeAdapterFactory.java:93) at com.google.gson.internal.bind.ReflectiveTypeAdapterFactory$Adapter.read(ReflectiveTypeAdapterFactory.java:172) at com.google.gson.internal.bind.TypeAdapterRuntimeTypeWrapper.read(TypeAdapterRuntimeTypeWrapper.java:40) at com.google.gson.internal.bind.CollectionTypeAdapterFactory$Adapter.read(CollectionTypeAdapterFactory.java:81) at com.google.gson.internal.bind.CollectionTypeAdapterFactory$Adapter.read(CollectionTypeAdapterFactory.java:60) at com.google.gson.internal.bind.ReflectiveTypeAdapterFactory$1.read(ReflectiveTypeAdapterFactory.java:93) at com.google.gson.internal.bind.ReflectiveTypeAdapterFactory$Adapter.read(ReflectiveTypeAdapterFactory.java:172) at com.google.gson.Gson.fromJson(Gson.java:791) at com.google.gson.Gson.fromJson(Gson.java:757) at com.google.gson.Gson.fromJson(Gson.java:706) at com.google.gson.Gson.fromJson(Gson.java:678) at org.apache.zeppelin.notebook.Note.fromJson(Note.java:988) at org.apache.zeppelin.notebook.repo.FileSystemNotebookRepo.get(FileSystemNotebookRepo.java:68) at org.apache.zeppelin.notebook.repo.NotebookRepoSync.get(NotebookRepoSync.java:165) at org.apache.zeppelin.notebook.Notebook.loadNoteFromRepo(Notebook.java:505) at org.apache.zeppelin.notebook.Notebook.loadAllNotes(Notebook.java:589) at org.apache.zeppelin.notebook.Notebook.<init>(Notebook.java:123) at org.apache.zeppelin.server.ZeppelinServer.<init>(ZeppelinServer.java:161) at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) at java.lang.reflect.Constructor.newInstance(Constructor.java:423) at org.glassfish.hk2.utilities.reflection.ReflectionHelper.makeMe(ReflectionHelper.java:1375) at org.jvnet.hk2.internal.Utilities.justCreate(Utilities.java:1083) at org.jvnet.hk2.internal.ServiceLocatorImpl.create(ServiceLocatorImpl.java:978) at org.jvnet.hk2.internal.ServiceLocatorImpl.createAndInitialize(ServiceLocatorImpl.java:1082) at org.jvnet.hk2.internal.ServiceLocatorImpl.createAndInitialize(ServiceLocatorImpl.java:1074) at org.glassfish.jersey.inject.hk2.AbstractHk2InjectionManager.createAndInitialize(AbstractHk2InjectionManager.java:213) at org.glassfish.jersey.inject.hk2.ImmediateHk2InjectionManager.createAndInitialize(ImmediateHk2InjectionManager.java:54) at org.glassfish.jersey.server.ApplicationConfigurator.createApplication(ApplicationConfigurator.java:138) at org.glassfish.jersey.server.ApplicationConfigurator.init(ApplicationConfigurator.java:96) at org.glassfish.jersey.server.ApplicationHandler.lambda$initialize$0(ApplicationHandler.java:313) at java.util.Arrays$ArrayList.forEach(Arrays.java:3880) at org.glassfish.jersey.server.ApplicationHandler.initialize(ApplicationHandler.java:313) at org.glassfish.jersey.server.ApplicationHandler.<init>(ApplicationHandler.java:282) at org.glassfish.jersey.servlet.WebComponent.<init>(WebComponent.java:335) at org.glassfish.jersey.servlet.ServletContainer.init(ServletContainer.java:178) at org.glassfish.jersey.servlet.ServletContainer.init(ServletContainer.java:370) at javax.servlet.GenericServlet.init(GenericServlet.java:244) at org.eclipse.jetty.servlet.ServletHolder.initServlet(ServletHolder.java:670) at org.eclipse.jetty.servlet.ServletHolder.initialize(ServletHolder.java:427) at org.eclipse.jetty.servlet.ServletHandler.initialize(ServletHandler.java:760) at org.eclipse.jetty.servlet.ServletContextHandler.startContext(ServletContextHandler.java:374) at org.eclipse.jetty.webapp.WebAppContext.startWebapp(WebAppContext.java:1497) at org.eclipse.jetty.webapp.WebAppContext.startContext(WebAppContext.java:1459) at org.eclipse.jetty.server.handler.ContextHandler.doStart(ContextHandler.java:848) at org.eclipse.jetty.servlet.ServletContextHandler.doStart(ServletContextHandler.java:287) at org.eclipse.jetty.webapp.WebAppContext.doStart(WebAppContext.java:545) at org.eclipse.jetty.util.component.AbstractLifeCycle.start(AbstractLifeCycle.java:68) at org.eclipse.jetty.util.component.ContainerLifeCycle.start(ContainerLifeCycle.java:138) at org.eclipse.jetty.util.component.ContainerLifeCycle.doStart(ContainerLifeCycle.java:117) at org.eclipse.jetty.server.handler.AbstractHandler.doStart(AbstractHandler.java:113) at org.eclipse.jetty.server.handler.ContextHandlerCollection.doStart(ContextHandlerCollection.java:167) at org.eclipse.jetty.util.component.AbstractLifeCycle.start(AbstractLifeCycle.java:68) at org.eclipse.jetty.util.component.ContainerLifeCycle.start(ContainerLifeCycle.java:138) at org.eclipse.jetty.server.Server.start(Server.java:419) at org.eclipse.jetty.util.component.ContainerLifeCycle.doStart(ContainerLifeCycle.java:108) at org.eclipse.jetty.server.handler.AbstractHandler.doStart(AbstractHandler.java:113) at org.eclipse.jetty.server.Server.doStart(Server.java:386) at org.eclipse.jetty.util.component.AbstractLifeCycle.start(AbstractLifeCycle.java:68) at org.apache.zeppelin.server.ZeppelinServer.main(ZeppelinServer.java:215) WARN [2020-06-04 18:02:26,999] ({main} WebAppContext.java[doStart]:554) - Failed startup of context o.e.j.w.WebAppContext@60611244{zeppelin-web,/,file:///usr/hdp/3.0.1.0-187/zeppelin/webapps/webapp/,UNAVAILABLE}{/usr/hdp/current/zeppelin-server/lib/zeppelin-web-0.8.0.3.0.1.0-187.war} javax.servlet.ServletException: rest@355bd4==org.eclipse.jetty.servlet.NoJspServlet,jsp=rest,order=-1,inst=false at org.eclipse.jetty.servlet.ServletHolder.initServlet(ServletHolder.java:691) at org.eclipse.jetty.servlet.ServletHolder.initialize(ServletHolder.java:427) at org.eclipse.jetty.servlet.ServletHandler.initialize(ServletHandler.java:760) at org.eclipse.jetty.servlet.ServletContextHandler.startContext(ServletContextHandler.java:374) at org.eclipse.jetty.webapp.WebAppContext.startWebapp(WebAppContext.java:1497) at org.eclipse.jetty.webapp.WebAppContext.startContext(WebAppContext.java:1459) at org.eclipse.jetty.server.handler.ContextHandler.doStart(ContextHandler.java:848) at org.eclipse.jetty.servlet.ServletContextHandler.doStart(ServletContextHandler.java:287) at org.eclipse.jetty.webapp.WebAppContext.doStart(WebAppContext.java:545) at org.eclipse.jetty.util.component.AbstractLifeCycle.start(AbstractLifeCycle.java:68) at org.eclipse.jetty.util.component.ContainerLifeCycle.start(ContainerLifeCycle.java:138) at org.eclipse.jetty.util.component.ContainerLifeCycle.doStart(ContainerLifeCycle.java:117) at org.eclipse.jetty.server.handler.AbstractHandler.doStart(AbstractHandler.java:113) at org.eclipse.jetty.server.handler.ContextHandlerCollection.doStart(ContextHandlerCollection.java:167) at org.eclipse.jetty.util.component.AbstractLifeCycle.start(AbstractLifeCycle.java:68) at org.eclipse.jetty.util.component.ContainerLifeCycle.start(ContainerLifeCycle.java:138) at org.eclipse.jetty.server.Server.start(Server.java:419) at org.eclipse.jetty.util.component.ContainerLifeCycle.doStart(ContainerLifeCycle.java:108) at org.eclipse.jetty.server.handler.AbstractHandler.doStart(AbstractHandler.java:113) at org.eclipse.jetty.server.Server.doStart(Server.java:386) at org.eclipse.jetty.util.component.AbstractLifeCycle.start(AbstractLifeCycle.java:68) at org.apache.zeppelin.server.ZeppelinServer.main(ZeppelinServer.java:215) Caused by: A MultiException has 1 exceptions. They are: 1. com.google.gson.JsonSyntaxException: duplicate key: colWidth at org.jvnet.hk2.internal.Utilities.justCreate(Utilities.java:1085) at org.jvnet.hk2.internal.ServiceLocatorImpl.create(ServiceLocatorImpl.java:978) at org.jvnet.hk2.internal.ServiceLocatorImpl.createAndInitialize(ServiceLocatorImpl.java:1082) at org.jvnet.hk2.internal.ServiceLocatorImpl.createAndInitialize(ServiceLocatorImpl.java:1074) at org.glassfish.jersey.inject.hk2.AbstractHk2InjectionManager.createAndInitialize(AbstractHk2InjectionManager.java:213) at org.glassfish.jersey.inject.hk2.ImmediateHk2InjectionManager.createAndInitialize(ImmediateHk2InjectionManager.java:54) at org.glassfish.jersey.server.ApplicationConfigurator.createApplication(ApplicationConfigurator.java:138) at org.glassfish.jersey.server.ApplicationConfigurator.init(ApplicationConfigurator.java:96) at org.glassfish.jersey.server.ApplicationHandler.lambda$initialize$0(ApplicationHandler.java:313) at java.util.Arrays$ArrayList.forEach(Arrays.java:3880) at org.glassfish.jersey.server.ApplicationHandler.initialize(ApplicationHandler.java:313) at org.glassfish.jersey.server.ApplicationHandler.<init>(ApplicationHandler.java:282) at org.glassfish.jersey.servlet.WebComponent.<init>(WebComponent.java:335) at org.glassfish.jersey.servlet.ServletContainer.init(ServletContainer.java:178) at org.glassfish.jersey.servlet.ServletContainer.init(ServletContainer.java:370) at javax.servlet.GenericServlet.init(GenericServlet.java:244) at org.eclipse.jetty.servlet.ServletHolder.initServlet(ServletHolder.java:670) ... 21 more Caused by: com.google.gson.JsonSyntaxException: duplicate key: colWidth at com.google.gson.internal.bind.MapTypeAdapterFactory$Adapter.read(MapTypeAdapterFactory.java:191) at com.google.gson.internal.bind.MapTypeAdapterFactory$Adapter.read(MapTypeAdapterFactory.java:146) at com.google.gson.internal.bind.ReflectiveTypeAdapterFactory$1.read(ReflectiveTypeAdapterFactory.java:93) at com.google.gson.internal.bind.ReflectiveTypeAdapterFactory$Adapter.read(ReflectiveTypeAdapterFactory.java:172) at com.google.gson.internal.bind.TypeAdapterRuntimeTypeWrapper.read(TypeAdapterRuntimeTypeWrapper.java:40) at com.google.gson.internal.bind.CollectionTypeAdapterFactory$Adapter.read(CollectionTypeAdapterFactory.java:81) at com.google.gson.internal.bind.CollectionTypeAdapterFactory$Adapter.read(CollectionTypeAdapterFactory.java:60) at com.google.gson.internal.bind.ReflectiveTypeAdapterFactory$1.read(ReflectiveTypeAdapterFactory.java:93) at com.google.gson.internal.bind.ReflectiveTypeAdapterFactory$Adapter.read(ReflectiveTypeAdapterFactory.java:172) at com.google.gson.Gson.fromJson(Gson.java:791) at com.google.gson.Gson.fromJson(Gson.java:757) at com.google.gson.Gson.fromJson(Gson.java:706) at com.google.gson.Gson.fromJson(Gson.java:678) at org.apache.zeppelin.notebook.Note.fromJson(Note.java:988) at org.apache.zeppelin.notebook.repo.FileSystemNotebookRepo.get(FileSystemNotebookRepo.java:68) at org.apache.zeppelin.notebook.repo.NotebookRepoSync.get(NotebookRepoSync.java:165) at org.apache.zeppelin.notebook.Notebook.loadNoteFromRepo(Notebook.java:505) at org.apache.zeppelin.notebook.Notebook.loadAllNotes(Notebook.java:589) at org.apache.zeppelin.notebook.Notebook.<init>(Notebook.java:123) at org.apache.zeppelin.server.ZeppelinServer.<init>(ZeppelinServer.java:161) at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) at java.lang.reflect.Constructor.newInstance(Constructor.java:423) at org.glassfish.hk2.utilities.reflection.ReflectionHelper.makeMe(ReflectionHelper.java:1375) at org.jvnet.hk2.internal.Utilities.justCreate(Utilities.java:1083) ... 37 more INFO [2020-06-04 18:02:27,022] ({main} AbstractConnector.java[doStart]:289) - Started ServerConnector@5d0e703a{HTTP/1.1,[http/1.1]}{0.0.0.0:9995} INFO [2020-06-04 18:02:27,023] ({main} Server.java[doStart]:411) - Started @21690ms INFO [2020-06-04 18:02:27,023] ({main} ZeppelinServer.java[main]:223) - Done, zeppelin server started           ... View more

I am trying to stream data from a postgres table to hive using nifi but getting the error "Failed to process session due to java.lang.nullpointerException:" I am using nifi1.9.0, hdp 3.1.4.Any help is greatly appreciated.   The full log is as follows->   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) 2019-10-18 12:29:45,810 INFO [Timer-Driven Process Thread-8] o.a.h.streaming.HiveStreamingConnection Creating metastore client for streaming-connection 2019-10-18 12:29:45,810 INFO [Timer-Driven Process Thread-1] o.a.h.streaming.HiveStreamingConnection Creating metastore client for streaming-connection 2019-10-18 12:29:45,810 INFO [Timer-Driven Process Thread-8] o.a.h.hive.metastore.HiveMetaStoreClient Trying to connect to metastore with URI thrift://hmaster.nic.in:9083 2019-10-18 12:29:45,810 INFO [Timer-Driven Process Thread-1] o.a.h.hive.metastore.HiveMetaStoreClient Trying to connect to metastore with URI thrift://hmaster.nic.in:9083 2019-10-18 12:29:45va.lang.NullPointerException: null at org.apache.nifi.processors.hive.PutHive3Streaming.onTrigger(PutHive3Streaming.java:445) 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) 2019-10-18 12:29:57,877 WARN [Timer-Driven Process Thread-6] o.a.n.controller.tasks.ConnectableTask Administratively Yielding PutHive3Streaming[id=b7bd2405-c48b-37b1-afac-5f41cda6bf64] due to uncaught Exception: java.lang.NullPointerException java.lang.NullPointerException: null at org.apache.nifi.processors.hive.PutHive3Streaming.onTrigger(PutHive3Streaming.java:445) 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)               Configuration for Querydatabasetable processor Configuration for Puthive3streaming processor Configuration for the controller service Avroreader Error details   ... View more

I am trying to stream the contents of hdfs into hive using Puthive3streaming processor,but getting the error " Failed to process session due to org.apache.nifi.processor.exception.ProcessException: java.lang.IllegalStateException".Please help  I am using  nifi 1.9.0, hdp 3.1.4   The full Nifi error log is as follows   o.a.n.processors.hive.PutHive3Streaming PutHive3Streaming[id=4cffb87b-016d-1000-ffff-ffffb2a1da7b] Failed to process session due to org.apache.nifi.processor.exception.ProcessException: java.lang.IllegalStateException: StandardFlowFileRecord[uuid=331fed74-91b6-4bcd-9969-ed759b58527f,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1569321274564-294672, container=default, section=784], offset=0, length=33638488],offset=0,name=case_info.avro,size=33638488] already in use for an active callback or an InputStream created by ProcessSession.read(FlowFile) has not been closed: org.apache.nifi.processor.exception.ProcessException: java.lang.IllegalStateException: StandardFlowFileRecord[uuid=331fed74-91b6-4bcd-9969-ed759b58527f,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1569321274564-294672, container=default, section=784], offset=0, length=33638488],offset=0,name=case_info.avro,size=33638488] already in use for an active callback or an InputStream created by ProcessSession.read(FlowFile) has not been closed org.apache.nifi.processor.exception.ProcessException: java.lang.IllegalStateException: StandardFlowFileRecord[uuid=331fed74-91b6-4bcd-9969-ed759b58527f,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1569321274564-294672, container=default, section=784], offset=0, length=33638488],offset=0,name=case_info.avro,size=33638488] already in use for an active callback or an InputStream created by ProcessSession.read(FlowFile) has not been closed at org.apache.nifi.processors.hive.PutHive3Streaming.onTrigger(PutHive3Streaming.java:489) 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) Caused by: java.lang.IllegalStateException: StandardFlowFileRecord[uuid=331fed74-91b6-4bcd-9969-ed759b58527f,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1569321274564-294672, container=default, section=784], offset=0, length=33638488],offset=0,name=case_info.avro,size=33638488] already in use for an active callback or an InputStream created by ProcessSession.read(FlowFile) has not been closed at org.apache.nifi.controller.repository.StandardProcessSession.validateRecordState(StandardProcessSession.java:3126) at org.apache.nifi.controller.repository.StandardProcessSession.validateRecordState(StandardProcessSession.java:3121) at org.apache.nifi.controller.repository.StandardProcessSession.transfer(StandardProcessSession.java:1887) at org.apache.nifi.processors.hive.PutHive3Streaming.onTrigger(PutHive3Streaming.java:434) ... 12 common frames omitted 2019-09-25 10:00:02,265 ERROR [Timer-Driven Process Thread-10] o.a.n.processors.hive.PutHive3Streaming PutHive3Streaming[id=4cffb87b-016d-1000-ffff-ffffb2a1da7b] Failed to process session due to org.apache.nifi.processor.exception.ProcessException: java.lang.IllegalStateException: StandardFlowFileRecord[uuid=5988775d-6bca-4a14-b257-01eb50ec67e2,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1569321274726-294673, container=default, section=785], offset=0, length=33638488],offset=0,name=case_info,size=33638488] already in use for an active callback or an InputStream created by ProcessSession.read(FlowFile) has not been closed: org.apache.nifi.processor.exception.ProcessException: java.lang.IllegalStateException: StandardFlowFileRecord[uuid=5988775d-6bca-4a14-b257-01eb50ec67e2,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1569321274726-294673, container=default, section=785], offset=0, length=33638488],offset=0,name=case_info,size=33638488] already in use for an active callback or an InputStream created by ProcessSession.read(FlowFile) has not been closed org.apache.nifi.processor.exception.ProcessException: java.lang.IllegalStateException: StandardFlowFileRecord[uuid=5988775d-6bca-4a14-b257-01eb50ec67e2,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1569321274726-294673, container=default, section=785], offset=0, length=33638488],offset=0,name=case_info,size=33638488] already in use for an active callback or an InputStream created by ProcessSession.read(FlowFile) has not been closed at org.apache.nifi.processors.hive.PutHive3Streaming.onTrigger(PutHive3Streaming.java:489)   Below are the snapshots of pipeline and configs of puthivestreaming and convert csv to avro processors   Config for convert csv to avro processor config for puthive3streaming processor config for infer avro schema processor   ... View more