This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 77cd942f51e [fix][test] Fix that some test cases are not running as
expected on CI (#21532)
77cd942f51e is described below
commit 77cd942f51ea0fecdcae789504a2f5987b79a813
Author: Yuri Mizushima <[email protected]>
AuthorDate: Sat Nov 11 06:56:41 2023 +0900
[fix][test] Fix that some test cases are not running as expected on CI
(#21532)
---
....java => MangedLedgerInterceptorImpl2Test.java} | 4 +--
.../worker/PulsarFunctionLocalRunTest.java | 34 +++++++++++-----------
...TestUtils.java => TestPulsarFunctionUtils.java} | 3 +-
.../apache/pulsar/io/PulsarBatchSourceE2ETest.java | 8 ++---
.../apache/pulsar/io/PulsarFunctionE2ETest.java | 12 ++++----
.../org/apache/pulsar/io/PulsarSinkE2ETest.java | 18 ++++++------
.../org/apache/pulsar/io/PulsarSourceE2ETest.java | 8 ++---
...Auth.java => ProxyKeyStoreTlsWithAuthTest.java} | 2 +-
...h.java => ProxyKeyStoreTlsWithoutAuthTest.java} | 2 +-
...TestWithAuth.java => ProxyTlsWithAuthTest.java} | 2 +-
10 files changed, 47 insertions(+), 46 deletions(-)
diff --git
a/pulsar-broker/src/test/java/org/apache/bookkeeper/mledger/impl/MangedLedgerInterceptorImplTest2.java
b/pulsar-broker/src/test/java/org/apache/bookkeeper/mledger/impl/MangedLedgerInterceptorImpl2Test.java
similarity index 96%
rename from
pulsar-broker/src/test/java/org/apache/bookkeeper/mledger/impl/MangedLedgerInterceptorImplTest2.java
rename to
pulsar-broker/src/test/java/org/apache/bookkeeper/mledger/impl/MangedLedgerInterceptorImpl2Test.java
index 080ef9ea4c5..1be66a7f9d8 100644
---
a/pulsar-broker/src/test/java/org/apache/bookkeeper/mledger/impl/MangedLedgerInterceptorImplTest2.java
+++
b/pulsar-broker/src/test/java/org/apache/bookkeeper/mledger/impl/MangedLedgerInterceptorImpl2Test.java
@@ -39,9 +39,9 @@ import org.testng.annotations.Test;
*/
@Slf4j
@Test(groups = "broker")
-public class MangedLedgerInterceptorImplTest2 extends MockedBookKeeperTestCase
{
+public class MangedLedgerInterceptorImpl2Test extends MockedBookKeeperTestCase
{
- public static void switchLedgerManually(ManagedLedgerImpl ledger){
+ private static void switchLedgerManually(ManagedLedgerImpl ledger){
LedgerHandle originalLedgerHandle = ledger.currentLedger;
ledger.ledgerClosed(ledger.currentLedger);
ledger.createLedgerAfterClosed();
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/functions/worker/PulsarFunctionLocalRunTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/functions/worker/PulsarFunctionLocalRunTest.java
index aa190cd2e0a..aff13f1a1ca 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/functions/worker/PulsarFunctionLocalRunTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/functions/worker/PulsarFunctionLocalRunTest.java
@@ -538,15 +538,15 @@ public class PulsarFunctionLocalRunTest {
totalMsgs);
// validate prometheus metrics
- String prometheusMetrics =
PulsarFunctionTestUtils.getPrometheusMetrics(metricsPort);
+ String prometheusMetrics =
TestPulsarFunctionUtils.getPrometheusMetrics(metricsPort);
log.info("prometheus metrics: {}", prometheusMetrics);
- Map<String, PulsarFunctionTestUtils.Metric> metricsMap = new
HashMap<>();
+ Map<String, TestPulsarFunctionUtils.Metric> metricsMap = new
HashMap<>();
Arrays.asList(prometheusMetrics.split("\n")).forEach(line -> {
if
(line.startsWith("pulsar_function_processed_successfully_total")) {
- Map<String, PulsarFunctionTestUtils.Metric> metrics =
PulsarFunctionTestUtils.parseMetrics(line);
+ Map<String, TestPulsarFunctionUtils.Metric> metrics =
TestPulsarFunctionUtils.parseMetrics(line);
assertFalse(metrics.isEmpty());
- PulsarFunctionTestUtils.Metric m =
metrics.get("pulsar_function_processed_successfully_total");
+ TestPulsarFunctionUtils.Metric m =
metrics.get("pulsar_function_processed_successfully_total");
if (m != null) {
metricsMap.put(m.tags.get("instance_id"), m);
}
@@ -556,7 +556,7 @@ public class PulsarFunctionLocalRunTest {
double totalMsgRecv = 0.0;
for (int i = 0; i < parallelism; i++) {
- PulsarFunctionTestUtils.Metric m =
metricsMap.get(String.valueOf(i));
+ TestPulsarFunctionUtils.Metric m =
metricsMap.get(String.valueOf(i));
Assert.assertNotNull(m);
assertEquals(m.tags.get("cluster"), config.getClusterName());
assertEquals(m.tags.get("instance_id"), String.valueOf(i));
@@ -843,15 +843,15 @@ public class PulsarFunctionLocalRunTest {
assertEquals(admin.topics().getStats(sinkTopic).getPublishers().size(),
parallelism);
// validate prometheus metrics
- String prometheusMetrics =
PulsarFunctionTestUtils.getPrometheusMetrics(metricsPort);
+ String prometheusMetrics =
TestPulsarFunctionUtils.getPrometheusMetrics(metricsPort);
log.info("prometheus metrics: {}", prometheusMetrics);
- Map<String, PulsarFunctionTestUtils.Metric> metricsMap = new
HashMap<>();
+ Map<String, TestPulsarFunctionUtils.Metric> metricsMap = new
HashMap<>();
Arrays.asList(prometheusMetrics.split("\n")).forEach(line -> {
if (line.startsWith("pulsar_source_written_total")) {
- Map<String, PulsarFunctionTestUtils.Metric> metrics =
PulsarFunctionTestUtils.parseMetrics(line);
+ Map<String, TestPulsarFunctionUtils.Metric> metrics =
TestPulsarFunctionUtils.parseMetrics(line);
assertFalse(metrics.isEmpty());
- PulsarFunctionTestUtils.Metric m =
metrics.get("pulsar_source_written_total");
+ TestPulsarFunctionUtils.Metric m =
metrics.get("pulsar_source_written_total");
if (m != null) {
metricsMap.put(m.tags.get("instance_id"), m);
}
@@ -860,7 +860,7 @@ public class PulsarFunctionLocalRunTest {
Assert.assertEquals(metricsMap.size(), parallelism);
for (int i = 0; i < parallelism; i++) {
- PulsarFunctionTestUtils.Metric m =
metricsMap.get(String.valueOf(i));
+ TestPulsarFunctionUtils.Metric m =
metricsMap.get(String.valueOf(i));
Assert.assertNotNull(m);
assertEquals(m.tags.get("cluster"), config.getClusterName());
assertEquals(m.tags.get("instance_id"), String.valueOf(i));
@@ -1002,22 +1002,22 @@ public class PulsarFunctionLocalRunTest {
}, 5, 200));
// validate prometheus metrics
- String prometheusMetrics =
PulsarFunctionTestUtils.getPrometheusMetrics(metricsPort);
+ String prometheusMetrics =
TestPulsarFunctionUtils.getPrometheusMetrics(metricsPort);
log.info("prometheus metrics: {}", prometheusMetrics);
- Map<String, PulsarFunctionTestUtils.Metric> metricsMap = new
HashMap<>();
+ Map<String, TestPulsarFunctionUtils.Metric> metricsMap = new
HashMap<>();
Arrays.asList(prometheusMetrics.split("\n")).forEach(line -> {
if (line.startsWith("pulsar_sink_written_total")) {
- Map<String, PulsarFunctionTestUtils.Metric> metrics =
PulsarFunctionTestUtils.parseMetrics(line);
+ Map<String, TestPulsarFunctionUtils.Metric> metrics =
TestPulsarFunctionUtils.parseMetrics(line);
assertFalse(metrics.isEmpty());
- PulsarFunctionTestUtils.Metric m =
metrics.get("pulsar_sink_written_total");
+ TestPulsarFunctionUtils.Metric m =
metrics.get("pulsar_sink_written_total");
if (m != null) {
metricsMap.put(m.tags.get("instance_id"), m);
}
} else if (line.startsWith("pulsar_sink_sink_exceptions_total")) {
- Map<String, PulsarFunctionTestUtils.Metric> metrics =
PulsarFunctionTestUtils.parseMetrics(line);
+ Map<String, TestPulsarFunctionUtils.Metric> metrics =
TestPulsarFunctionUtils.parseMetrics(line);
assertFalse(metrics.isEmpty());
- PulsarFunctionTestUtils.Metric m =
metrics.get("pulsar_sink_sink_exceptions_total");
+ TestPulsarFunctionUtils.Metric m =
metrics.get("pulsar_sink_sink_exceptions_total");
if (m == null) {
m = metrics.get("pulsar_sink_sink_exceptions_1min_total");
}
@@ -1028,7 +1028,7 @@ public class PulsarFunctionLocalRunTest {
double totalNumRecvMsg = 0;
for (int i = 0; i < parallelism; i++) {
- PulsarFunctionTestUtils.Metric m =
metricsMap.get(String.valueOf(i));
+ TestPulsarFunctionUtils.Metric m =
metricsMap.get(String.valueOf(i));
Assert.assertNotNull(m);
assertEquals(m.tags.get("cluster"), config.getClusterName());
assertEquals(m.tags.get("instance_id"), String.valueOf(i));
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/functions/worker/PulsarFunctionTestUtils.java
b/pulsar-broker/src/test/java/org/apache/pulsar/functions/worker/TestPulsarFunctionUtils.java
similarity index 98%
rename from
pulsar-broker/src/test/java/org/apache/pulsar/functions/worker/PulsarFunctionTestUtils.java
rename to
pulsar-broker/src/test/java/org/apache/pulsar/functions/worker/TestPulsarFunctionUtils.java
index 292c571c3bc..71f10cc2cbc 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/functions/worker/PulsarFunctionTestUtils.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/functions/worker/TestPulsarFunctionUtils.java
@@ -39,7 +39,8 @@ import org.testng.annotations.Test;
import static com.google.common.base.Preconditions.checkArgument;
@Slf4j
-public class PulsarFunctionTestUtils {
+@Test(groups = "functions-worker")
+public class TestPulsarFunctionUtils {
public static String getPrometheusMetrics(int metricsPort) throws
IOException {
StringBuilder result = new StringBuilder();
URL url = new URL(String.format("http://%s:%s/metrics";, "localhost",
metricsPort));
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/io/PulsarBatchSourceE2ETest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/io/PulsarBatchSourceE2ETest.java
index 90a1a537502..3fa4aeb550c 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/io/PulsarBatchSourceE2ETest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/io/PulsarBatchSourceE2ETest.java
@@ -35,7 +35,7 @@ import org.apache.pulsar.common.io.SourceConfig;
import org.apache.pulsar.common.policies.data.TopicStats;
import org.apache.pulsar.functions.utils.FunctionCommon;
-import org.apache.pulsar.functions.worker.PulsarFunctionTestUtils;
+import org.apache.pulsar.functions.worker.TestPulsarFunctionUtils;
import org.apache.pulsar.io.batchdiscovery.ImmediateTriggerer;
import org.testng.annotations.Test;
@@ -102,11 +102,11 @@ public class PulsarBatchSourceE2ETest extends
AbstractPulsarE2ETest {
}, 50, 150);
assertEquals(admin.topics().getStats(sinkTopic2).getPublishers().size(), 1);
- String prometheusMetrics =
PulsarFunctionTestUtils.getPrometheusMetrics(pulsar.getListenPortHTTP().get());
+ String prometheusMetrics =
TestPulsarFunctionUtils.getPrometheusMetrics(pulsar.getListenPortHTTP().get());
log.info("prometheusMetrics: {}", prometheusMetrics);
- Map<String, PulsarFunctionTestUtils.Metric> metrics =
PulsarFunctionTestUtils.parseMetrics(prometheusMetrics);
- PulsarFunctionTestUtils.Metric m =
metrics.get("pulsar_source_received_total");
+ Map<String, TestPulsarFunctionUtils.Metric> metrics =
TestPulsarFunctionUtils.parseMetrics(prometheusMetrics);
+ TestPulsarFunctionUtils.Metric m =
metrics.get("pulsar_source_received_total");
assertEquals(m.tags.get("cluster"), config.getClusterName());
assertEquals(m.tags.get("instance_id"), "0");
assertEquals(m.tags.get("name"), sourceName);
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/io/PulsarFunctionE2ETest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/io/PulsarFunctionE2ETest.java
index d549dca1e87..ab4925bfeb8 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/io/PulsarFunctionE2ETest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/io/PulsarFunctionE2ETest.java
@@ -67,7 +67,7 @@ import org.apache.pulsar.functions.api.Context;
import org.apache.pulsar.functions.instance.InstanceUtils;
import org.apache.pulsar.functions.utils.FunctionCommon;
import org.apache.pulsar.functions.worker.FunctionRuntimeManager;
-import org.apache.pulsar.functions.worker.PulsarFunctionTestUtils;
+import org.apache.pulsar.functions.worker.TestPulsarFunctionUtils;
import org.awaitility.Awaitility;
import org.testng.Assert;
import org.testng.annotations.Test;
@@ -373,11 +373,11 @@ public class PulsarFunctionE2ETest extends
AbstractPulsarE2ETest {
functionStats.getAvgProcessLatency());
// validate prometheus metrics empty
- String prometheusMetrics =
PulsarFunctionTestUtils.getPrometheusMetrics(pulsar.getListenPortHTTP().get());
+ String prometheusMetrics =
TestPulsarFunctionUtils.getPrometheusMetrics(pulsar.getListenPortHTTP().get());
log.info("prometheus metrics: {}", prometheusMetrics);
- Map<String, PulsarFunctionTestUtils.Metric> metrics =
PulsarFunctionTestUtils.parseMetrics(prometheusMetrics);
- PulsarFunctionTestUtils.Metric m =
metrics.get("pulsar_function_received_total");
+ Map<String, TestPulsarFunctionUtils.Metric> metrics =
TestPulsarFunctionUtils.parseMetrics(prometheusMetrics);
+ TestPulsarFunctionUtils.Metric m =
metrics.get("pulsar_function_received_total");
assertEquals(m.tags.get("cluster"), config.getClusterName());
assertEquals(m.tags.get("instance_id"), "0");
assertEquals(m.tags.get("name"), functionName);
@@ -533,10 +533,10 @@ public class PulsarFunctionE2ETest extends
AbstractPulsarE2ETest {
assertEquals(functionInstanceStats,
functionStats.instances.get(0).getMetrics());
// validate prometheus metrics
- prometheusMetrics =
PulsarFunctionTestUtils.getPrometheusMetrics(pulsar.getListenPortHTTP().get());
+ prometheusMetrics =
TestPulsarFunctionUtils.getPrometheusMetrics(pulsar.getListenPortHTTP().get());
log.info("prometheus metrics: {}", prometheusMetrics);
- metrics = PulsarFunctionTestUtils.parseMetrics(prometheusMetrics);
+ metrics = TestPulsarFunctionUtils.parseMetrics(prometheusMetrics);
m = metrics.get("pulsar_function_received_total");
assertEquals(m.tags.get("cluster"), config.getClusterName());
assertEquals(m.tags.get("instance_id"), "0");
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/io/PulsarSinkE2ETest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/io/PulsarSinkE2ETest.java
index 7e0dbabb105..7edc87bb996 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/io/PulsarSinkE2ETest.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/io/PulsarSinkE2ETest.java
@@ -53,7 +53,7 @@ import org.apache.pulsar.compaction.TwoPhaseCompactor;
import org.apache.pulsar.functions.LocalRunner;
import org.apache.pulsar.functions.api.Record;
import org.apache.pulsar.functions.utils.FunctionCommon;
-import org.apache.pulsar.functions.worker.PulsarFunctionTestUtils;
+import org.apache.pulsar.functions.worker.TestPulsarFunctionUtils;
import org.apache.pulsar.io.core.Sink;
import org.apache.pulsar.io.core.SinkContext;
import org.awaitility.Awaitility;
@@ -122,9 +122,9 @@ public class PulsarSinkE2ETest extends
AbstractPulsarE2ETest {
// 5 Sink should only read compacted value, so we will only receive
compacted messages
Awaitility.await().ignoreExceptions().untilAsserted(() -> {
- String prometheusMetrics =
PulsarFunctionTestUtils.getPrometheusMetrics(pulsar.getListenPortHTTP().get());
- Map<String, PulsarFunctionTestUtils.Metric> metrics =
PulsarFunctionTestUtils.parseMetrics(prometheusMetrics);
- PulsarFunctionTestUtils.Metric m =
metrics.get("pulsar_sink_received_total");
+ String prometheusMetrics =
TestPulsarFunctionUtils.getPrometheusMetrics(pulsar.getListenPortHTTP().get());
+ Map<String, TestPulsarFunctionUtils.Metric> metrics =
TestPulsarFunctionUtils.parseMetrics(prometheusMetrics);
+ TestPulsarFunctionUtils.Metric m =
metrics.get("pulsar_sink_received_total");
assertEquals(m.value, maxKeys);
});
}
@@ -271,11 +271,11 @@ public class PulsarSinkE2ETest extends
AbstractPulsarE2ETest {
status.getInstances().forEach(sinkInstanceStatus ->
assertEquals(sinkInstanceStatus.status.numSystemExceptions, 0));
// validate prometheus metrics empty
- String prometheusMetrics =
PulsarFunctionTestUtils.getPrometheusMetrics(pulsar.getListenPortHTTP().get());
+ String prometheusMetrics =
TestPulsarFunctionUtils.getPrometheusMetrics(pulsar.getListenPortHTTP().get());
log.info("prometheus metrics: {}", prometheusMetrics);
- Map<String, PulsarFunctionTestUtils.Metric> metrics =
PulsarFunctionTestUtils.parseMetrics(prometheusMetrics);
- PulsarFunctionTestUtils.Metric m =
metrics.get("pulsar_sink_received_total");
+ Map<String, TestPulsarFunctionUtils.Metric> metrics =
TestPulsarFunctionUtils.parseMetrics(prometheusMetrics);
+ TestPulsarFunctionUtils.Metric m =
metrics.get("pulsar_sink_received_total");
assertEquals(m.tags.get("cluster"), config.getClusterName());
assertEquals(m.tags.get("instance_id"), "0");
assertEquals(m.tags.get("name"), sinkName);
@@ -364,10 +364,10 @@ public class PulsarSinkE2ETest extends
AbstractPulsarE2ETest {
status.getInstances().forEach(sinkInstanceStatus ->
assertEquals(sinkInstanceStatus.status.numSystemExceptions, 0));
// get stats after producing
- prometheusMetrics =
PulsarFunctionTestUtils.getPrometheusMetrics(pulsar.getListenPortHTTP().get());
+ prometheusMetrics =
TestPulsarFunctionUtils.getPrometheusMetrics(pulsar.getListenPortHTTP().get());
log.info("prometheusMetrics: {}", prometheusMetrics);
- metrics = PulsarFunctionTestUtils.parseMetrics(prometheusMetrics);
+ metrics = TestPulsarFunctionUtils.parseMetrics(prometheusMetrics);
m = metrics.get("pulsar_sink_received_total");
assertEquals(m.tags.get("cluster"), config.getClusterName());
assertEquals(m.tags.get("instance_id"), "0");
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/io/PulsarSourceE2ETest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/io/PulsarSourceE2ETest.java
index 99d16447bf8..1b7ffca2283 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/io/PulsarSourceE2ETest.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/io/PulsarSourceE2ETest.java
@@ -33,7 +33,7 @@ import org.apache.pulsar.common.functions.Utils;
import org.apache.pulsar.common.io.SourceConfig;
import org.apache.pulsar.common.policies.data.TopicStats;
import org.apache.pulsar.functions.utils.FunctionCommon;
-import org.apache.pulsar.functions.worker.PulsarFunctionTestUtils;
+import org.apache.pulsar.functions.worker.TestPulsarFunctionUtils;
import org.testng.annotations.Test;
import com.google.common.collect.Lists;
@@ -106,11 +106,11 @@ public class PulsarSourceE2ETest extends
AbstractPulsarE2ETest {
}, 50, 150);
assertEquals(admin.topics().getStats(sinkTopic2).getPublishers().size(), 1);
- String prometheusMetrics =
PulsarFunctionTestUtils.getPrometheusMetrics(pulsar.getListenPortHTTP().get());
+ String prometheusMetrics =
TestPulsarFunctionUtils.getPrometheusMetrics(pulsar.getListenPortHTTP().get());
log.info("prometheusMetrics: {}", prometheusMetrics);
- Map<String, PulsarFunctionTestUtils.Metric> metrics =
PulsarFunctionTestUtils.parseMetrics(prometheusMetrics);
- PulsarFunctionTestUtils.Metric m =
metrics.get("pulsar_source_received_total");
+ Map<String, TestPulsarFunctionUtils.Metric> metrics =
TestPulsarFunctionUtils.parseMetrics(prometheusMetrics);
+ TestPulsarFunctionUtils.Metric m =
metrics.get("pulsar_source_received_total");
assertEquals(m.tags.get("cluster"), config.getClusterName());
assertEquals(m.tags.get("instance_id"), "0");
assertEquals(m.tags.get("name"), sourceName);
diff --git
a/pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyKeyStoreTlsTestWithAuth.java
b/pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyKeyStoreTlsWithAuthTest.java
similarity index 99%
rename from
pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyKeyStoreTlsTestWithAuth.java
rename to
pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyKeyStoreTlsWithAuthTest.java
index 6a9745f0550..1f21281a6f6 100644
---
a/pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyKeyStoreTlsTestWithAuth.java
+++
b/pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyKeyStoreTlsWithAuthTest.java
@@ -51,7 +51,7 @@ import org.testng.annotations.BeforeMethod;
import org.testng.annotations.Test;
@Slf4j
-public class ProxyKeyStoreTlsTestWithAuth extends MockedPulsarServiceBaseTest {
+public class ProxyKeyStoreTlsWithAuthTest extends MockedPulsarServiceBaseTest {
private ProxyService proxyService;
private ProxyConfiguration proxyConfig = new ProxyConfiguration();
diff --git
a/pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyKeyStoreTlsTestWithoutAuth.java
b/pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyKeyStoreTlsWithoutAuthTest.java
similarity index 99%
rename from
pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyKeyStoreTlsTestWithoutAuth.java
rename to
pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyKeyStoreTlsWithoutAuthTest.java
index 4ceb85a8524..d7935755ce0 100644
---
a/pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyKeyStoreTlsTestWithoutAuth.java
+++
b/pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyKeyStoreTlsWithoutAuthTest.java
@@ -47,7 +47,7 @@ import org.testng.annotations.BeforeMethod;
import org.testng.annotations.Test;
@Slf4j
-public class ProxyKeyStoreTlsTestWithoutAuth extends
MockedPulsarServiceBaseTest {
+public class ProxyKeyStoreTlsWithoutAuthTest extends
MockedPulsarServiceBaseTest {
private ProxyService proxyService;
private ProxyConfiguration proxyConfig = new ProxyConfiguration();
diff --git
a/pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyTlsTestWithAuth.java
b/pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyTlsWithAuthTest.java
similarity index 98%
rename from
pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyTlsTestWithAuth.java
rename to
pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyTlsWithAuthTest.java
index f6dff8fc3ea..ec5cace8a06 100644
---
a/pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyTlsTestWithAuth.java
+++
b/pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyTlsWithAuthTest.java
@@ -34,7 +34,7 @@ import org.testng.annotations.AfterClass;
import org.testng.annotations.BeforeClass;
import org.testng.annotations.Test;
-public class ProxyTlsTestWithAuth extends MockedPulsarServiceBaseTest {
+public class ProxyTlsWithAuthTest extends MockedPulsarServiceBaseTest {
private ProxyService proxyService;
private ProxyConfiguration proxyConfig = new ProxyConfiguration();
