Skip config logging in tests

pinterest · Oct 23, 2024 · 3621561 · 3621561
1 parent f85ae75
commit 3621561
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 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
@@ -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/...nk/src/test/java/com/pinterest/flink/connector/psc/source/reader/PscSourceReaderTest.java b/...nk/src/test/java/com/pinterest/flink/connector/psc/source/reader/PscSourceReaderTest.java
@@ -511,6 +511,7 @@ private SourceReader<Integer, PscTopicUriPartitionSplit> 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");
         }