Re: Setting basic NiFi network problem

2017-05-26 Thread Bryan Rosander
; doWorkLoop(LeaderSelector.java:441)
> at
> org.apache.curator.framework.recipes.leader.LeaderSelector.
> access$100(LeaderSelector.java:64)
> at
> org.apache.curator.framework.recipes.leader.LeaderSelector$
> 2.call(LeaderSelector.java:245)
> at
> org.apache.curator.framework.recipes.leader.LeaderSelector$
> 2.call(LeaderSelector.java:239)
> at java.util.concurrent.FutureTask.run(FutureTask.java:266)
> at java.util.concurrent.Executors$RunnableAdapter.
> call(Executors.java:511)
> at java.util.concurrent.FutureTask.run(FutureTask.java:266)
> at java.util.concurrent.Executors$RunnableAdapter.
> call(Executors.java:511)
> at java.util.concurrent.FutureTask.run(FutureTask.java:266)
> at
> java.util.concurrent.ScheduledThreadPoolExecutor$
> ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
> at
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(
> ScheduledThreadPoolExecutor.java:293)
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(
> ThreadPoolExecutor.java:1142)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(
> ThreadPoolExecutor.java:617)
> at java.lang.Thread.run(Thread.java:748)
> 2017-05-26 14:54:09,669 INFO [main] o.a.n.c.l.e.
> CuratorLeaderElectionManager
> CuratorLeaderElectionManager[stopped=true] stopped and closed
> 2017-05-26 14:54:09,669 INFO [main] o.a.n.c.c.h.AbstractHeartbeatMonitor
> Heartbeat Monitor stopped
> 2017-05-26 14:54:09,670 INFO [main] o.apache.nifi.controller.
> FlowController
> Initiated immediate shutdown of flow controller...
> 2017-05-26 14:54:09,672 ERROR [/127.0.0.1:3888]
> o.a.z.server.quorum.QuorumCnxManager Exception while listening
> java.net.SocketException: Socket closed
> at java.net.PlainSocketImpl.socketAccept(Native Method)
> at
> java.net.AbstractPlainSocketImpl.accept(AbstractPlainSocketImpl.java:409)
> at java.net.ServerSocket.implAccept(ServerSocket.java:545)
> at java.net.ServerSocket.accept(ServerSocket.java:513)
> at
> org.apache.zookeeper.server.quorum.QuorumCnxManager$
> Listener.run(QuorumCnxManager.java:509)
> 2017-05-26 14:54:10,403 INFO [main] o.apache.nifi.controller.
> FlowController
> Controller has been terminated successfully.
> 2017-05-26 14:54:10,405 WARN [main] org.apache.nifi.web.server.JettyServer
> Failed to start web server... shutting down.
> java.lang.Exception: Unable to load flow due to:
> org.apache.nifi.lifecycle.LifeCycleStartException: Failed to start Flow
> Service due to: java.net.BindException: Address already in use (Bind
> failed)
> at org.apache.nifi.web.server.JettyServer.start(JettyServer.
> java:799)
> at org.apache.nifi.NiFi.(NiFi.java:160)
> at org.apache.nifi.NiFi.main(NiFi.java:267)
> Caused by: org.apache.nifi.lifecycle.LifeCycleStartException: Failed to
> start Flow Service due to: java.net.BindException: Address already in use
> (Bind failed)
> at
> org.apache.nifi.controller.StandardFlowService.start(
> StandardFlowService.java:312)
> at org.apache.nifi.web.server.JettyServer.start(JettyServer.
> java:789)
> ... 2 common frames omitted
> Caused by: java.net.BindException: Address already in use (Bind failed)
> at java.net.PlainSocketImpl.socketBind(Native Method)
> at java.net.AbstractPlainSocketImpl.bind(
> AbstractPlainSocketImpl.java:387)
> at java.net.ServerSocket.bind(ServerSocket.java:375)
> at java.net.ServerSocket.(ServerSocket.java:237)
> at java.net.ServerSocket.(ServerSocket.java:128)
> at
> org.apache.nifi.io.socket.SocketUtils.createServerSocket(
> SocketUtils.java:108)
> at org.apache.nifi.io.socket.SocketListener.start(
> SocketListener.java:85)
> at
> org.apache.nifi.cluster.protocol.impl.SocketProtocolListener.start(
> SocketProtocolListener.java:90)
> at
> org.apache.nifi.cluster.protocol.impl.NodeProtocolSenderListener.start(
> NodeProtocolSenderListener.java:64)
> at
> org.apache.nifi.controller.StandardFlowService.start(
> StandardFlowService.java:303)
> ... 3 common frames omitted
> 2017-05-26 14:54:10,407 INFO [Thread-1] org.apache.nifi.NiFi Initiating
> shutdown of Jetty web server...
> 2017-05-26 14:54:10,410 INFO [Thread-1]
> o.eclipse.jetty.server.AbstractConnector Stopped
> ServerConnector@e280006{HTTP/1.1,[http/1.1]}{0.0.0.0:8080}
> 2017-05-26 14:54:10,410 INFO [Thread-1] org.eclipse.jetty.server.session
> Stopped scavenging
>
>
>
>
> --
> View this message in context: http://apache-nifi-developer-
> list.39713.n7.nabble.com/Setting-basic-NiFi-network-
> problem-tp15989p15998.html
> Sent from the Apache NiFi Developer List mailing list archive at
> Nabble.com.
>


Re: Setting basic NiFi network problem

2017-05-26 Thread Xphos
t.SocketException: Socket closed
at java.net.PlainSocketImpl.socketAccept(Native Method)
at
java.net.AbstractPlainSocketImpl.accept(AbstractPlainSocketImpl.java:409)
at java.net.ServerSocket.implAccept(ServerSocket.java:545)
at java.net.ServerSocket.accept(ServerSocket.java:513)
at
org.apache.zookeeper.server.quorum.QuorumCnxManager$Listener.run(QuorumCnxManager.java:509)
2017-05-26 14:54:10,403 INFO [main] o.apache.nifi.controller.FlowController
Controller has been terminated successfully.
2017-05-26 14:54:10,405 WARN [main] org.apache.nifi.web.server.JettyServer
Failed to start web server... shutting down.
java.lang.Exception: Unable to load flow due to:
org.apache.nifi.lifecycle.LifeCycleStartException: Failed to start Flow
Service due to: java.net.BindException: Address already in use (Bind failed)
at org.apache.nifi.web.server.JettyServer.start(JettyServer.java:799)
at org.apache.nifi.NiFi.(NiFi.java:160)
at org.apache.nifi.NiFi.main(NiFi.java:267)
Caused by: org.apache.nifi.lifecycle.LifeCycleStartException: Failed to
start Flow Service due to: java.net.BindException: Address already in use
(Bind failed)
at
org.apache.nifi.controller.StandardFlowService.start(StandardFlowService.java:312)
at org.apache.nifi.web.server.JettyServer.start(JettyServer.java:789)
... 2 common frames omitted
Caused by: java.net.BindException: Address already in use (Bind failed)
at java.net.PlainSocketImpl.socketBind(Native Method)
at 
java.net.AbstractPlainSocketImpl.bind(AbstractPlainSocketImpl.java:387)
at java.net.ServerSocket.bind(ServerSocket.java:375)
at java.net.ServerSocket.(ServerSocket.java:237)
at java.net.ServerSocket.(ServerSocket.java:128)
at
org.apache.nifi.io.socket.SocketUtils.createServerSocket(SocketUtils.java:108)
at 
org.apache.nifi.io.socket.SocketListener.start(SocketListener.java:85)
at
org.apache.nifi.cluster.protocol.impl.SocketProtocolListener.start(SocketProtocolListener.java:90)
at
org.apache.nifi.cluster.protocol.impl.NodeProtocolSenderListener.start(NodeProtocolSenderListener.java:64)
at
org.apache.nifi.controller.StandardFlowService.start(StandardFlowService.java:303)
... 3 common frames omitted
2017-05-26 14:54:10,407 INFO [Thread-1] org.apache.nifi.NiFi Initiating
shutdown of Jetty web server...
2017-05-26 14:54:10,410 INFO [Thread-1]
o.eclipse.jetty.server.AbstractConnector Stopped
ServerConnector@e280006{HTTP/1.1,[http/1.1]}{0.0.0.0:8080}
2017-05-26 14:54:10,410 INFO [Thread-1] org.eclipse.jetty.server.session
Stopped scavenging




--
View this message in context: 
http://apache-nifi-developer-list.39713.n7.nabble.com/Setting-basic-NiFi-network-problem-tp15989p15998.html
Sent from the Apache NiFi Developer List mailing list archive at Nabble.com.


Re: Setting basic NiFi network problem

2017-05-25 Thread Andy LoPresto
ifi.cluster.flow.election.max.wait.time=1 mins
> nifi.cluster.flow.election.max.candidates= 3
> 
> # zookeeper properties, used for cluster management #
> nifi.zookeeper.connect.string=localhost:2180,localhost:2190,localhost:2200
> nifi.zookeeper.connect.timeout=3 secs
> nifi.zookeeper.session.timeout=3 secs
> nifi.zookeeper.root.node=/nifi
> 
> 
> 
> *Node 3:*
> # Site to Site properties
> nifi.remote.input.host=localhost
> nifi.remote.input.secure=false
> nifi.remote.input.socket.port=8140
> nifi.remote.input.http.enabled=true
> nifi.remote.input.http.transaction.ttl=30 sec
> 
> # web properties #
> nifi.web.war.directory=./lib
> nifi.web.http.host=
> 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=200
> 
> # cluster common properties (all nodes must have same values) #
> nifi.cluster.protocol.heartbeat.interval=5 sec
> nifi.cluster.protocol.is.secure=false
> 
> # cluster node properties (only configure for cluster nodes) #
> nifi.cluster.is.node=true
> nifi.cluster.node.address=
> nifi.cluster.node.protocol.port=8110
> nifi.cluster.node.protocol.threads=10
> nifi.cluster.node.event.history.size=25
> nifi.cluster.node.connection.timeout=5 sec
> nifi.cluster.node.read.timeout=5 sec
> nifi.cluster.firewall.file=
> nifi.cluster.flow.election.max.wait.time=1 mins
> nifi.cluster.flow.election.max.candidates=3
> 
> # zookeeper properties, used for cluster management #
> nifi.zookeeper.connect.string=localhost:2180,localhost:2190,localhost:2200
> nifi.zookeeper.connect.timeout=3 secs
> nifi.zookeeper.session.timeout=3 secs
> nifi.zookeeper.root.node=/nifi
> 
> 
> 
> *Zookeeper conf files*
> clientPort=2200  //for all of my nodes i just boost this port by 10
> initLimit=10
> autopurge.purgeInterval=24
> syncLimit=5
> tickTime=2000
> dataDir=./state/zookeeper
> autopurge.snapRetainCount=30
> 
> 
> server.1=localhost:2888:3888
> server.2=localhost:2888:3888
> server.3=localhost:2888:3888
> 
> 
> 
> --
> View this message in context: 
> http://apache-nifi-developer-list.39713.n7.nabble.com/Setting-basic-NiFi-network-problem-tp15989.html
> Sent from the Apache NiFi Developer List mailing list archive at Nabble.com.



signature.asc
Description: Message signed with OpenPGP using GPGMail


Setting basic NiFi network problem

2017-05-25 Thread Xphos
ster management #
nifi.zookeeper.connect.string=localhost:2180,localhost:2190,localhost:2200
nifi.zookeeper.connect.timeout=3 secs
nifi.zookeeper.session.timeout=3 secs
nifi.zookeeper.root.node=/nifi



*Zookeeper conf files*
clientPort=2200  //for all of my nodes i just boost this port by 10
initLimit=10
autopurge.purgeInterval=24
syncLimit=5
tickTime=2000
dataDir=./state/zookeeper
autopurge.snapRetainCount=30


server.1=localhost:2888:3888
server.2=localhost:2888:3888
server.3=localhost:2888:3888



--
View this message in context: 
http://apache-nifi-developer-list.39713.n7.nabble.com/Setting-basic-NiFi-network-problem-tp15989.html
Sent from the Apache NiFi Developer List mailing list archive at Nabble.com.