fix

iamlinjunhong · iamlinjunhong · commit 6579d491669a · 2025-07-07T14:40:11.000+08:00
diff --git a/pkg/sql/plan/build_ddl.go b/pkg/sql/plan/build_ddl.go
@@ -4603,10 +4603,7 @@ func buildCreatePitr(stmt *tree.CreatePitr, ctx CompilerContext) (*Plan, error)
 		if !ctx.DatabaseExists(string(stmt.DatabaseName), nil) {
 			return nil, moerr.NewInternalError(ctx.GetContext(), "database "+string(stmt.DatabaseName)+" does not exist")
 		}
-		objRef, tableDef, err := ctx.Resolve(string(stmt.DatabaseName), string(stmt.TableName), nil)
-		if err != nil {
-			return nil, err
-		}
+		objRef, tableDef := ctx.Resolve(string(stmt.DatabaseName), string(stmt.TableName), nil)
 		if objRef == nil || tableDef == nil {
 			return nil, moerr.NewInternalError(ctx.GetContext(), "table "+string(stmt.DatabaseName)+"."+string(stmt.TableName)+" does not exist")
 		}

Original file line number	Diff line number	Diff line change
`@@ -4603,10 +4603,7 @@ func buildCreatePitr(stmt tree.CreatePitr, ctx CompilerContext) (Plan, error)`
`4603`	`4603`	`if !ctx.DatabaseExists(string(stmt.DatabaseName), nil) {`
`4604`	`4604`	`return nil, moerr.NewInternalError(ctx.GetContext(), "database "+string(stmt.DatabaseName)+" does not exist")`
`4605`	`4605`	`}`
`4606`		`- objRef, tableDef, err := ctx.Resolve(string(stmt.DatabaseName), string(stmt.TableName), nil)`
`4607`		`- if err != nil {`
`4608`		`- return nil, err`
`4609`		`- }`
	`4606`	`+ objRef, tableDef := ctx.Resolve(string(stmt.DatabaseName), string(stmt.TableName), nil)`
`4610`	`4607`	`if objRef == nil \|\| tableDef == nil {`
`4611`	`4608`	`return nil, moerr.NewInternalError(ctx.GetContext(), "table "+string(stmt.DatabaseName)+"."+string(stmt.TableName)+" does not exist")`
`4612`	`4609`	`}`