This is an automated email from the ASF dual-hosted git repository.
abeizn pushed a commit to branch release-v0.16
in repository https://gitbox.apache.org/repos/asf/incubator-devlake.git
The following commit(s) were added to refs/heads/release-v0.16 by this push:
new 002ca6137 fix: cached plan must not change result type in customize
(#4868)
002ca6137 is described below
commit 002ca6137cc5a20bc4db5f61e74da8fe97354379
Author: abeizn <[email protected]>
AuthorDate: Mon Apr 10 10:26:04 2023 +0800
fix: cached plan must not change result type in customize (#4868)
---
backend/plugins/starrocks/tasks/tasks.go | 14 +++++++++++++-
1 file changed, 13 insertions(+), 1 deletion(-)
diff --git a/backend/plugins/starrocks/tasks/tasks.go
b/backend/plugins/starrocks/tasks/tasks.go
index b69dc5197..f72f23ce6 100644
--- a/backend/plugins/starrocks/tasks/tasks.go
+++ b/backend/plugins/starrocks/tasks/tasks.go
@@ -247,7 +247,19 @@ func copyDataToDst(dc *DataConfigParams, columnMap
map[string]string, orderBy st
dal.Orderby(orderBy),
)
if err != nil {
- return err
+ if strings.Contains(err.Error(), "cached plan must not change
result type") {
+ logger.Warn(err, "skip err: cached plan must not change
result type")
+ rows, err = db.Cursor(
+ dal.From(table),
+ dal.Orderby(orderBy),
+ )
+ if err != nil {
+ return err
+ }
+ } else {
+ return err
+ }
+
}
defer rows.Close()
