From 3cc10db28c498d04d31ae780917a204b1eb529e8 Mon Sep 17 00:00:00 2001 From: kumuwu Date: Mon, 23 Dec 2024 16:44:27 +0800 Subject: [PATCH] Fix stats type --- .../components/relational/snowflake/SnowflakeSink.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) 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 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; }