Member since
09-24-2019
8
Posts
0
Kudos Received
0
Solutions
06-05-2020
12:13 AM
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
06-04-2020
07:16 AM
hello a new thread has been created and you have been tagged in it with heading Zeppelin UI returns 503 error everytime
... View more
05-14-2020
12:58 AM
Does Major compaction in Hbase lead to regions merging or the regions are merged only manually by applying merge command? Please help @Manoj69 @jsensharma
... View more
10-18-2019
12:02 AM
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
Labels:
09-24-2019
10:36 PM
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