Last active
December 13, 2015 23:29
-
-
Save boorad/4992420 to your computer and use it in GitHub Desktop.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
0 [main] WARN com.mapr.franz.server.ClusterState - connecting to localhost:2108 | |
489 [main-EventThread] INFO com.mapr.franz.server.ClusterState - SyncConnected | |
987 [main] INFO com.mapr.franz.server.ClusterState - Server -3851085439804092173 reading from status directory /franz | |
1681 [main] INFO com.mapr.franz.server.ClusterState - Entries: [ca8e323248cc50f3], our file: ca8e323248cc50f3 | |
1681 [main] INFO com.mapr.franz.server.ClusterState - Server -3851085439804092173 read 1 entries in status directory | |
1681 [main] INFO com.mapr.franz.server.ClusterState - Server -3851085439804092173 has position 0 | |
6964 [main] INFO com.googlecode.protobuf.pro.duplex.RpcServiceRegistry - Registered Blocking CatcherService allowTimeout=Y | |
18575 [New I/O worker #1] DEBUG com.googlecode.protobuf.pro.duplex.handler.ServerConnectRequestHandler - Received [2]ConnectRequest. | |
18579 [New I/O worker #1] DEBUG com.googlecode.protobuf.pro.duplex.handler.ServerConnectRequestHandler - Sending [2]ConnectResponse. | |
18591 [New I/O worker #1] DEBUG com.mapr.franz.server.Server - Connect with clientHostname:9999[0835aef8-8ab8-447f-b2d5-b1df6bd2b3bf] | |
18714 [New I/O worker #1] DEBUG com.googlecode.protobuf.pro.duplex.RpcServer - Received [1]RpcRequest. | |
18714 [New I/O worker #1] DEBUG com.googlecode.protobuf.pro.duplex.RpcServiceRegistry - Resolved CatcherService | |
18720 [rpc:pool-3-thread-1] DEBUG com.googlecode.protobuf.pro.duplex.RpcServer - Sending [1]RpcResponse. | |
18797 [rpc:pool-3-thread-1] INFO CatcherService.hello.info - duration: 7 server: "serverHostname:8080[bb39536e-b175-413b-98c2-2ea4fcca72d3]" signature: "CatcherService.hello" client: "clientHostname:9999[0835aef8-8ab8-447f-b2d5-b1df6bd2b3bf]" corId: 1 request { ts: 1361328819132 size: 15 uuid: "fe5b3d1f-353e-4ca1-957b-1ebd466e3310" } response { ts: 1361328819139 size: 62 uuid: "e960fc26-220e-400d-ba8c-cb357ffd1525" } | |
18797 [rpc:pool-3-thread-1] INFO CatcherService.hello.data.request - uuid: "fe5b3d1f-353e-4ca1-957b-1ebd466e3310" content: "clientId: 1 application: \"test-client\"" | |
18797 [rpc:pool-3-thread-1] INFO CatcherService.hello.data.response - uuid: "fe5b3d1f-353e-4ca1-957b-1ebd466e3310" content: "serverId: 14595658633905459443 host { hostName: \"192.168.1.81\" port: 9013 } cluster { serverId: 14595658633905459443 host { hostName: \"192.168.1.81\" port: 9013 } }" | |
18843 [New I/O worker #1] DEBUG com.mapr.franz.server.Server - Disconnect from clientHostname:9999[0835aef8-8ab8-447f-b2d5-b1df6bd2b3bf] |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
13/02/19 21:53:38 INFO catcher.Client: Connecting to HostPort{host='127.0.0.1', port=8080} | |
13/02/19 21:53:38 INFO catcher.CatcherConnection: Connecting to 127.0.0.1:8080[7545003d-de94-4ec3-aa3e-ec646f8f28cf] | |
13/02/19 21:53:39 INFO catcher.Client: Connecting to HostPort{host='192.168.1.81', port=9013} | |
13/02/19 21:53:39 INFO catcher.CatcherConnection: Connecting to 192.168.1.81:9013[a8413dd9-e682-4c8a-b4f1-61796ccd576d] | |
13/02/19 21:53:39 WARN catcher.CatcherConnection: Cannot connect to 192.168.1.81:9013[a8413dd9-e682-4c8a-b4f1-61796ccd576d] | |
java.io.IOException: Failed to connect to /192.168.1.81:9013 | |
at com.googlecode.protobuf.pro.duplex.client.DuplexTcpClientBootstrap.peerWith(DuplexTcpClientBootstrap.java:139) | |
at com.googlecode.protobuf.pro.duplex.client.DuplexTcpClientBootstrap.peerWith(DuplexTcpClientBootstrap.java:106) | |
at com.mapr.franz.catcher.CatcherConnection.<init>(CatcherConnection.java:55) | |
at com.mapr.franz.catcher.CatcherConnection.connect(CatcherConnection.java:31) | |
at com.mapr.franz.catcher.ConnectionFactory.create(ConnectionFactory.java:10) | |
at com.mapr.franz.catcher.Client.connectAll(Client.java:306) | |
at com.mapr.franz.catcher.Client.<init>(Client.java:104) | |
at com.mapr.franz.catcher.Client.<init>(Client.java:97) | |
at com.mapr.demo.twitter.TweetLogger.query(TweetLogger.java:34) | |
at com.mapr.demo.twitter.TweetLogger.main(TweetLogger.java:27) | |
Caused by: java.net.ConnectException: Connection refused | |
at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) | |
at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:599) | |
at org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.connect(NioClientSocketPipelineSink.java:496) | |
at org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.processSelectedKeys(NioClientSocketPipelineSink.java:452) | |
at org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.run(NioClientSocketPipelineSink.java:365) | |
at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:102) | |
at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42) | |
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886) | |
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908) | |
at java.lang.Thread.run(Thread.java:680) | |
13/02/19 21:53:39 WARN handler.ClientConnectResponseHandler: Exception caught during RPC connection handshake. | |
java.net.ConnectException: Connection refused | |
at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) | |
at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:599) | |
at org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.connect(NioClientSocketPipelineSink.java:496) | |
at org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.processSelectedKeys(NioClientSocketPipelineSink.java:452) | |
at org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.run(NioClientSocketPipelineSink.java:365) | |
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886) | |
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908) | |
at java.lang.Thread.run(Thread.java:680) | |
13/02/19 21:53:39 WARN catcher.Client: Cannot connect to HostPort{host='192.168.1.81', port=9013} |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment