incubator-cassandra-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Pradeep Kumar Mantha <pradeep...@gmail.com>
Subject Fwd: Loading SSTables failing via Cassandra SSTableLoader on mulit-node cluster.
Date Wed, 05 Dec 2012 00:43:15 GMT
Hi!

I am trying to load sstables generated onto a running multi-node
Cassandra cluster.  But I see problems only with multi-cluster and
single node works fine.

Cassandra version used is 1.1.2 .
The cassandra cluster seems to be active.

-bash-3.2$ nodetool -host 129.56.57.45 -p 7199 ring
Address         DC          Rack        Status State   Load
Effective-Ownership Token

                    13087783343113017825514407978144931209
129.56.57.45    datacenter1 rack1       Up     Normal  57.49 KB
92.31%              0
129.56.57.46    datacenter1 rack1       Up     Normal  50.6 KB
7.69%               13087783343113017825514407978144931209
-bash-3.2$


I tried sstableloader from cassandra node ( 129.56.57.45) annd other
outside machine. But I get the same error in both the cases.


Error:

-bash-3.2$ sstableloader -d 129.56.57.45 Blast/Blast_NR/
log4j:WARN No appenders could be found for logger
(org.apache.cassandra.io.sstable.SSTableReader).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig
for more info.
Streaming revelant part of Blast/Blast_NR/Blast-Blast_NR-hd-1-Data.db
to [/129.56.57.46, /129.56.57.45]

progress: [/129.56.57.46 0/0 (100)] [/129.56.57.45 0/1 (0)] [total: 0
- 0MB/s (avg: 0MB/s)]Streaming session to /129.56.57.45 failed
Exception in thread "Streaming to /129.56.57.45:1"
java.lang.RuntimeException: java.net.ConnectException: Connection
timed out
        at org.apache.cassandra.utils.FBUtilities.unchecked(FBUtilities.java:628)
        at org.apache.cassandra.utils.WrappedRunnable.run(WrappedRunnable.java:34)
        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:619)
Caused by: java.net.ConnectException: Connection timed out
        at java.net.PlainSocketImpl.socketConnect(Native Method)
        at java.net.PlainSocketImpl.doConnect(PlainSocketImpl.java:333)
        at java.net.PlainSocketImpl.connectToAddress(PlainSocketImpl.java:195)
        at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:182)
        at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:366)
        at java.net.Socket.connect(Socket.java:519)
        at java.net.Socket.connect(Socket.java:469)
        at java.net.Socket.<init>(Socket.java:366)Streaming session to
/129.56.57.46 failed

        at java.net.Socket.<init>(Socket.java:267)
        at org.apache.cassandra.net.OutboundTcpConnectionPool.newSocket(OutboundTcpConnectionPool.java:96)
        at org.apache.cassandra.streaming.FileStreamTask.connectAttempt(FileStreamTask.java:245)
        at org.apache.cassandra.streaming.FileStreamTask.runMayThrow(FileStreamTask.java:91)
        at org.apache.cassandra.utils.WrappedRunnable.run(WrappedRunnable.java:30)
        ... 3 more
Exception in thread "Streaming to /129.56.57.46:1"
java.lang.RuntimeException: java.net.ConnectException: Connection
timed out
        at org.apache.cassandra.utils.FBUtilities.unchecked(FBUtilities.java:628)
        at org.apache.cassandra.utils.WrappedRunnable.run(WrappedRunnable.java:34)
        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:619)
Caused by: java.net.ConnectException: Connection timed out
        at java.net.PlainSocketImpl.socketConnect(Native Method)
        at java.net.PlainSocketImpl.doConnect(PlainSocketImpl.java:333)
        at java.net.PlainSocketImpl.connectToAddress(PlainSocketImpl.java:195)
        at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:182)
        at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:366)
        at java.net.Socket.connect(Socket.java:519)
        at java.net.Socket.connect(Socket.java:469)
        at java.net.Socket.<init>(Socket.java:366)
        at java.net.Socket.<init>(Socket.java:267)
        at org.apache.cassandra.net.OutboundTcpConnectionPool.newSocket(OutboundTcpConnectionPool.java:96)
        at org.apache.cassandra.streaming.FileStreamTask.connectAttempt(FileStreamTask.java:245)
        at org.apache.cassandra.streaming.FileStreamTask.runMayThrow(FileStreamTask.java:91)
        at org.apache.cassandra.utils.WrappedRunnable.run(WrappedRunnable.java:30)
        ... 3 more
progress: [/129.56.57.46 0/0 (100)] [/129.56.57.45 0/1 (0)] [total: 0
- 0MB/s (avg: 0MB/s)]Streaming to the following hosts failed:
[/129.56.57.45, /129.56.57.46]



Configuration on 129.56.57.45(cassandra.yaml):

rpc_address: 129.56.57.45
listen_address: 129.56.57.45
storage_port: 7000
rpc_port: 9160
seed_provider:
    # Addresses of hosts that are deemed contact points.
    # Cassandra nodes use this list of hosts to find each other and learn
    # the topology of the ring.  You must change this if you are running
    # multiple nodes!
    - class_name: org.apache.cassandra.locator.SimpleSeedProvider
      parameters:
          # seeds is actually a comma-delimited list of addresses.
          # Ex: "<ip1>,<ip2>,<ip3>"
          - seeds: 129.56.57.45


Configuration on 129.56.57.46(cassandra.yaml):

rpc_address: 129.56.57.46
listen_address: 129.56.57.46
storage_port: 7000
rpc_port: 9160
seed_provider:
    # Addresses of hosts that are deemed contact points.
    # Cassandra nodes use this list of hosts to find each other and learn
    # the topology of the ring.  You must change this if you are running
    # multiple nodes!
    - class_name: org.apache.cassandra.locator.SimpleSeedProvider
      parameters:
          # seeds is actually a comma-delimited list of addresses.
          # Ex: "<ip1>,<ip2>,<ip3>"
          - seeds: 129.56.57.45


-bash-3.2$ netstat -ant | grep 7000
tcp        0      0 129.56.57.45:7000           0.0.0.0:*
     LISTEN
tcp        0      0 129.56.57.45:37000          128.55.57.61:790
     ESTABLISHED
tcp        0      0 129.56.57.45:7000           129.56.57.46:48235
     ESTABLISHED
tcp        0      0 129.56.57.45:60323          129.56.57.46:7000
     ESTABLISHED
tcp        0      0 129.56.57.45:60976          129.56.57.46:7000
     ESTABLISHED


Please let me know if you need any information.

thanks

Mime
View raw message