diff --git a/pkg/sink/cloudstorage/path.go b/pkg/sink/cloudstorage/path.go index 97694dc6beb..583577be830 100644 --- a/pkg/sink/cloudstorage/path.go +++ b/pkg/sink/cloudstorage/path.go @@ -221,7 +221,7 @@ func (f *FilePathGenerator) CheckOrWriteSchema( // Case 2: the table meta path is not empty. if schemaFileCnt != 0 { if lastVersion == 0 { - log.Panic("no table schema file found in an non-empty meta path", + log.Warn("no table schema file found in an non-empty meta path", zap.Any("versionedTableName", table), zap.Uint32("checksum", checksum)) } @@ -229,9 +229,9 @@ func (f *FilePathGenerator) CheckOrWriteSchema( return nil } - // Case 3: the table meta path is empty, which only happens when the table is - // existed before changefeed started. We need to write schema file to external - // storage. + // Case 3: the table meta path is empty, which happens when: + // a. the table is existed before changefeed started. We need to write schema file to external storage. + // b. the schema file is deleted by the consumer. We write schema file to external storage too. encodedDetail, err := def.MarshalWithQuery() if err != nil { return err