How to rollback from scylldb to cassandra?

ScyllaDB
, , ,
1

Cassandra to Scylla migration is seamless using sstableloader as documented here - Apache Cassandra to Scylla Migration Process | ScyllaDB Docs.

But is there any process to roll back from scyllDB to Cassandra?

It is mentioned here that Scylla and Cassandra sstables are compatible but when I try to just replace the sstables file, it fails.

Also, tried the same scylla to Cassandra migration by just replacing sstables and that too failed.

Any leads on how to successfully rollback to Cassandra in case ?

image
image943×222 15.1 KB

2

It is mentioned here that Scylla and Cassandra sstables are compatible but when I try to just replace the sstables file, it fails.

Failed how? What error did you get?
What version of ScyllaDB and Apache Cassandra are you using?

Also, tried the same scylla to Cassandra migration by just replacing sstables and that too failed.

Same questions as above.

Another alternative is using SSTableloadr. Since it use CQL, it should work with Apache Cassanra.

3

Cassandra = 4.0
Scylla = 5.1

Cassandra to Scylla migration-

  1. Using sstableloader
sstableloader -d 0.0.0.0 /home/keyspace1/table1/
===== Using optimized driver!!! =====
java.lang.ArrayIndexOutOfBoundsException: Index 640228101 out of bounds for length 4
	at org.apache.cassandra.io.sstable.metadata.MetadataSerializer.deserialize(MetadataSerializer.java:114)
	at org.apache.cassandra.io.sstable.metadata.MetadataSerializer.deserialize(MetadataSerializer.java:93)
	at org.apache.cassandra.io.sstable.format.SSTableReader.openForBatch(SSTableReader.java:416)
	at com.scylladb.tools.BulkLoader.openFile(BulkLoader.java:1527)
	at com.scylladb.tools.BulkLoader.process(BulkLoader.java:1572)
	at com.scylladb.tools.BulkLoader.lambda$main$1(BulkLoader.java:1369)
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
	at java.base/java.lang.Thread.run(Thread.java:829)
java.lang.ArrayIndexOutOfBoundsException: Index 640228101 out of bounds for length 4
	at org.apache.cassandra.io.sstable.metadata.MetadataSerializer.deserialize(MetadataSerializer.java:114)
	at org.apache.cassandra.io.sstable.metadata.MetadataSerializer.deserialize(MetadataSerializer.java:93)
	at org.apache.cassandra.io.sstable.format.SSTableReader.openForBatch(SSTableReader.java:416)
	at com.scylladb.tools.BulkLoader.openFile(BulkLoader.java:1527)
	at com.scylladb.tools.BulkLoader.process(BulkLoader.java:1572)
	at com.scylladb.tools.BulkLoader.lambda$main$1(BulkLoader.java:1369)
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
	at java.base/java.lang.Thread.run(Thread.java:829)
java.lang.ArrayIndexOutOfBoundsException: Index 640228101 out of bounds for length 4
	at org.apache.cassandra.io.sstable.metadata.MetadataSerializer.deserialize(MetadataSerializer.java:114)
	at org.apache.cassandra.io.sstable.metadata.MetadataSerializer.deserialize(MetadataSerializer.java:93)
	at org.apache.cassandra.io.sstable.format.SSTableReader.openForBatch(SSTableReader.java:416)
	at com.scylladb.tools.BulkLoader.openFile(BulkLoader.java:1527)
	at com.scylladb.tools.BulkLoader.process(BulkLoader.java:1572)
	at com.scylladb.tools.BulkLoader.lambda$main$1(BulkLoader.java:1369)
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
	at java.base/java.lang.Thread.run(Thread.java:829)
  0% done.        0 statements sent (in        0 batches,        0 failed).
       0 statements generated.
       0 cql rows processed in        0 partitions.
       0 cql rows and        0 partitions deleted.
       0 local and        0 remote counter shards where skipped.
  1. Replacing Cassandra snapshot in scylla

Got some corrupted stable format exceptions.

Scylla to Cassandra rollback-

The actual question was is it actually possible to do so ?