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 <pradeepm66@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
|