[incubator-devlake] branch main updated: fix: cached plan must not change result type in customize (#4868)

[zhangliang2022]

This is an automated email from the ASF dual-hosted git repository.

zhangliang2022 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-devlake.git


The following commit(s) were added to refs/heads/main by this push:
     new b664b4de6 fix: cached plan must not change result type in customize 
(#4868)
b664b4de6 is described below

commit b664b4de6e41ea4f1e7d0485cbf0573eabc4a265
Author: abeizn <zikuan...@merico.dev>
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()