update

Author: yinshuangfei

downstreamadapter/sink/cloudstorage/sink_test.go

@@ -289,6 +289,9 @@ func TestWriteDDLEventWithInvalidExchangePartitionEvent(t *testing.T) {
 			ctx, cancel := context.WithCancel(context.Background())
 			defer cancel()
 
+			mockPDClock := pdutil.NewClock4Test()
+			appcontext.SetService(appcontext.DefaultPDClock, mockPDClock)
+
 			cloudStorageSink, err := newSinkForTest(ctx, replicaConfig, sinkURI, nil)
 			require.NoError(t, err)
 

pkg/sink/cloudstorage/table_definition.go

@@ -14,7 +14,6 @@ package cloudstorage
 
 import (
 	"encoding/json"
-	"fmt"
 	"sort"
 	"strconv"
 	"strings"
@@ -340,9 +339,6 @@ func (t *TableDefinition) GenerateSchemaFilePath(useTableIDAsPath bool, tableID
 	if !t.IsTableSchema() && t.Table != "" {
 		log.Panic("invalid table definition", zap.Any("tableDef", t))
 	}
-	table := t.Table
-	if useTableIDAsPath && t.IsTableSchema() {
-		table = fmt.Sprintf("%d", tableID)
-	}
+	table := generateTablePath(t.Table, tableID, useTableIDAsPath)
 	return generateSchemaFilePath(t.Schema, table, t.TableVersion, checksum), nil
 }