1

커다란 묘비가있는 테이블이 있습니다. 특정 테이블에서 스파크 작업 (읽음)을 수행하면 아무런 문제없이 결과가 나타납니다. 그러나 나는 cqlsh를 사용하여 같은 쿼리를 실행했다. 그 테이블에 거대한 묘석이 있기 때문에 에러가 발생했다.왜 거대한 묘비가있을 때 cqlsh 쿼리가 실패합니까?

일관성 하나 (1 개 복제에서 읽기 쿼리 동안

카산드라 실패 필요하지만 오 복제본 내가 그들을 피하기 위해 복구를 실행하지만, 분리 할 수 ​​있습니다, 하나는 내가 삭제 표시가 안 알고

실패, 반응 커넥터가 작동 스파크가 성공하는 이유 cqlsh이 실패했음을에서. 그들은 모두 동일한 세션과 쿼리를 사용합니다.

어떻게 spark-cassandra? 그것은 cqlsh 다르다? 은 알려 주시기 바랍니다.

감사합니다.

답변

1

Spark Cassandra 커넥터는 몇 가지 점에서 cqlsh와 다릅니다.

  • 그것은 자바 드라이버가 아닌 파이썬 드라이버를 사용
  • 그것은 조각

이러한 항목들로 요청을 파괴하여

  • 이 전체 테이블 스캔 훨씬 더 관대 재시도 정책을 가지고 SCC에서 왜 CQLSH에서 작동하지 않는지에 기여할 수 있습니다.