From 3621561333b453f58b41ffc00d901b9e7a3e43e2 Mon Sep 17 00:00:00 2001 From: Jeff Xiang Date: Wed, 23 Oct 2024 12:53:25 -0400 Subject: [PATCH] Skip config logging in tests --- .../pinterest/flink/connector/psc/sink/PscCommitterTest.java | 2 +- .../flink/connector/psc/source/reader/PscSourceReaderTest.java | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/psc-flink/src/test/java/com/pinterest/flink/connector/psc/sink/PscCommitterTest.java b/psc-flink/src/test/java/com/pinterest/flink/connector/psc/sink/PscCommitterTest.java index e30d3c7..702fd71 100644 --- a/psc-flink/src/test/java/com/pinterest/flink/connector/psc/sink/PscCommitterTest.java +++ b/psc-flink/src/test/java/com/pinterest/flink/connector/psc/sink/PscCommitterTest.java @@ -135,7 +135,7 @@ Properties getProperties() { properties.setProperty("psc.discovery.connection.urls", "http://localhost:1"); properties.setProperty("psc.discovery.security.protocols", StringUtils.repeat("plaintext", ",", 1)); - + properties.setProperty(PscConfiguration.PSC_CONFIG_LOGGING_ENABLED, "false"); return properties; } } diff --git a/psc-flink/src/test/java/com/pinterest/flink/connector/psc/source/reader/PscSourceReaderTest.java b/psc-flink/src/test/java/com/pinterest/flink/connector/psc/source/reader/PscSourceReaderTest.java index 67a8bf8..747ded3 100644 --- a/psc-flink/src/test/java/com/pinterest/flink/connector/psc/source/reader/PscSourceReaderTest.java +++ b/psc-flink/src/test/java/com/pinterest/flink/connector/psc/source/reader/PscSourceReaderTest.java @@ -511,6 +511,7 @@ private SourceReader createReader( throws Exception { props.setProperty(PscFlinkConfiguration.CLUSTER_URI_CONFIG, PscTestEnvironmentWithKafkaAsPubSub.PSC_TEST_TOPIC_URI_PREFIX); props.setProperty(PscConfiguration.PSC_METRICS_FREQUENCY_MS, "100"); + props.setProperty(PscConfiguration.PSC_CONFIG_LOGGING_ENABLED, "false"); if (!props.containsKey(PscConfiguration.PSC_CONSUMER_GROUP_ID)) { props.setProperty(PscConfiguration.PSC_CONSUMER_GROUP_ID, "test-group-id"); }