Update tests

Author: Avogar

tests/integration/test_merge_tree_s3/test.py

@@ -88,6 +88,7 @@ def create_table(node, table_name, **additional_settings):
         "old_parts_lifetime": 0,
         "index_granularity": 512,
         "temporary_directories_lifetime": 1,
+        "write_marks_for_substreams_in_compact_parts": 1,
     }
     settings.update(additional_settings)
 

tests/integration/test_merge_tree_s3_failover/test.py

@@ -123,7 +123,7 @@ def test_write_failover(
         ) ENGINE=MergeTree()
         ORDER BY id
         PARTITION BY dt
-        SETTINGS storage_policy='s3', min_bytes_for_wide_part={}
+        SETTINGS storage_policy='s3', min_bytes_for_wide_part={}, write_marks_for_substreams_in_compact_parts=1
         """.format(
             min_bytes_for_wide_part
         )

tests/performance/compact_part_subcolumns.xml

@@ -3,8 +3,8 @@
         <allow_experimental_json_type>1</allow_experimental_json_type>
     </settings>
 
-    <create_query>CREATE TABLE t_json_1 (data JSON) ENGINE = MergeTree ORDER BY tuple() SETTINGS min_rows_for_wide_part=1000000000, min_bytes_for_wide_part=100000000000</create_query>
-    <create_query>CREATE TABLE t_json_2 (data JSON) ENGINE = MergeTree ORDER BY tuple() SETTINGS min_rows_for_wide_part=1000000000, min_bytes_for_wide_part=100000000000</create_query>
+    <create_query>CREATE TABLE t_json_1 (data JSON) ENGINE = MergeTree ORDER BY tuple() SETTINGS min_rows_for_wide_part=1000000000, min_bytes_for_wide_part=100000000000, write_marks_for_substreams_in_compact_parts=1</create_query>
+    <create_query>CREATE TABLE t_json_2 (data JSON) ENGINE = MergeTree ORDER BY tuple() SETTINGS min_rows_for_wide_part=1000000000, min_bytes_for_wide_part=100000000000, write_marks_for_substreams_in_compact_parts=1</create_query>
 
     <fill_query>INSERT INTO t_json_1 SELECT toJSONString(map(number % 10, repeat('a', number % 100))) FROM numbers(10000000)</fill_query>
     <fill_query>INSERT INTO t_json_2 SELECT toJSONString(arrayMap(x -> tuple('a' || x, x > 0 ? repeat('a', 100) : 'a'), range(1000))::Map(String, String)) FROM numbers(200000)</fill_query>

tests/queries/0_stateless/02241_filesystem_cache_on_write_operations.sh

@@ -12,7 +12,7 @@ for STORAGE_POLICY in 's3_cache' 'local_cache' 'azure_cache'; do
     echo "Using storage policy: $STORAGE_POLICY"
 
     $CLICKHOUSE_CLIENT --echo --query "DROP TABLE IF EXISTS test_02241"
-    $CLICKHOUSE_CLIENT --echo --query "CREATE TABLE test_02241 (key UInt32, value String) Engine=MergeTree() ORDER BY key SETTINGS storage_policy='$STORAGE_POLICY', min_bytes_for_wide_part = 10485760, compress_marks=false, compress_primary_key=false, min_bytes_for_full_part_storage=0, ratio_of_defaults_for_sparse_serialization = 1"
+    $CLICKHOUSE_CLIENT --echo --query "CREATE TABLE test_02241 (key UInt32, value String) Engine=MergeTree() ORDER BY key SETTINGS storage_policy='$STORAGE_POLICY', min_bytes_for_wide_part = 10485760, compress_marks=false, compress_primary_key=false, min_bytes_for_full_part_storage=0, ratio_of_defaults_for_sparse_serialization = 1, write_marks_for_substreams_in_compact_parts=1"
     $CLICKHOUSE_CLIENT --echo --query "SYSTEM STOP MERGES test_02241"
 
     $CLICKHOUSE_CLIENT --echo --query "SYSTEM DROP FILESYSTEM CACHE"