Skip to content

Commit 67a86c3

Browse files
committed
fix TestFTP and other mv_refreshable tests, fix #1271
Signed-off-by: Slach <[email protected]>
1 parent db85bd9 commit 67a86c3

File tree

1 file changed

+4
-7
lines changed

1 file changed

+4
-7
lines changed

test/integration/integration_test.go

Lines changed: 4 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -4253,11 +4253,9 @@ func generateTestDataForDifferentServerVersion(remoteStorageType string, offset,
42534253
Name: "mv_refreshable_dst_table",
42544254
Schema: "(id UInt64) Engine=MergeTree ORDER BY id",
42554255
SkipInsert: true,
4256-
//during second restore ATTACH PART can happen for non-empty refreshed table
4256+
//table shall be empty cause restore mv_refreshable with EMPTY option
42574257
Rows: func() []map[string]interface{} {
4258-
return []map[string]interface{}{
4259-
{"id": uint64(0)},
4260-
}
4258+
return []map[string]interface{}{}
42614259
}(),
42624260
Fields: []string{"id"},
42634261
OrderBy: "id",
@@ -4269,10 +4267,9 @@ func generateTestDataForDifferentServerVersion(remoteStorageType string, offset,
42694267
Name: "mv_refreshable",
42704268
Schema: fmt.Sprintf("REFRESH EVERY 24 HOUR TO `%s`.`mv_refreshable_dst_table_{test}` EMPTY AS SELECT max(id) AS id FROM `%s`.`mv_src_table_{test}`", dbNameAtomic, dbNameAtomic),
42714269
SkipInsert: true,
4270+
//table shall be empty cause restore mv_refreshable with EMPTY option
42724271
Rows: func() []map[string]interface{} {
4273-
return []map[string]interface{}{
4274-
{"id": uint64(0)},
4275-
}
4272+
return []map[string]interface{}{}
42764273
}(),
42774274
Fields: []string{"id"},
42784275
OrderBy: "id",

0 commit comments

Comments
 (0)