diff --git a/legend-engine-xts-persistence/legend-engine-xt-persistence-component/legend-engine-xt-persistence-component-relational-snowflake/src/main/java/org/finos/legend/engine/persistence/components/relational/snowflake/SnowflakeSink.java b/legend-engine-xts-persistence/legend-engine-xt-persistence-component/legend-engine-xt-persistence-component-relational-snowflake/src/main/java/org/finos/legend/engine/persistence/components/relational/snowflake/SnowflakeSink.java
index f007e918908..d8bcf7d5e17 100644
--- a/legend-engine-xts-persistence/legend-engine-xt-persistence-component/legend-engine-xt-persistence-component-relational-snowflake/src/main/java/org/finos/legend/engine/persistence/components/relational/snowflake/SnowflakeSink.java
+++ b/legend-engine-xts-persistence/legend-engine-xt-persistence-component/legend-engine-xt-persistence-component-relational-snowflake/src/main/java/org/finos/legend/engine/persistence/components/relational/snowflake/SnowflakeSink.java
@@ -622,22 +622,22 @@ private void appendLoadQueryStats(Executor<SqlGen, TabularData, SqlPlan> executo
                             Object externalScan = queryStats.get(QueryStatsLogicalPlanUtils.EXTERNAL_BYTES_SCANNED_ALIAS);
                             if (externalScan != null)
                             {
-                                stats.put(StatisticName.INPUT_FILES_BYTES_SCANNED, externalScan);
+                                stats.put(StatisticName.INPUT_FILES_BYTES_SCANNED, Long.parseLong(String.valueOf(externalScan)));
                             }
                             else
                             {
-                                stats.put(StatisticName.INPUT_FILES_BYTES_SCANNED, 0);
+                                stats.put(StatisticName.INPUT_FILES_BYTES_SCANNED, 0L);
                             }
                             break;
                         case QueryStatsLogicalPlanUtils.INSERT_STAGE:
                             Object insert = queryStats.get(QueryStatsLogicalPlanUtils.INPUT_ROWS_ALIAS);
                             if (insert != null)
                             {
-                                stats.put(StatisticName.INCOMING_RECORD_COUNT, insert);
+                                stats.put(StatisticName.INCOMING_RECORD_COUNT, Long.parseLong(String.valueOf(insert)));
                             }
                             else
                             {
-                                stats.put(StatisticName.INCOMING_RECORD_COUNT, 0);
+                                stats.put(StatisticName.INCOMING_RECORD_COUNT, 0L);
                             }
                             break;
                     }