@@ -211,10 +211,8 @@ func TestReBalanceTablesMetadataIfDiskNotExists_CheckErrors(t *testing.T) {
211
211
invalidRemoteBackup .DataFormat = DirectoryFormat
212
212
invalidTable := metadata.TableMetadata {
213
213
Parts : map [string ][]metadata.Part {
214
- "default" : {{Name : "part_1_1_0" }, {Name : "part_2_2_0" }},
215
- "hdd2" : {{Name : "part_3_3_0" }, {Name : "part_4_4_0" }},
216
- "s3" : {{Name : "part_5_5_0" }, {Name : "part_6_6_0" }},
217
- "s3_disk2" : {{Name : "part_7_7_0" }, {Name : "part_8_8_0" }},
214
+ "default" : {{Name : "part_1_1_0" }, {Name : "part_2_2_0" }},
215
+ "hdd2" : {{Name : "part_3_3_0" }, {Name : "part_4_4_0" }},
218
216
},
219
217
RebalancedFiles : nil ,
220
218
Database : "default" ,
@@ -227,7 +225,7 @@ func TestReBalanceTablesMetadataIfDiskNotExists_CheckErrors(t *testing.T) {
227
225
LocalFile : "/dev/null" ,
228
226
}
229
227
tableMetadataAfterDownload := []metadata.TableMetadata {invalidTable }
230
- // not exists diskType
228
+ // hdd2 not exists diskType
231
229
delete (invalidRemoteBackup .DiskTypes , "hdd2" )
232
230
err := b .reBalanceTablesMetadataIfDiskNotExists (tableMetadataAfterDownload , baseDisks , invalidRemoteBackup , log )
233
231
assert .Error (t , err )
@@ -244,6 +242,13 @@ func TestReBalanceTablesMetadataIfDiskNotExists_CheckErrors(t *testing.T) {
244
242
245
243
// invalid storage_policy
246
244
invalidRemoteBackup .DiskTypes ["hdd2" ] = "local"
245
+ invalidTable .Parts = map [string ][]metadata.Part {
246
+ "default" : {{Name : "part_1_1_0" }, {Name : "part_2_2_0" }},
247
+ "hdd2" : {{Name : "part_3_3_0" }, {Name : "part_4_4_0" }},
248
+ "s3" : {{Name : "part_5_5_0" }, {Name : "part_6_6_0" }},
249
+ "s3_disk2" : {{Name : "part_7_7_0" }, {Name : "part_8_8_0" }},
250
+ }
251
+
247
252
invalidTable .Table = "test3"
248
253
invalidTable .Query = "CREATE TABLE default.test3(id UInt64) ENGINE=MergeTree() ORDER BY id SETTINGS storage_policy='invalid'"
249
254
tableMetadataAfterDownload = []metadata.TableMetadata {invalidTable }
0 commit comments