I am using Spark + Cassandra The version is: <dependency> <!-- Cassandra --> <groupId>com.datastax.spark</groupId> <artifactId>spark-cassandra-connector-java_2.10</artifactId> <version>1.1.0</version> </dependency>
My problem: I send 100 messages to kafka and I save to cassandra. Only it save some messages (between 70-80).
Environment
None
Pull Requests
None
Activity
Show:
David
February 17, 2015 at 8:42 AM
I am sorry. I created several times the table and I changed the primary key. The problem is often silly. Thanks you.
Russell Spitzer
February 17, 2015 at 2:45 AM
Are you sure the rows have unique primary keys?
Jacek
February 16, 2015 at 10:16 PM
Can you attach log from the executors ?
David
February 16, 2015 at 8:30 PM
Yes, I debug but I dont see anything.
Enviado desde mi iPhone
Jacek
February 16, 2015 at 7:43 PM
Have you tried to debug it? Do you have any logs from executors? You may also try to print RDDs to console for debugging.
Major
I am using Spark + Cassandra
The version is:
<dependency> <!-- Cassandra -->
<groupId>com.datastax.spark</groupId>
<artifactId>spark-cassandra-connector-java_2.10</artifactId>
<version>1.1.0</version>
</dependency>
My problem:
I send 100 messages to kafka and I save to cassandra. Only it save some messages (between 70-80).