test

arenadata · Nov 1, 2024 · 6a8ee92 · 6a8ee92
1 parent e716e9a
commit 6a8ee92
Showing 1 changed file with 17 additions and 0 deletions.
diff --git a/end_to_end/end_to_end_suite_test.go b/end_to_end/end_to_end_suite_test.go
@@ -2669,6 +2669,23 @@ LANGUAGE plpgsql NO SQL;`)
 			assertArtifactsCleaned("20240730085053")
 			testhelper.AssertQueryRuns(restoreConn, "DROP TABLE a; DROP TABLE b; DROP TABLE c; DROP TABLE d;")
 		})
+		It("Will not hang and fatal error after helper error on resize-restore with jobs", func() {
+			command := exec.Command("tar", "-xzf", "resources/4-segment-db-single-backup-dir.tar.gz", "-C", backupDir)
+			mustRunCommand(command)
+			command = exec.Command("mv",
+				path.Join(backupDir, "4-segment-db-single-backup-dir/backups/20240730/20240730085053/gpbackup_0_20240730085053_16417.gz"),
+				path.Join(backupDir, "4-segment-db-single-backup-dir/backups/20240730/20240730085053/gpbackup_0_20240730085053_16417.gz.1"))
+			mustRunCommand(command)
+			gprestoreCmd := exec.Command(gprestorePath,
+				"--timestamp", "20240730085053",
+				"--redirect-db", "restoredb",
+				"--backup-dir", path.Join(backupDir, "4-segment-db-single-backup-dir"),
+				"--resize-cluster", "--on-error-continue", "--jobs", "3")
+			output, _ := gprestoreCmd.CombinedOutput()
+			Expect(string(output)).To(ContainSubstring(`[ERROR]:-Encountered errors with 1 helper agent(s)`))
+			assertArtifactsCleaned("20240730085053")
+			testhelper.AssertQueryRuns(restoreConn, "DROP TABLE a; DROP TABLE b; DROP TABLE c; DROP TABLE d;")
+		})
 	})
 	Describe("Restore indexes and constraints on exchanged partition tables", func() {
 		BeforeEach(func() {