Have you checked the yaml configuration for the sstableloader ? Background 
configuration section here http://www.datastax.com/dev/blog/bulk-loading

 
Hope that helps. 

-----------------
Aaron Morton
Freelance Cassandra Developer
New Zealand

@aaronmorton
http://www.thelastpickle.com

On 5/12/2012, at 1:43 PM, Pradeep Kumar Mantha <pradeep...@gmail.com> wrote:

> 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

Reply via email to