diff --git a/src/test/regress/expected/local_shard_execution_dropped_column.out b/src/test/regress/expected/local_shard_execution_dropped_column.out index 993321735..2090b71b8 100644 --- a/src/test/regress/expected/local_shard_execution_dropped_column.out +++ b/src/test/regress/expected/local_shard_execution_dropped_column.out @@ -18,6 +18,7 @@ SELECT stop_metadata_sync_to_node('localhost',:worker_2_port); -- create a distributed table, drop a column and sync the metadata SET citus.shard_replication_factor TO 1; +SET citus.replication_model to 'streaming'; CREATE TABLE t1 (a int, b int, c int UNIQUE); SELECT create_distributed_table('t1', 'c'); create_distributed_table diff --git a/src/test/regress/sql/local_shard_execution_dropped_column.sql b/src/test/regress/sql/local_shard_execution_dropped_column.sql index b3473a1f2..0cc028bf9 100644 --- a/src/test/regress/sql/local_shard_execution_dropped_column.sql +++ b/src/test/regress/sql/local_shard_execution_dropped_column.sql @@ -12,6 +12,7 @@ SELECT stop_metadata_sync_to_node('localhost',:worker_2_port); -- create a distributed table, drop a column and sync the metadata SET citus.shard_replication_factor TO 1; +SET citus.replication_model to 'streaming'; CREATE TABLE t1 (a int, b int, c int UNIQUE); SELECT create_distributed_table('t1', 'c'); ALTER TABLE t1 DROP COLUMN b;