From 15265689f529f05fd3f4065b3f098864de686edb Mon Sep 17 00:00:00 2001 From: Sylvain Lebresne Date: Thu, 23 Jul 2015 17:55:37 +0200 Subject: [PATCH] Upgrade CommitLogUpgradeTest post-8099 --- .../db/commitlog/CommitLogUpgradeTest.java | 13 ++++++++++++- 1 file changed, 12 insertions(+), 1 deletion(-) diff --git a/test/unit/org/apache/cassandra/db/commitlog/CommitLogUpgradeTest.java b/test/unit/org/apache/cassandra/db/commitlog/CommitLogUpgradeTest.java index d443b8c012..ce4e6053b1 100644 --- a/test/unit/org/apache/cassandra/db/commitlog/CommitLogUpgradeTest.java +++ b/test/unit/org/apache/cassandra/db/commitlog/CommitLogUpgradeTest.java @@ -41,8 +41,11 @@ import org.apache.cassandra.config.Schema; import org.apache.cassandra.db.Mutation; import org.apache.cassandra.db.rows.Cell; import org.apache.cassandra.db.rows.Row; +import org.apache.cassandra.db.marshal.AsciiType; import org.apache.cassandra.db.marshal.UTF8Type; +import org.apache.cassandra.db.marshal.BytesType; import org.apache.cassandra.db.partitions.PartitionUpdate; +import org.apache.cassandra.schema.KeyspaceParams; public class CommitLogUpgradeTest { @@ -70,8 +73,16 @@ public class CommitLogUpgradeTest @BeforeClass static public void initialize() throws FileNotFoundException, IOException, InterruptedException { + CFMetaData metadata = CFMetaData.Builder.createDense(KEYSPACE, TABLE, false, false) + .addPartitionKey("key", AsciiType.instance) + .addClusteringColumn("col", BytesType.instance) + .addRegularColumn("val", BytesType.instance) + .build() + .compressionParameters(SchemaLoader.getCompressionParameters()); SchemaLoader.loadSchema(); - SchemaLoader.schemaDefinition(""); + SchemaLoader.createKeyspace(KEYSPACE, + KeyspaceParams.simple(1), + metadata); } public void testRestore(String location) throws IOException, InterruptedException