From 31bdbdbb7e15d1f211d415df0a5d8e7e4ed47d4d Mon Sep 17 00:00:00 2001 From: Alec Huang Date: Fri, 18 Oct 2024 13:12:41 -0700 Subject: [PATCH] Set NV/NDV args to false in FDN mode --- .../ingest/streaming/internal/ParquetRowBuffer.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/main/java/net/snowflake/ingest/streaming/internal/ParquetRowBuffer.java b/src/main/java/net/snowflake/ingest/streaming/internal/ParquetRowBuffer.java index c2197da24..96a1156ce 100644 --- a/src/main/java/net/snowflake/ingest/streaming/internal/ParquetRowBuffer.java +++ b/src/main/java/net/snowflake/ingest/streaming/internal/ParquetRowBuffer.java @@ -114,8 +114,8 @@ public void setupSchema(List columns) { column.getOrdinal(), null /* fieldId */, parquetType.isPrimitive() ? parquetType.asPrimitiveType() : null, - clientBufferParameters.isEnableDistinctValuesCount(), - clientBufferParameters.isEnableValuesCount())); + false /* enableDistinctValuesCount */, + false /* enableValuesCount */)); if (onErrorOption == OpenChannelRequest.OnErrorOption.ABORT || onErrorOption == OpenChannelRequest.OnErrorOption.SKIP_BATCH) { @@ -131,8 +131,8 @@ public void setupSchema(List columns) { column.getOrdinal(), null /* fieldId */, parquetType.isPrimitive() ? parquetType.asPrimitiveType() : null, - clientBufferParameters.isEnableDistinctValuesCount(), - clientBufferParameters.isEnableValuesCount())); + false /* enableDistinctValuesCount */, + false /* enableValuesCount */)); } }