Обновление с Cassandea 1.1.9 до 1.2.18

Я пытаюсь обновить кластер с 3 узлами 1.1.9 до кластера с 6 узлами 1.2.18. Можно ли использовать sstableloader для потоковой передачи из существующего кластера в новый кластер? Если да, то какой предлагаемый метод? Я продолжаю получать следующее, когда пытаюсь это сделать:

разделитель org.apache.cassandra.dht.RandomPartitioner не соответствует системному разделителю org.apache.cassandra.dht.Murmur3Partitioner. Обратите внимание, что разделителем по умолчанию, начиная с Cassandra 1.2, является Murmur3Partitioner, поэтому вам нужно будет отредактировать его, чтобы он соответствовал вашему старому разделителю при обновлении.

Похоже, что в 1.1.9 нет Murmur3Partitioner, поэтому я изменил разделитель в новом кластере на RandomPartitioner. Даже с этим я получаю следующую ошибку:

Есть ли способ заставить sstableloader работать? Если нет, может ли кто-нибудь указать мне на документацию, объясняющую другие способы переноса данных/пространств ключей? Я не смог найти никаких подробных документов.

Спасибо

Способ сделать это поэтапно:


person msd    schedule 14.07.2014    source источник


Ответы (1)


Сначала обновите существующий кластер до версии 1.2.

Во-вторых, либо создайте моментальный снимок ваших sstables на каждом существующем узле и скопируйте их на новые узлы, либо настройте свои новые узлы как центр обработки данных, подключенный к вашим существующим узлам, и позвольте репликации обрабатывать нагрузку.

Не используйте sstable2json.

CLASSPATH=/etc/cassandra/conf/cassandra.yaml:/root/lib_cass15/apache-cassandra-1.2.18.jar:/root/lib_cass15/guava-13.0.1.jar:/etc/cassandra/conf:/usr /share/java/jna.jar:/usr/share/cassandra/lib/antlr-3.2.jar:/usr/share/cassandra/lib/apache-cassandra-1.1.9.jar:/usr/share/cassandra/ lib/apache-cassandra-clientutil-1.1.9.jar:/usr/share/cassandra/lib/apache-cassandra-thrift-1.1.9.jar:/usr/share/cassandra/lib/avro-1.4.0- fixes.jar:/usr/share/cassandra/lib/avro-1.4.0-sources-fixes.jar:/usr/share/cassandra/lib/commons-cli-1.1.jar:/usr/share/cassandra/lib /commons-codec-1.2.jar:/usr/share/cassandra/lib/commons-lang-2.4.jar:/usr/share/cassandra/lib/compress-lzf-0.8.4.jar:/usr/share/ cassandra/lib/concurrentlinkedhashmap-lru-1.3.jar:/usr/share/cassandra/lib/guava-r08.jar:/usr/share/cassandra/lib/high-scale-lib-1.1.2.jar:/usr /share/cassandra/lib/jackson-core-asl-1.9.2.jar:/usr/share/cassandra/lib/jackson-mapper-asl-1.9.2.jar:/usr/share/cassandra/lib/jamm -0.2.5.jar:/usr/доля/cassandra/lib/jline-0.9.94 .jar:/usr/share/cassandra/lib/json-simple-1.1.jar:/usr/share/cassandra/lib/libthrift-0.7.0.jar:/usr/share/cassandra/lib/log4j-1.2. 16.jar:/usr/share/cassandra/lib/metrics-core-2.0.3.jar:/usr/share/cassandra/lib/servlet-api-2.5-20081211.jar:/usr/share/cassandra/lib /slf4j-api-1.6.1.jar:/usr/share/cassandra/lib/slf4j-log4j12-1.6.1.jar:/usr/share/cassandra/lib/snakeyaml-1.6.jar:/usr/share/ cassandra/lib/snappy-java-1.0.4.1.jar:/usr/share/cassandra/lib/snaptree-0.1.jar:/usr/share/cassandra/lib/stress.jar Не удалось получить диапазоны конечных точек: java.lang .RuntimeException: не удалось получить диапазоны конечных точек: в org.apache.cassandra.tools.BulkLoader$ExternalClient.init(BulkLoader.java:233) в org.apache.cassandra.io.sstable.SSTableLoader.stream(SSTableLoader.java:119 ) в org.apache.cassandra.tools.BulkLoader.main(BulkLoader.java:67) Вызвано: org.apache.thrift.transport.TTransportException в org.apache.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java :132) в org.apache.thrift.transport.TTransport.readAll(TTransport.java:84) в org.apache.thrift.transport.TFramedTransport.readFrame(TFramedTransport.java:129) в org.apache.thrift.transport. TFramedTransport.read(TFramedTransport.java:101) в org.apache.thrift.transport.TTransport.readAll(TTransport.java:84) в org.apache.thrift.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:378) в org .apache.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:297) в org.apache.thrift.protocol. TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:204) в org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:69) в org.apache.cassandra.thrift.Cassandra$Client.recv_describe_ring(Cassandra.java:1155) в org. .apache.cassandra.thrift.Cassandra$Client.describe_ring(Cassandra.java:1142) в org.apache.cassandra.tools.BulkLoader$ExternalClient.init(BulkLoader.java:212) ... еще 2

person rs_atl    schedule 14.07.2014