From 3be0095b938bd876b1d34d57671f4e5843e67c9a Mon Sep 17 00:00:00 2001 From: superxan <33817352+SuperRxan@users.noreply.github.com> Date: Fri, 29 Jul 2022 08:43:18 +0800 Subject: [PATCH] fix(sink): report io error when write to tdengine/sql error (#1345) Signed-off-by: Jianxiang Ran --- extensions/sinks/sql/sql.go | 3 ++- extensions/sinks/tdengine/tdengine.go | 3 ++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/extensions/sinks/sql/sql.go b/extensions/sinks/sql/sql.go index bad0f36ae3..3d50885c7e 100644 --- a/extensions/sinks/sql/sql.go +++ b/extensions/sinks/sql/sql.go @@ -21,6 +21,7 @@ import ( "github.com/lf-edge/ekuiper/extensions/sqldatabase/driver" "github.com/lf-edge/ekuiper/pkg/api" "github.com/lf-edge/ekuiper/pkg/cast" + "github.com/lf-edge/ekuiper/pkg/errorx" "github.com/xo/dburl" "reflect" "strings" @@ -109,7 +110,7 @@ func (m *sqlSink) writeToDB(ctx api.StreamContext, sqlStr *string) error { ctx.GetLogger().Debugf(*sqlStr) rows, err := m.db.Query(*sqlStr) if err != nil { - return err + return fmt.Errorf("%s: %s", errorx.IOErr, err.Error()) } return rows.Close() } diff --git a/extensions/sinks/tdengine/tdengine.go b/extensions/sinks/tdengine/tdengine.go index 30d031c1d7..32d314aacd 100644 --- a/extensions/sinks/tdengine/tdengine.go +++ b/extensions/sinks/tdengine/tdengine.go @@ -21,6 +21,7 @@ import ( "github.com/lf-edge/ekuiper/internal/conf" "github.com/lf-edge/ekuiper/pkg/api" "github.com/lf-edge/ekuiper/pkg/cast" + "github.com/lf-edge/ekuiper/pkg/errorx" _ "github.com/taosdata/driver-go/v2/taosSql" "reflect" "strings" @@ -268,7 +269,7 @@ func (m *taosSink) writeToDB(ctx api.StreamContext, SqlVal *string) error { ctx.GetLogger().Debugf(finalSql) rows, err := m.db.Query(finalSql) if err != nil { - return err + return fmt.Errorf("%s: %s", errorx.IOErr, err.Error()) } rows.Close() return nil