Разъем Spark Cassandra не поддерживает ByteOrderedParitioner? - PullRequest
0 голосов
/ 23 сентября 2018

Я использую spark-cassandra-connector_2.11-2.0.0.jar для подключения к Cassandra (версия 2.1.9).Разделителем Кассандры является `ByteOrderedParitioner '.

Однако, когда я отправляю программы драйвера спрайта, он показывает: Exception in thread "main" java.lang.IllegalArgumentException: Unsupported partitioner: org.apache.cassandra.dht.ByteOrderedPartitioner.

Кажется, что только" Murmur3Partitioner "и" RandomPartitioner "поддерживаются висходный код.

Но Hadoop поддерживает ByteOrderedPartitioner.Интересно, как это решить, когда заставляю использовать ByteOrderedPartitioner.

Спасибо за вашу помощь.

1 Ответ

0 голосов
/ 23 сентября 2018

Это не в Spark, потому что никто не должен больше использовать ByteOrderedPartitioner.Это потому, что он:

A) Существует только для обратной совместимости.

B) Его создание (и последующее использование) широко признано как плохая идея.

Это обсуждалось до тошноты.Смотрите мой ответ здесь на похожий вопрос: Cassandra ByteOrderedPartitioner

Я рекомендую вам:

  • Перестройте кластер, используя Murmur3Partitioner.
  • ИЛИ создайте новый кластер и загрузите его с данными из оригинала.
  • Найдите того, кто построил исходный кластер, и slap их.
...