Member since
02-04-2021
12
Posts
0
Kudos Received
0
Solutions
09-07-2023
12:32 AM
HI ALL, i am try to read multiple files from particular location. Logs will generate every 1 minute , it will create new file. i am getting below error. ERROR [Timer-Driven Process Thread-3] o.a.nifi.processors.standard.TailFile TailFile[id=3f714fb2-72eb-1376-037b-167383110223] Failed to properly initialize Processor. If still scheduled to run, NiFi will attempt to initialize and run the Processor again after the 'Administrative Yield Duration' has elapsed. Failure is due to java.util.regex.PatternSyntaxException: Unknown character property name {In/IsY} near index 14 D:\Softwares\PYTHON-YOUTUBE\SIMULATION\modbus_logs\Q\\E^modbus_log\.\d{4}-\d{2}-\d{2}_\d{2}-\d{2}$ ^ java.util.regex.PatternSyntaxException: Unknown character property name {In/IsY} near index 14 D:\Softwares\PYTHON-YOUTUBE\SIMULATION\modbus_logs\Q\\E^modbus_log\.\d{4}-\d{2}-\d{2}_\d{2}-\d{2}$ ^ at java.base/java.util.regex.Pattern.error(Pattern.java:2027) at java.base/java.util.regex.Pattern.family(Pattern.java:2916) at java.base/java.util.regex.Pattern.sequence(Pattern.java:2155) at java.base/java.util.regex.Pattern.expr(Pattern.java:2068) at java.base/java.util.regex.Pattern.compile(Pattern.java:1782) at java.base/java.util.regex.Pattern.<init>(Pattern.java:1428) at java.base/java.util.regex.Pattern.compile(Pattern.java:1068) at org.apache.nifi.processors.standard.TailFile.getFilesToTail(TailFile.java:525) at org.apache.nifi.processors.standard.TailFile.lookup(TailFile.java:386) at org.apache.nifi.processors.standard.TailFile.recoverState(TailFile.java:410) at jdk.internal.reflect.GeneratedMethodAccessor1142.invoke(Unknown Source) at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.base/java.lang.reflect.Method.invoke(Method.java:566) at org.apache.nifi.util.ReflectionUtils.invokeMethodsWithAnnotations(ReflectionUtils.java:145) at org.apache.nifi.util.ReflectionUtils.invokeMethodsWithAnnotations(ReflectionUtils.java:133) at org.apache.nifi.util.ReflectionUtils.invokeMethodsWithAnnotations(ReflectionUtils.java:78) at org.apache.nifi.util.ReflectionUtils.invokeMethodsWithAnnotation(ReflectionUtils.java:55) at org.apache.nifi.controller.StandardProcessorNode.lambda$initiateStart$8(StandardProcessorNode.java:1736) at org.apache.nifi.engine.FlowEngine$3.call(FlowEngine.java:123) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:834) How to resolve this issue. in modbus_logs dir file name are like modbus_log.2023-09-06_16-16,modbus_log.2023-09-06_16-17,modbus_log.2023-09-06_16-18,modbus_log.2023-09-06_16-19.
... View more
Labels:
- Labels:
-
Apache NiFi
09-06-2023
09:10 AM
Hi all, Putelasticsearchhttp delete and upsert is not working. Fetchelasticsearch is giving error code 400. Thanks Kumar
... View more
Labels:
- Labels:
-
Apache NiFi
10-06-2022
05:11 AM
@Green_ wrote: I've run into similar issues and haven't reached a clear conclusion either. It seems your have very high heap usage which might potentially be relevant. Once we stop nifi then only it is reducing..there is no data in queue but it is in high heap only.. unable to understanding why it is not reducing automatically..
... View more
10-05-2022
10:06 AM
Hi, we are running nifi 1.11.4 version .we had resource issue before recently RAM and CPU core increase in server. we changed bootstrap.conf file java.arg.2=-Xms20g java.arg.3=-Xmx40g Total 1100 processors are running in nifi, around 150+ processor disable (in disable processors have queue with 3GB). After restart nifi it is working fine for sometime ,after that Nifi ui response is too slowly. Even for refresh option it is taking 1 minute +. After sometime we are unable to access nifi ui. it is not loading anything but in server nifi is running telnet is working fine. os: redhat RAM : 64 GB CPU : 16GB java:1.8 unable to find the actually issue. nifi-api/system-diagnostics {"systemDiagnostics":{"aggregateSnapshot":{"totalNonHeap":"366 MB","totalNonHeapBytes":383778816,"usedNonHeap":"273.25 MB","usedNonHeapBytes":286525256,"freeNonHeap":"92.75 MB","freeNonHeapBytes":97253560,"maxNonHeap":"-1 bytes","maxNonHeapBytes":-1,"totalHeap":"38.34 GB","totalHeapBytes":41163423744,"usedHeap":"35.97 GB","usedHeapBytes":38624675432,"freeHeap":"2.36 GB","freeHeapBytes":2538748312,"maxHeap":"38.34 GB","maxHeapBytes":41163423744,"heapUtilization":"94.0%","availableProcessors":20,"processorLoadAverage":14.13,"totalThreads":338,"daemonThreads":155,"uptime":"91:55:36.089","flowFileRepositoryStorageUsage":{"freeSpace":"145.38 GB","totalSpace":"300 GB","usedSpace":"154.62 GB","freeSpaceBytes":156101574656,"totalSpaceBytes":322122547200,"usedSpaceBytes":166020972544,"utilization":"52.0%"},"contentRepositoryStorageUsage":[{"identifier":"default","freeSpace":"145.38 GB","totalSpace":"300 GB","usedSpace":"154.62 GB","freeSpaceBytes":156101574656,"totalSpaceBytes":322122547200,"usedSpaceBytes":166020972544,"utilization":"52.0%"}],"provenanceRepositoryStorageUsage":[{"identifier":"default","freeSpace":"145.38 GB","totalSpace":"300 GB","usedSpace":"154.62 GB","freeSpaceBytes":156101574656,"totalSpaceBytes":322122547200,"usedSpaceBytes":166020972544,"utilization":"52.0%"}],"garbageCollection":[{"name":"PS Scavenge","collectionCount":2458,"collectionTime":"00:52:34.376","collectionMillis":3154376},{"name":"PS MarkSweep","collectionCount":4935,"collectionTime":"64:44:42.397","collectionMillis":233082397}],"statsLastRefreshed":"10:40:31 IST","versionInfo":{"niFiVersion":"1.11.4","javaVendor":"Oracle Corporation","javaVersion":"1.8.0_242","osName":"Linux","osVersion":"3.10.0-1062.12.1.el7.x86_64","osArchitecture":"amd64","buildTag":"nifi-1.11.4-RC1","buildTimestamp":"03/18/2020 12:42:54 IST"}}}}
... View more
Labels:
- Labels:
-
Apache NiFi
09-27-2022
01:21 AM
Nifi stop working.error Unable to start Flow Controller. Nifi version : 1.11.4 java :1.8 os :Windows Nifi application was running fine. Suddenly it is stopped, try to restart it but it is giving same error. Nifi is running single node , we are not using zookeeper and nifi cluster. 2022-09-21 11:38:21,130 INFO [main] org.wali.MinimalLockingWriteAheadLog org.wali.MinimalLockingWriteAheadLog@38f4a641 checkpointed with 1 Records and 0 Swap Files in 119 milliseconds (Stop-the-world time = 30 milliseconds, Clear Edit Logs time = 27 millis), max Transaction ID 40732 2022-09-21 11:38:21,163 INFO [main] o.apache.nifi.controller.FlowController Not enabling RAW Socket Site-to-Site functionality because nifi.remote.input.socket.port is not set 2022-09-21 11:38:21,194 INFO [main] o.a.n.w.c.ApplicationStartupContextListener Starting Flow Controller... 2022-09-21 11:38:21,201 INFO [main] o.apache.nifi.controller.FlowController Initiated graceful shutdown of flow controller...waiting up to 10 seconds 2022-09-21 11:38:22,159 INFO [main] o.apache.nifi.controller.FlowController Controller has been terminated successfully. 2022-09-21 11:38:22,428 WARN [main] org.eclipse.jetty.webapp.WebAppContext Failed startup of context o.e.j.w.WebAppContext@2b91004a{nifi-api,/nifi-api,file:///C:/ProgramData/NodeSense/nifi-1.11.4/work/jetty/nifi-web-api-1.11.4.war/webapp/,UNAVAILABLE}{.\work\nar\framework\nifi-framework-nar-1.11.4.nar-unpacked\NAR-INF\bundled-dependencies\nifi-web-api-1.11.4.war} org.apache.nifi.web.NiFiCoreException: Unable to start Flow Controller. at org.apache.nifi.web.contextlistener.ApplicationStartupContextListener.contextInitialized(ApplicationStartupContextListener.java:88) at org.eclipse.jetty.server.handler.ContextHandler.callContextInitialized(ContextHandler.java:959) at org.eclipse.jetty.servlet.ServletContextHandler.callContextInitialized(ServletContextHandler.java:553) at org.eclipse.jetty.server.handler.ContextHandler.startContext(ContextHandler.java:924) at org.eclipse.jetty.servlet.ServletContextHandler.startContext(ServletContextHandler.java:365) 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:854) at org.eclipse.jetty.servlet.ServletContextHandler.doStart(ServletContextHandler.java:278) 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:167) at org.eclipse.jetty.util.component.ContainerLifeCycle.doStart(ContainerLifeCycle.java:119) at org.eclipse.jetty.server.handler.AbstractHandler.doStart(AbstractHandler.java:113) at org.eclipse.jetty.util.component.AbstractLifeCycle.start(AbstractLifeCycle.java:68) at org.eclipse.jetty.util.component.ContainerLifeCycle.start(ContainerLifeCycle.java:167) at org.eclipse.jetty.util.component.ContainerLifeCycle.doStart(ContainerLifeCycle.java:110) at org.eclipse.jetty.server.handler.AbstractHandler.doStart(AbstractHandler.java:113) at org.eclipse.jetty.server.handler.gzip.GzipHandler.doStart(GzipHandler.java:406) at org.eclipse.jetty.util.component.AbstractLifeCycle.start(AbstractLifeCycle.java:68) at org.eclipse.jetty.util.component.ContainerLifeCycle.start(ContainerLifeCycle.java:167) at org.eclipse.jetty.util.component.ContainerLifeCycle.doStart(ContainerLifeCycle.java:119) at org.eclipse.jetty.server.handler.AbstractHandler.doStart(AbstractHandler.java:113) at org.eclipse.jetty.util.component.AbstractLifeCycle.start(AbstractLifeCycle.java:68) at org.eclipse.jetty.util.component.ContainerLifeCycle.start(ContainerLifeCycle.java:167) at org.eclipse.jetty.util.component.ContainerLifeCycle.doStart(ContainerLifeCycle.java:119) at org.eclipse.jetty.server.handler.AbstractHandler.doStart(AbstractHandler.java:113) at org.eclipse.jetty.util.component.AbstractLifeCycle.start(AbstractLifeCycle.java:68) at org.eclipse.jetty.util.component.ContainerLifeCycle.start(ContainerLifeCycle.java:167) at org.eclipse.jetty.server.Server.start(Server.java:418) at org.eclipse.jetty.util.component.ContainerLifeCycle.doStart(ContainerLifeCycle.java:110) at org.eclipse.jetty.server.handler.AbstractHandler.doStart(AbstractHandler.java:113) at org.eclipse.jetty.server.Server.doStart(Server.java:382) at org.eclipse.jetty.util.component.AbstractLifeCycle.start(AbstractLifeCycle.java:68) at org.apache.nifi.web.server.JettyServer.start(JettyServer.java:952) at org.apache.nifi.NiFi.<init>(NiFi.java:158) at org.apache.nifi.NiFi.<init>(NiFi.java:72) at org.apache.nifi.NiFi.main(NiFi.java:301) Caused by: java.util.zip.ZipException: invalid distance too far back at java.util.zip.InflaterInputStream.read(Unknown Source) at java.util.zip.GZIPInputStream.read(Unknown Source) at java.io.FilterInputStream.read(Unknown Source) at org.apache.nifi.util.file.FileUtils.copy(FileUtils.java:303) at org.apache.nifi.controller.StandardFlowService.copyCurrentFlow(StandardFlowService.java:1060) at org.apache.nifi.controller.StandardFlowService.loadFromBytes(StandardFlowService.java:796) at org.apache.nifi.controller.StandardFlowService.load(StandardFlowService.java:557) at org.apache.nifi.web.contextlistener.ApplicationStartupContextListener.contextInitialized(ApplicationStartupContextListener.java:72) ... 37 common frames omitted 2022-09-21 11:38:22,661 INFO [main] o.e.j.a.AnnotationConfiguration Scanning elapsed time=49ms 2022-09-21 11:38:22,663 INFO [main] o.e.j.s.h.C._nifi_content_viewer No Spring WebApplicationInitializer types detected on classpath 2022-09-21 11:38:22,687 INFO [main] o.e.jetty.server.handler.ContextHandler Started o.e.j.w.WebAppContext@20ccf40b{nifi-content-viewer,/nifi-content-viewer,file:///C:/ProgramData/NodeSense/nifi-1.11.4/work/jetty/nifi-web-content-viewer-1.11.4.war/webapp/,AVAILABLE}{.\work\nar\framework\nifi-framework-nar-1.11.4.nar-unpacked\NAR-INF\bundled-dependencies\nifi-web-content-viewer-1.11.4.war} 2022-09-21 11:38:22,848 INFO [main] o.e.j.a.AnnotationConfiguration Scanning elapsed time=10ms 2022-09-21 11:38:22,850 WARN [main] o.e.j.webapp.StandardDescriptorProcessor Duplicate mapping from / to default 2022-09-21 11:38:22,850 INFO [main] o.e.j.s.h.ContextHandler._nifi_docs No Spring WebApplicationInitializer types detected on classpath 2022-09-21 11:38:22,867 INFO [main] o.e.jetty.server.handler.ContextHandler Started o.e.j.w.WebAppContext@2fb3536e{nifi-docs,/nifi-docs,file:///C:/ProgramData/NodeSense/nifi-1.11.4/work/jetty/nifi-web-docs-1.11.4.war/webapp/,AVAILABLE}{.\work\nar\framework\nifi-framework-nar-1.11.4.nar-unpacked\NAR-INF\bundled-dependencies\nifi-web-docs-1.11.4.war} 2022-09-21 11:38:22,901 INFO [main] o.e.j.a.AnnotationConfiguration Scanning elapsed time=8ms 2022-09-21 11:38:22,903 INFO [main] o.e.j.server.handler.ContextHandler._ No Spring WebApplicationInitializer types detected on classpath 2022-09-21 11:38:22,917 INFO [main] o.e.jetty.server.handler.ContextHandler Started o.e.j.w.WebAppContext@169e6180{nifi-error,/,file:///C:/ProgramData/NodeSense/nifi-1.11.4/work/jetty/nifi-web-error-1.11.4.war/webapp/,AVAILABLE}{.\work\nar\framework\nifi-framework-nar-1.11.4.nar-unpacked\NAR-INF\bundled-dependencies\nifi-web-error-1.11.4.war} 2022-09-21 11:38:22,935 INFO [main] o.eclipse.jetty.server.AbstractConnector Started ServerConnector@f79e{HTTP/1.1,[http/1.1]}{0.0.0.0:8080} 2022-09-21 11:38:22,935 INFO [main] org.eclipse.jetty.server.Server Started @31402ms 2022-09-21 11:38:22,935 WARN [main] org.apache.nifi.web.server.JettyServer Failed to start web server,shutting down. org.apache.nifi.web.NiFiCoreException: Unable to start Flow Controller. at org.apache.nifi.web.contextlistener.ApplicationStartupContextListener.contextInitialized(ApplicationStartupContextListener.java:88) at org.eclipse.jetty.server.handler.ContextHandler.callContextInitialized(ContextHandler.java:959)
... View more
Labels:
- Labels:
-
Apache NiFi
10-28-2021
12:56 AM
Need to use apache-zookeeper for external one. Once you use apache-zookeeper it will work. https://zookeeper.apache.org/releases.html
... View more
02-06-2021
12:15 AM
Please help on this
... View more
02-04-2021
03:56 AM
We are using ubuntu:20.04 OS. Any configuration missed out? Any solution for this issue. Zookeeper cluster is working well.when we try to use zookeeper in nifi at the point of time nifi is giving error. zookeeper configuration : same configuration is available in 3 servers tickTime=2000 dataDir=/opt/zookeeper/data clientPort=2181 maxClientCnxns=60 initLimit=10 syncLimit=5 server.1=nifi-zoo:2888:3888 server.2=nifi-zoo-2:2888:3888 server.3=nifi-zoo-3:2888:3888 nifi configuration nifi-config-1 # State Management # #################### nifi.state.management.configuration.file=./conf/state-management.xml nifi.state.management.provider.local=local-provider nifi.state.management.provider.cluster=zk-provider nifi.state.management.embedded.zookeeper.start=false nifi.state.management.embedded.zookeeper.properties=./conf/zookeeper.properties # Site to Site properties nifi.remote.input.host=nifi-zoo nifi.remote.input.secure=false nifi.remote.input.socket.port= nifi.remote.input.http.enabled=true nifi.remote.input.http.transaction.ttl=30 sec nifi.remote.contents.cache.expiration=30 secs # web properties # nifi.web.http.host=nifi-zoo nifi.web.http.port=8080 nifi.web.http.network.interface.default= nifi.web.https.host= nifi.web.https.port= nifi.web.https.network.interface.default= nifi.web.jetty.working.directory=./work/jetty nifi.web.jetty.threads=400 nifi.web.max.header.size=16 KB nifi.web.proxy.context.path= nifi.web.proxy.host= nifi.web.max.content.size= nifi.web.max.requests.per.second=30000 nifi.web.should.send.server.version=true # cluster node properties (only configure for cluster nodes) # nifi.cluster.is.node=true nifi.cluster.node.address=nifi-zoo nifi.cluster.node.protocol.port=12000 nifi.cluster.node.protocol.threads=20 nifi.cluster.node.protocol.max.threads=50 nifi.cluster.node.event.history.size=25 nifi.cluster.node.connection.timeout=60 sec nifi.cluster.node.read.timeout=60 sec nifi.cluster.node.max.concurrent.requests=100 nifi.cluster.firewall.file= nifi.cluster.flow.election.max.wait.time=30 sec nifi.cluster.flow.election.max.candidates= # cluster load balancing properties # nifi.cluster.load.balance.host= nifi.cluster.load.balance.port=6342 nifi.cluster.load.balance.connections.per.node=1 nifi.cluster.load.balance.max.thread.count=8 nifi.cluster.load.balance.comms.timeout=30 sec # zookeeper properties, used for cluster management # nifi.zookeeper.connect.string=nifi-zoo:2181,nifi-zoo-2:2181,nifi-zoo-3:2181 nifi.zookeeper.connect.timeout=60 secs nifi.zookeeper.session.timeout=60 secs nifi.zookeeper.root.node=/nifi nifi-config-2 # State Management # #################### nifi.state.management.configuration.file=./conf/state-management.xml nifi.state.management.provider.local=local-provider nifi.state.management.provider.cluster=zk-provider nifi.state.management.embedded.zookeeper.start=false nifi.state.management.embedded.zookeeper.properties=./conf/zookeeper.properties # Site to Site properties nifi.remote.input.host=nifi-zoo-2 nifi.remote.input.secure=false nifi.remote.input.socket.port= nifi.remote.input.http.enabled=true nifi.remote.input.http.transaction.ttl=30 sec nifi.remote.contents.cache.expiration=30 secs # web properties # nifi.web.http.host=nifi-zoo-2 nifi.web.http.port=8080 nifi.web.http.network.interface.default= nifi.web.https.host= nifi.web.https.port= nifi.web.https.network.interface.default= nifi.web.jetty.working.directory=./work/jetty nifi.web.jetty.threads=400 nifi.web.max.header.size=16 KB nifi.web.proxy.context.path= nifi.web.proxy.host= nifi.web.max.content.size= nifi.web.max.requests.per.second=30000 nifi.web.should.send.server.version=true # cluster node properties (only configure for cluster nodes) # nifi.cluster.is.node=true nifi.cluster.node.address=nifi-zoo-2 nifi.cluster.node.protocol.port=12000 nifi.cluster.node.protocol.threads=20 nifi.cluster.node.protocol.max.threads=50 nifi.cluster.node.event.history.size=25 nifi.cluster.node.connection.timeout=60 sec nifi.cluster.node.read.timeout=60 sec nifi.cluster.node.max.concurrent.requests=100 nifi.cluster.firewall.file= nifi.cluster.flow.election.max.wait.time=30 sec nifi.cluster.flow.election.max.candidates= # cluster load balancing properties # nifi.cluster.load.balance.host= nifi.cluster.load.balance.port=6342 nifi.cluster.load.balance.connections.per.node=1 nifi.cluster.load.balance.max.thread.count=8 nifi.cluster.load.balance.comms.timeout=30 sec # zookeeper properties, used for cluster management # nifi.zookeeper.connect.string=nifi-zoo:2181,nifi-zoo-2:2181,nifi-zoo-3:2181 nifi.zookeeper.connect.timeout=60 secs nifi.zookeeper.session.timeout=60 secs nifi.zookeeper.root.node=/nifi nifi-config-3 # State Management # #################### nifi.state.management.configuration.file=./conf/state-management.xml nifi.state.management.provider.local=local-provider nifi.state.management.provider.cluster=zk-provider nifi.state.management.embedded.zookeeper.start=false nifi.state.management.embedded.zookeeper.properties=./conf/zookeeper.properties # Site to Site properties nifi.remote.input.host=nifi-zoo-3 nifi.remote.input.secure=false nifi.remote.input.socket.port= nifi.remote.input.http.enabled=true nifi.remote.input.http.transaction.ttl=30 sec nifi.remote.contents.cache.expiration=30 secs # web properties # nifi.web.http.host=nifi-zoo-3 nifi.web.http.port=8080 nifi.web.http.network.interface.default= nifi.web.https.host= nifi.web.https.port= nifi.web.https.network.interface.default= nifi.web.jetty.working.directory=./work/jetty nifi.web.jetty.threads=400 nifi.web.max.header.size=16 KB nifi.web.proxy.context.path= nifi.web.proxy.host= nifi.web.max.content.size= nifi.web.max.requests.per.second=30000 nifi.web.should.send.server.version=true # cluster node properties (only configure for cluster nodes) # nifi.cluster.is.node=true nifi.cluster.node.address=nifi-zoo-3 nifi.cluster.node.protocol.port=12000 nifi.cluster.node.protocol.threads=20 nifi.cluster.node.protocol.max.threads=50 nifi.cluster.node.event.history.size=25 nifi.cluster.node.connection.timeout=60 sec nifi.cluster.node.read.timeout=60 sec nifi.cluster.node.max.concurrent.requests=100 nifi.cluster.firewall.file= nifi.cluster.flow.election.max.wait.time=30 sec nifi.cluster.flow.election.max.candidates= # cluster load balancing properties # nifi.cluster.load.balance.host= nifi.cluster.load.balance.port=6342 nifi.cluster.load.balance.connections.per.node=1 nifi.cluster.load.balance.max.thread.count=8 nifi.cluster.load.balance.comms.timeout=30 sec # zookeeper properties, used for cluster management # nifi.zookeeper.connect.string=nifi-zoo:2181,nifi-zoo-2:2181,nifi-zoo-3:2181 nifi.zookeeper.connect.timeout=60 secs nifi.zookeeper.session.timeout=60 secs nifi.zookeeper.root.node=/nifi NIFI ERROR: 2021-02-04 11:12:47,783 INFO [Curator-ConnectionStateManager-0] o.a.n.c.l.e.CuratorLeaderElectionManager org.apache.nifi.controller.leader.election.CuratorLeaderElectionManager$ElectionListener@5e3bcc78 Connection State changed to SUSPENDED 2021-02-04 11:12:49,106 INFO [main-EventThread] o.a.c.f.state.ConnectionStateManager State change: RECONNECTED 2021-02-04 11:12:49,107 INFO [Curator-ConnectionStateManager-0] o.a.n.c.l.e.CuratorLeaderElectionManager org.apache.nifi.controller.leader.election.CuratorLeaderElectionManager$ElectionListener@5a0453e0 Connection State changed to RECONNECTED 2021-02-04 11:12:49,107 INFO [Curator-ConnectionStateManager-0] o.a.n.c.l.e.CuratorLeaderElectionManager org.apache.nifi.controller.leader.election.CuratorLeaderElectionManager$ElectionListener@5e3bcc78 Connection State changed to RECONNECTED 2021-02-04 11:12:49,209 INFO [main-EventThread] o.a.c.f.state.ConnectionStateManager State change: SUSPENDED 2021-02-04 11:12:49,209 INFO [Curator-ConnectionStateManager-0] o.a.n.c.l.e.CuratorLeaderElectionManager org.apache.nifi.controller.leader.election.CuratorLeaderElectionManager$ElectionListener@5a0453e0 Connection State changed to SUSPENDED 2021-02-04 11:12:49,209 INFO [Curator-ConnectionStateManager-0] o.a.n.c.l.e.CuratorLeaderElectionManager org.apache.nifi.controller.leader.election.CuratorLeaderElectionManager$ElectionListener@5e3bcc78 Connection State changed to SUSPENDED 2021-02-04 11:12:49,506 INFO [main-EventThread] o.a.c.f.state.ConnectionStateManager State change: RECONNECTED 2021-02-04 11:12:49,507 INFO [Curator-ConnectionStateManager-0] o.a.n.c.l.e.CuratorLeaderElectionManager org.apache.nifi.controller.leader.election.CuratorLeaderElectionManager$ElectionListener@5a0453e0 Connection State changed to RECONNECTED 2021-02-04 11:12:49,507 INFO [Curator-ConnectionStateManager-0] o.a.n.c.l.e.CuratorLeaderElectionManager org.apache.nifi.controller.leader.election.CuratorLeaderElectionManager$ElectionListener@5e3bcc78 Connection State changed to RECONNECTED 2021-02-04 11:12:49,508 INFO [main-EventThread] o.a.c.f.state.ConnectionStateManager State change: SUSPENDED 2021-02-04 11:12:49,508 INFO [Curator-ConnectionStateManager-0] o.a.n.c.l.e.CuratorLeaderElectionManager org.apache.nifi.controller.leader.election.CuratorLeaderElectionManager$ElectionListener@5a0453e0 Connection State changed to SUSPENDED 2021-02-04 11:12:49,508 INFO [Curator-ConnectionStateManager-0] o.a.n.c.l.e.CuratorLeaderElectionManager org.apache.nifi.controller.leader.election.CuratorLeaderElectionManager$ElectionListener@5e3bcc78 Connection State changed to SUSPENDED 2021-02-04 11:12:49,508 ERROR [main-EventThread] o.a.c.f.imps.CuratorFrameworkImpl Background operation retry gave up org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss at org.apache.zookeeper.KeeperException.create(KeeperException.java:102) at org.apache.curator.framework.imps.CuratorFrameworkImpl.checkBackgroundRetry(CuratorFrameworkImpl.java:862) at org.apache.curator.framework.imps.CuratorFrameworkImpl.processBackgroundOperation(CuratorFrameworkImpl.java:647) at org.apache.curator.framework.imps.WatcherRemovalFacade.processBackgroundOperation(WatcherRemovalFacade.java:152) at org.apache.curator.framework.imps.FindAndDeleteProtectedNodeInBackground$2.processResult(FindAndDeleteProtectedNodeInBackground.java:104) at org.apache.zookeeper.ClientCnxn$EventThread.processEvent(ClientCnxn.java:630) at org.apache.zookeeper.ClientCnxn$EventThread.run(ClientCnxn.java:510) 2021-02-04 11:12:50,214 INFO [main-EventThread] o.a.c.f.state.ConnectionStateManager State change: RECONNECTED 2021-02-04 11:12:50,214 INFO [Curator-ConnectionStateManager-0] o.a.n.c.l.e.CuratorLeaderElectionManager org.apache.nifi.controller.leader.election.CuratorLeaderElectionManager$ElectionListener@5a0453e0 Connection State changed to RECONNECTED 2021-02-04 11:12:50,214 INFO [Curator-ConnectionStateManager-0] o.a.n.c.l.e.CuratorLeaderElectionManager org.apache.nifi.controller.leader.election.CuratorLeaderElectionManager$ElectionListener@5e3bcc78 Connection State changed to RECONNECTED 2021-02-04 11:12:50,316 INFO [main-EventThread] o.a.c.f.state.ConnectionStateManager State change: SUSPENDED 2021-02-04 11:12:50,316 INFO [Curator-ConnectionStateManager-0] o.a.n.c.l.e.CuratorLeaderElectionManager org.apache.nifi.controller.leader.election.CuratorLeaderElectionManager$ElectionListener@5a0453e0 Connection State changed to SUSPENDED 2021-02-04 11:12:50,316 INFO [Curator-ConnectionStateManager-0] o.a.n.c.l.e.CuratorLeaderElectionManager org.apache.nifi.controller.leader.election.CuratorLeaderElectionManager$ElectionListener@5e3bcc78 Connection State changed to SUSPENDED 2021-02-04 11:12:50,434 INFO [main-EventThread] o.a.c.f.state.ConnectionStateManager State change: RECONNECTED 2021-02-04 11:12:50,434 INFO [Curator-ConnectionStateManager-0] o.a.n.c.l.e.CuratorLeaderElectionManager org.apache.nifi.controller.leader.election.CuratorLeaderElectionManager$ElectionListener@5a0453e0 Connection State changed to RECONNECTED 2021-02-04 11:12:50,434 INFO [Curator-ConnectionStateManager-0] o.a.n.c.l.e.CuratorLeaderElectionManager org.apache.nifi.controller.leader.election.CuratorLeaderElectionManager$ElectionListener@5e3bcc78 Connection State changed to RECONNECTED 2021-02-04 11:12:50,536 INFO [main-EventThread] o.a.c.f.state.ConnectionStateManager State change: SUSPENDED 2021-02-04 11:12:50,536 INFO [Curator-ConnectionStateManager-0] o.a.n.c.l.e.CuratorLeaderElectionManager org.apache.nifi.controller.leader.election.CuratorLeaderElectionManager$ElectionListener@5a0453e0 Connection State changed to SUSPENDED 2021-02-04 11:12:50,536 ERROR [main-EventThread] o.a.c.f.imps.CuratorFrameworkImpl Background operation retry gave up org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss at org.apache.zookeeper.KeeperException.create(KeeperException.java:102) at org.apache.curator.framework.imps.CuratorFrameworkImpl.checkBackgroundRetry(CuratorFrameworkImpl.java:862) at org.apache.curator.framework.imps.CuratorFrameworkImpl.processBackgroundOperation(CuratorFrameworkImpl.java:647) at org.apache.curator.framework.imps.WatcherRemovalFacade.processBackgroundOperation(WatcherRemovalFacade.java:152) at org.apache.curator.framework.imps.GetConfigBuilderImpl$2.processResult(GetConfigBuilderImpl.java:222) at org.apache.zookeeper.ClientCnxn$EventThread.processEvent(ClientCnxn.java:601) at org.apache.zookeeper.ClientCnxn$EventThread.run(ClientCnxn.java:510) 2021-02-04 11:12:50,536 INFO [Curator-ConnectionStateManager-0] o.a.n.c.l.e.CuratorLeaderElectionManager org.apache.nifi.controller.leader.election.CuratorLeaderElectionManager$ElectionListener@5e3bcc78 Connection State changed to SUSPENDED 2021-02-04 11:12:51,990 INFO [main-EventThread] o.a.c.f.state.ConnectionStateManager State change: RECONNECTED 2021-02-04 11:12:51,990 INFO [Curator-ConnectionStateManager-0] o.a.n.c.l.e.CuratorLeaderElectionManager org.apache.nifi.controller.leader.election.CuratorLeaderElectionManager$ElectionListener@5a0453e0 Connection State changed to RECONNECTED 2021-02-04 11:12:51,990 INFO [Curator-ConnectionStateManager-0] o.a.n.c.l.e.CuratorLeaderElectionManager org.apache.nifi.controller.leader.election.CuratorLeaderElectionManager$ElectionListener@5e3bcc78 Connection State changed to RECONNECTED 2021-02-04 11:12:51,991 WARN [Clustering Tasks Thread-2] o.apache.nifi.controller.FlowController Failed to send heartbeat due to: org.apache.nifi.cluster.protocol.ProtocolException: Cannot send heartbeat because there is no Cluster Coordinator currently elected 2021-02-04 11:12:52,092 INFO [main-EventThread] o.a.c.f.state.ConnectionStateManager State change: SUSPENDED 2021-02-04 11:12:52,093 INFO [Curator-ConnectionStateManager-0] o.a.n.c.l.e.CuratorLeaderElectionManager org.apache.nifi.controller.leader.election.CuratorLeaderElectionManager$ElectionListener@5a0453e0 Connection State changed to SUSPENDED 2021-02-04 11:12:52,093 INFO [Curator-ConnectionStateManager-0] o.a.n.c.l.e.CuratorLeaderElectionManager org.apache.nifi.controller.leader.election.CuratorLeaderElectionManager$ElectionListener@5e3bcc78 Connection State changed to SUSPENDED
... View more
Labels:
- Labels:
-
Apache NiFi
-
Apache Zookeeper