1

私は巨大な墓石を持つテーブルを持っています。その特定のテーブルでスパークジョブ(読み込み)を実行すると問題なしで結果が得られました。しかし、私はcqlshを使って同じクエリを実行しました。それは、巨大な墓石がそのテーブルに存在するため、私にエラーを与えました。一貫性の1の読取り問合せ中巨大な墓石が存在するときにcqlshクエリで読み込みが失敗する理由

カサンドラの失敗(1つのレプリカ が必要なもののOのレプリカが1私は墓石があってはならない知っている

を失敗したと答え、私は離れて、それらを避けるために、修復を実行することができますが、火花が成功したとcqlshが失敗した理由。彼らの両方が同じセッションやクエリを使用しています。

spark-cassandraコネクタがどのように動作する?それはcqlshと異なること? から私に知らせてください。

ありがとうございます。

答えて

1

Spark Cassandra Connectorは、いくつかの点でcqlshとは異なります。

  • それは

個にアップ要求を分割することによってそれ全表スキャン

  • これらの項目のいずれかをはるかに寛大再試行ポリシーを持つJavaドライバーではなく、Pythonのドライバ
  • を使用していますSCCではなぜそれがCQLSHではなく動作するのかに寄与している可能性があります。

  • 関連する問題