From 7857e5ef93fd4f8d8a13b5e2916961bdcc024ec1 Mon Sep 17 00:00:00 2001 From: achettyiitr Date: Tue, 3 Dec 2024 16:50:44 +0530 Subject: [PATCH] fix: discards infos column values --- .../asyncdestinationmanager/snowpipestreaming/discards.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/router/batchrouter/asyncdestinationmanager/snowpipestreaming/discards.go b/router/batchrouter/asyncdestinationmanager/snowpipestreaming/discards.go index bbcf6ec927e..6482910b78e 100644 --- a/router/batchrouter/asyncdestinationmanager/snowpipestreaming/discards.go +++ b/router/batchrouter/asyncdestinationmanager/snowpipestreaming/discards.go @@ -128,7 +128,7 @@ func convertDiscardedInfosToRows(discardInfos []discardInfo) []model.Row { return model.Row{ "column_name": info.colName, - "column_value": info.eventData[info.colName], + "column_value": fmt.Sprintf("%v", info.eventData[info.colName]), "reason": info.reason, "received_at": receivedAt, "row_id": id,