2016-04-08 16 views
0

SStableLoader yardımcı programını kullanarak Cassandra kümesine bazı sstables akışını yürütmeye çalışıyorum. Akış hatası alıyorum. İşte yığın.Bağlantı, sasstableLoader kullanılarak cassandra veri akışı için reddedildi

Established connection to initial hosts 
Opening sstables and calculating sections to stream 
18:05:04.058 [main] DEBUG o.a.c.i.s.m.MetadataSerializer - Load metadata for /path/new/xyz/search/xyz-search-ka-1 
18:05:04.073 [main] INFO o.a.c.io.sstable.SSTableReader - Opening /path/new/xyz/new/xyz_search/search/xyz_search-search-ka-1 (330768 bytes) 
Streaming relevant part of /path/new/xyz/xyz_search/search/xyz_search-search-ka-1-Data.db to [/10.XXX.XXX.XXX, /10.XXX.XXX.XXX, /10.XXX.XXX.XXX, /10.XXX.XXX.XXX, /10.XXX.XXX.XXX] 
18:05:04.411 [main] INFO o.a.c.streaming.StreamResultFuture - [Stream #ed3a0cd0-fd25-11e5-8509-63e9961cf787] Executing streaming plan for Bulk Load 
Streaming relevant part of /path/xyz-search-ka-1-Data.db to [/10.XXX.XXX.XXX, /10.XXX.XXX.XXX, /10.XXX.XXX.XXX, /10.XXX.XXX.XXX, /10.XXX.XXX.XXX] 
17:22:44.175 [main] INFO o.a.c.streaming.StreamResultFuture - [Stream #0327a9e0-fd20-11e5-b350-63e9961cf787] Executing streaming plan for Bulk Load 
17:22:44.177 [StreamConnectionEstablisher:1] INFO o.a.c.streaming.StreamSession - [Stream #0327a9e0-fd20-11e5-b350-63e9961cf787] Starting streaming to /10.XX.XX.XX 
17:22:44.177 [StreamConnectionEstablisher:1] DEBUG o.a.c.streaming.ConnectionHandler - [Stream #0327a9e0-fd20-11e5-b350-63e9961cf787] Sending stream init for incoming stream 
17:22:44.183 [StreamConnectionEstablisher:2] INFO o.a.c.streaming.StreamSession - [Stream #0327a9e0-fd20-11e5-b350-63e9961cf787] Starting streaming to /10.XX.XX.XX 
17:22:44.183 [StreamConnectionEstablisher:2] DEBUG o.a.c.streaming.ConnectionHandler - [Stream #0327a9e0-fd20-11e5-b350-63e9961cf787] Sending stream init for incoming stream 
17:23:47.191 [StreamConnectionEstablisher:2] ERROR o.a.c.streaming.StreamSession - [Stream #0327a9e0-fd20-11e5-b350-63e9961cf787] Streaming error occurred 
java.net.ConnectException: Connection timed out 
    at sun.nio.ch.Net.connect0(Native Method) ~[na:1.8.0_45] 
    at sun.nio.ch.Net.connect(Net.java:458) ~[na:1.8.0_45] 
    at sun.nio.ch.Net.connect(Net.java:450) ~[na:1.8.0_45] 
    at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:648) ~[na:1.8.0_45] 
    at java.nio.channels.SocketChannel.open(SocketChannel.java:189) ~[na:1.8.0_45] 
    at org.apache.cassandra.tools.BulkLoadConnectionFactory.createConnection(BulkLoadConnectionFactory.java:62) ~[cassandra-all-2.1.6.jar:2.1.6] 
    at org.apache.cassandra.streaming.StreamSession.createConnection(StreamSession.java:236) ~[cassandra-all-2.1.6.jar:2.1.6] 
    at org.apache.cassandra.streaming.ConnectionHandler.initiate(ConnectionHandler.java:79) ~[cassandra-all-2.1.6.jar:2.1.6] 
    at org.apache.cassandra.streaming.StreamSession.start(StreamSession.java:223) ~[cassandra-all-2.1.6.jar:2.1.6] 
    at org.apache.cassandra.streaming.StreamCoordinator$StreamSessionConnector.run(StreamCoordinator.java:208) [cassandra-all-2.1.6.jar:2.1.6] 
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [na:1.8.0_45] 
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [na:1.8.0_45] 
    at java.lang.Thread.run(Thread.java:745) [na:1.8.0_45] 
17:23:47.202 [StreamConnectionEstablisher:2] DEBUG o.a.c.streaming.ConnectionHandler - [Stream #0327a9e0-fd20-11e5-b350-63e9961cf787] Closing stream connection handler on /10.XXX.XXX.XXX 
17:23:47.205 [StreamConnectionEstablisher:1] ERROR o.a.c.streaming.StreamSession - [Stream #0327a9e0-fd20-11e5-b350-63e9961cf787] Streaming error occurred 
java.net.ConnectException: Connection timed out 
    at sun.nio.ch.Net.connect0(Native Method) ~[na:1.8.0_45] 
    at sun.nio.ch.Net.connect(Net.java:458) ~[na:1.8.0_45] 
    at sun.nio.ch.Net.connect(Net.java:450) ~[na:1.8.0_45] 
    at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:648) ~[na:1.8.0_45] 
    at java.nio.channels.SocketChannel.open(SocketChannel.java:189) ~[na:1.8.0_45] 
    at org.apache.cassandra.tools.BulkLoadConnectionFactory.createConnection(BulkLoadConnectionFactory.java:62) ~[cassandra-all-2.1.6.jar:2.1.6] 
    at org.apache.cassandra.streaming.StreamSession.createConnection(StreamSession.java:236) ~[cassandra-all-2.1.6.jar:2.1.6] 
    at org.apache.cassandra.streaming.ConnectionHandler.initiate(ConnectionHandler.java:79) ~[cassandra-all-2.1.6.jar:2.1.6] 
    at org.apache.cassandra.streaming.StreamSession.start(StreamSession.java:223) ~[cassandra-all-2.1.6.jar:2.1.6] 
    at org.apache.cassandra.streaming.StreamCoordinator$StreamSessionConnector.run(StreamCoordinator.java:208) [cassandra-all-2.1.6.jar:2.1.6] 
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [na:1.8.0_45] 
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [na:1.8.0_45] 
    at java.lang.Thread.run(Thread.java:745) [na:1.8.0_45] 

Ayrıca sstableloader'ı çalıştırdığım makinem de cassandra kümesinin dışında.

Teşekkür

cevap

1

Biraz daha hata ayıkladıktan sonra, sstableloader'ın sstables'i cassandra kümesine aktararak 7000 numaralı bağlantı noktasını da kullandığını gördük. Yerel makinem, cassandra kümesindeki makinelerde 7000 numaralı bağlantı noktasına erişemedi. Bu yüzden bağlantı süresi dışında bir istisna alıyordum.

Bu durumla karşılaşan herkes, makinenizin sstableloader'ı çalıştırdığınız yerden akış gerçekleştirmeye çalıştığınız tüm casssandra düğümlerinin 9160,7000 ve 9042 bağlantılarına sahip olduğundan emin olun.

0

DEBUG oacstreaming.ConnectionHandler - [Akış # 0327a9e0-fd20-11e5-b350-63e9961cf787] /10.XXX.XXX.XXX

üzerindeki akışı bağlantı işleyicisi Kapanış

İpucu : 10.xxx.xxx.xxx makinenin ağır yük altında olduğundan şüpheleniyorum. Kök nedenini daraltmak için bu makinedeki /var/log/cassandra/system.log dosyasını denetlemeye değer

İlgili konular