Skip to content

Commit

Permalink
cloudstorage(ticdc): Remove nfs schema file check (#10138) (#10154)
Browse files Browse the repository at this point in the history
close #10137
  • Loading branch information
ti-chi-bot authored Nov 24, 2023
1 parent 3a5901e commit ff6e944
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions pkg/sink/cloudstorage/path.go
Original file line number Diff line number Diff line change
Expand Up @@ -221,17 +221,17 @@ 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))
}
f.versionMap[table] = lastVersion
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
Expand Down

0 comments on commit ff6e944

Please sign in to comment.