Skip to content

Commit cbdacef

Browse files
committed
apply TestRestoreDistributedCluster for 19.17+
Signed-off-by: Slach <[email protected]>
1 parent a56dbd3 commit cbdacef

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

test/integration/integration_test.go

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2867,6 +2867,9 @@ func TestRestoreAsAttach(t *testing.T) {
28672867
}
28682868

28692869
func TestRestoreDistributedCluster(t *testing.T) {
2870+
if compareVersion(os.Getenv("CLICKHOUSE_VERSION"), "19.17") < 0 {
2871+
t.Skipf("system.clusters not cleanup properly in version %s", os.Getenv("CLICKHOUSE_VERSION"))
2872+
}
28702873
env, r := NewTestEnvironment(t)
28712874
env.connectWithWait(t, r, 0*time.Second, 1*time.Second, 1*time.Minute)
28722875
xml := `
@@ -2919,7 +2922,7 @@ func TestRestoreDistributedCluster(t *testing.T) {
29192922
// remove cluster and wait configuration reload
29202923
env.DockerExecNoError(r, "clickhouse", "bash", "-c", "rm -rfv /etc/clickhouse-server/config.d/new-cluster.xml")
29212924
newClusterExists := uint64(1)
2922-
for i := 0; i < 10 && newClusterExists == 1; i++ {
2925+
for i := 0; i < 60 && newClusterExists == 1; i++ {
29232926
r.NoError(env.ch.SelectSingleRowNoCtx(&newClusterExists, "SELECT count() FROM system.clusters WHERE cluster='new_cluster'"))
29242927
if newClusterExists == 0 {
29252928
break

0 commit comments

Comments
 (0)