From 405fccd2cdaa16a43efde2471a1826b2ddfe8bde Mon Sep 17 00:00:00 2001 From: Chris Cranford Date: Sat, 16 Mar 2024 08:42:19 -0400 Subject: [PATCH] DBZ-7654 Fix RedisSchemaHistoryIT failure --- .../java/io/debezium/server/redis/RedisSchemaHistoryIT.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/debezium-server-redis/src/test/java/io/debezium/server/redis/RedisSchemaHistoryIT.java b/debezium-server-redis/src/test/java/io/debezium/server/redis/RedisSchemaHistoryIT.java index ab082661..2b4cc9a2 100644 --- a/debezium-server-redis/src/test/java/io/debezium/server/redis/RedisSchemaHistoryIT.java +++ b/debezium-server-redis/src/test/java/io/debezium/server/redis/RedisSchemaHistoryIT.java @@ -43,7 +43,7 @@ public class RedisSchemaHistoryIT extends AbstractSchemaHistoryTest { private static final String STREAM_NAME = "metadata:debezium:schema_history"; - private static final int INIT_HISTORY_SIZE = 16; // Initial number of entries in the schema history stream. + private static final int INIT_HISTORY_SIZE = 21; // Initial number of entries in the schema history stream. protected static Jedis jedis; @@ -103,7 +103,7 @@ public void testRedisConnectionRetry() throws Exception { final AbstractConnectorConnection connection = getMySqlConnection(); connection.connect(); Testing.print("Creating new redis_test table and inserting 5 records to it"); - connection.execute("CREATE TABLE inventory.redis_test (id INT PRIMARY KEY)"); + connection.execute("CREATE TABLE IF NOT EXISTS inventory.redis_test (id INT PRIMARY KEY)"); connection.close(); Testing.print("Sleeping for 2 seconds to flush records");