sink(ticdc): fix create storage sink (#9244)

ref #8772, close #9316
pingcap · Jul 4, 2023 · 41fda20 · 41fda20
1 parent a0991ca
commit 41fda20
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/pkg/util/external_storage.go b/pkg/util/external_storage.go
@@ -75,6 +75,13 @@ func GetExternalStorage(
 		retErr := errors.ErrFailToCreateExternalStorage.Wrap(errors.Trace(err))
 		return nil, retErr.GenWithStackByArgs("creating ExternalStorage for s3")
 	}
+
+	// Check the connection and ignore the returned bool value, since we don't care if the file exists.
+	_, err = ret.FileExists(ctx, "test")
+	if err != nil {
+		retErr := errors.ErrFailToCreateExternalStorage.Wrap(errors.Trace(err))
+		return nil, retErr.GenWithStackByArgs("creating ExternalStorage for s3")
+	}
 	return ret, nil
 }