From 79fbacf0ceddfc9f1a822369285f6c79872c7042 Mon Sep 17 00:00:00 2001 From: Alec Huang Date: Wed, 20 Nov 2024 23:14:29 -0800 Subject: [PATCH] addresss comments and fix tests --- .../ingest/streaming/internal/it/IcebergBigFilesIT.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/src/test/java/net/snowflake/ingest/streaming/internal/it/IcebergBigFilesIT.java b/src/test/java/net/snowflake/ingest/streaming/internal/it/IcebergBigFilesIT.java index 90353e81c..a438a2afa 100644 --- a/src/test/java/net/snowflake/ingest/streaming/internal/it/IcebergBigFilesIT.java +++ b/src/test/java/net/snowflake/ingest/streaming/internal/it/IcebergBigFilesIT.java @@ -31,7 +31,6 @@ import net.snowflake.ingest.streaming.OpenChannelRequest; import net.snowflake.ingest.streaming.SnowflakeStreamingIngestChannel; import net.snowflake.ingest.streaming.internal.SnowflakeStreamingIngestClientInternal; -import net.snowflake.ingest.streaming.internal.datatypes.IcebergNumericTypesIT; import net.snowflake.ingest.utils.Constants; import net.snowflake.ingest.utils.HttpUtil; import net.snowflake.ingest.utils.SnowflakeURL; @@ -51,7 +50,7 @@ @Category(IcebergIT.class) @RunWith(Parameterized.class) public class IcebergBigFilesIT { - private static final Logger logger = LoggerFactory.getLogger(IcebergNumericTypesIT.class); + private static final Logger logger = LoggerFactory.getLogger(IcebergBigFilesIT.class); private static final ObjectMapper objectMapper = new ObjectMapper(); @Parameterized.Parameters(name = "icebergSerializationPolicy={0}") @@ -138,7 +137,7 @@ public void testMultiplePartUpload() throws Exception { String.format( "create or replace iceberg table %s(string_col string)" + "catalog = 'SNOWFLAKE' " - + "external_volume = 'exvol_managed' " + + "external_volume = 'streaming_ingest' " + "base_location = 'SDK_IT/%s/%s'" + "storage_serialization_policy = %s;", tableName, database, tableName, icebergSerializationPolicy.name()));