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