From 10e5ad492540a47e02c5ad61b7af0b5c81ff6d43 Mon Sep 17 00:00:00 2001 From: revi cheng Date: Tue, 17 Oct 2023 09:48:47 -0700 Subject: [PATCH] [SNOW-934984] Update Avro version for security vulnerability (#718) --- pom_confluent.xml | 2 +- .../kafka/connector/internal/TombstoneRecordIngestionIT.java | 4 ++-- test/perf_test/pom.xml | 4 ++-- 3 files changed, 5 insertions(+), 5 deletions(-) diff --git a/pom_confluent.xml b/pom_confluent.xml index 76a963be21..b6926f0667 100644 --- a/pom_confluent.xml +++ b/pom_confluent.xml @@ -398,7 +398,7 @@ org.apache.avro avro - 1.11.1 + 1.11.3 com.fasterxml.jackson.core diff --git a/src/test/java/com/snowflake/kafka/connector/internal/TombstoneRecordIngestionIT.java b/src/test/java/com/snowflake/kafka/connector/internal/TombstoneRecordIngestionIT.java index 45318216fd..00086a1d81 100644 --- a/src/test/java/com/snowflake/kafka/connector/internal/TombstoneRecordIngestionIT.java +++ b/src/test/java/com/snowflake/kafka/connector/internal/TombstoneRecordIngestionIT.java @@ -214,8 +214,8 @@ private void testIngestTombstoneRunner( this.behavior == SnowflakeSinkConnectorConfig.BehaviorOnNullValues.DEFAULT ? sinkRecords.size() : 1; - TestUtils.assertWithRetry(() -> TestUtils.tableSize(table) == expectedOffset, 10, 5); + TestUtils.assertWithRetry(() -> TestUtils.tableSize(table) == expectedOffset, 10, 20); TestUtils.assertWithRetry( - () -> service.getOffset(new TopicPartition(topic, partition)) == expectedOffset, 10, 5); + () -> service.getOffset(new TopicPartition(topic, partition)) == expectedOffset, 10, 20); } } diff --git a/test/perf_test/pom.xml b/test/perf_test/pom.xml index b8789382d8..311a8416d6 100644 --- a/test/perf_test/pom.xml +++ b/test/perf_test/pom.xml @@ -54,7 +54,7 @@ org.apache.avro avro - 1.11.1 + 1.11.3 @@ -63,7 +63,7 @@ org.apache.avro avro-maven-plugin - 1.11.1 + 1.11.3 generate-sources