Skip to content

[improve][client] Deduplicate in-progress lookup requests also for HttpLookupService #26293

[improve][client] Deduplicate in-progress lookup requests also for HttpLookupService

[improve][client] Deduplicate in-progress lookup requests also for HttpLookupService #26293

Triggered via pull request November 25, 2025 14:12
Status Failure
Total duration 59m 48s
Artifacts 39

pulsar-ci.yaml

on: pull_request
Preconditions
11s
Preconditions
Build and License check
7m 28s
Build and License check
Matrix: pulsar-test-latest-version-image
Matrix: unit-tests
Matrix: pulsar-java-test-image
Matrix: system-tests
Matrix: flaky-system-tests
CI - Unit - Upload Coverage
0s
CI - Unit - Upload Coverage
Run CodeQL Analysis
0s
Run CodeQL Analysis
Matrix: integration-tests
CI - System - Upload Coverage
2m 23s
CI - System - Upload Coverage
CI - Integration - Upload Coverage
CI - Integration - Upload Coverage
Build Pulsar on MacOS
Build Pulsar on MacOS
OWASP dependency check
OWASP dependency check
Delete system test docker image artifact
13s
Delete system test docker image artifact
Delete integration test docker image artifact
Delete integration test docker image artifact
Pulsar CI checks completed
4s
Pulsar CI checks completed
Fit to window
Zoom out
Zoom in

Annotations

10 errors and 109 warnings
LookupProtocolTest.binaryLookupTest: pulsar-websocket/src/test/java/org/apache/pulsar/websocket/LookupProtocolTest.java#L77
expected [org.apache.pulsar.client.impl.BinaryProtoLookupService] but found [org.apache.pulsar.client.impl.InProgressDeduplicationDecoratorLookupService]
CI - Unit - Other
Process completed with exit code 1.
ProxyWithExtensibleLoadManagerTest.testClientReconnectsToBrokerOnProxyClosing: pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyWithExtensibleLoadManagerTest.java#L272
Cannot locate declared field class org.apache.pulsar.client.impl.InProgressDeduplicationDecoratorLookupService.serviceNameResolver
CI - Unit - Proxy
Process completed with exit code 1.
CI - Unit - Brokers - Broker Group 2
Process completed with exit code 1.
CI - Integration - Kubernetes
Process completed with exit code 1.
Pulsar CI checks completed
Process completed with exit code 1.
CI - Unit - Pulsar Client
Traced leak detected ByteBuf
CI - Unit - Pulsar Client
Traced leak detected ByteBuf
CI - Unit - Pulsar Client
Traced leak detected ByteBuf
CI - Unit - Pulsar Client
Traced leak detected ByteBuf
CI - Unit - Pulsar Client
Traced leak detected ByteBuf
CI - Unit - Pulsar Client
Traced leak detected ByteBuf
CI - Unit - Pulsar Client
Traced leak detected ByteBuf
CI - Unit - Pulsar Client
Traced leak detected ByteBuf
CI - Unit - Pulsar Client
Traced leak detected ByteBuf
CI - Unit - Pulsar Client
Netty leaks found.
CI - Unit - Pulsar Client
Summary: Tests in class org.apache.pulsar.client.impl.ControlledClusterFailoverTest created 1 new threads. There are now 9 threads in total.
CI - Unit - Pulsar Client
Summary: Tests in class org.apache.pulsar.client.impl.auth.oauth2.AuthenticationOAuth2Test created 2 new threads. There are now 10 threads in total.
CI - Unit - Other
Traced leak detected ByteBuf
CI - Unit - Other
Traced leak detected ByteBuf
CI - Unit - Other
Traced leak detected ByteBuf
CI - Unit - Other
Traced leak detected ByteBuf
CI - Unit - Other
Traced leak detected ByteBuf
CI - Unit - Other
Traced leak detected ByteBuf
CI - Unit - Other
Traced leak detected ByteBuf
CI - Unit - Other
Traced leak detected ByteBuf
CI - Unit - Other
Netty leaks found.
CI - Unit - Other
Summary: Tests in class org.apache.pulsar.websocket.LookupProtocolTest created 8 new threads. There are now 17 threads in total.
CI - Unit - Other
Summary: Tests in class org.apache.bookkeeper.mledger.offload.filesystem.impl.FileSystemManagedLedgerOffloaderTest created 5 new threads. There are now 14 threads in total.
CI - Unit - Proxy
Summary: Tests in class org.apache.pulsar.proxy.server.ProxyRolesEnforcementTest created 59 new threads. There are now 68 threads in total.
CI - Unit - Proxy
Summary: Tests in class org.apache.pulsar.proxy.server.ProxyWithExtensibleLoadManagerTest created 4 new threads. There are now 13 threads in total.
CI - Unit - Proxy
Summary: Tests in class org.apache.pulsar.client.impl.AutoCloseUselessClientConProxyTest created 297 new threads. There are now 305 threads in total.
CI - Unit - Proxy
Summary: Tests in class org.apache.pulsar.proxy.server.ProxyAdditionalServletTest created 1 new threads. There are now 9 threads in total.
CI - Unit - Proxy
Summary: Tests in class org.apache.pulsar.proxy.server.ProxyStuckConnectionTest created 1 new threads. There are now 9 threads in total.
CI - Unit - Brokers - Broker Group 2
Traced leak detected ByteBuf
CI - Unit - Brokers - Broker Group 2
Traced leak detected ByteBuf
CI - Unit - Brokers - Broker Group 2
Traced leak detected ByteBuf
CI - Unit - Brokers - Broker Group 2
Traced leak detected ByteBuf
CI - Unit - Brokers - Broker Group 2
Traced leak detected ByteBuf
CI - Unit - Brokers - Broker Group 2
Traced leak detected ByteBuf
CI - Unit - Brokers - Broker Group 2
Traced leak detected HashedWheelTimer
CI - Unit - Brokers - Broker Group 2
Traced leak detected ByteBuf
CI - Unit - Brokers - Broker Group 2
Traced leak detected ByteBuf
CI - Unit - Brokers - Broker Group 2
Netty leaks found.
CI - Unit - Brokers - Broker Group 2
Summary: Tests in class org.apache.pulsar.broker.transaction.TopicTransactionBufferRecoverTest created 96 new threads. There are now 104 threads in total.
CI - Unit - Brokers - Broker Group 2
Summary: Tests in class org.apache.pulsar.broker.transaction.SegmentAbortedTxnProcessorTest created 73 new threads. There are now 81 threads in total.
CI - Unit - Brokers - Broker Group 2
Summary: Tests in class org.apache.pulsar.broker.delayed.DelayedDeliveryTrackerFactoryTest created 1 new threads. There are now 9 threads in total.
CI - Unit - Brokers - Broker Group 2
Summary: Tests in class org.apache.pulsar.schema.compatibility.SchemaCompatibilityCheckTest created 5 new threads. There are now 13 threads in total.
CI - Unit - Pulsar IO - Elastic Search
Summary: Tests in class org.apache.pulsar.io.elasticsearch.v7.ElasticSearch7AuthTest, org.apache.pulsar.io.elasticsearch.v8.ElasticSearch8AuthTest, org.apache.pulsar.io.elasticsearch.ElasticSearchBWCTest, org.apache.pulsar.io.elasticsearch.v7.ElasticSearch7ClientSslTest, org.apache.pulsar.io.elasticsearch.v8.ElasticSearch8ClientSslTest, org.apache.pulsar.io.elasticsearch.opensearch.OpenSearchClientTest, org.apache.pulsar.io.elasticsearch.v7.ElasticSearch7ClientTest, org.apache.pulsar.io.elasticsearch.v8.ElasticSearch8ClientTest, org.apache.pulsar.io.elasticsearch.ElasticSearchConfigTest, org.apache.pulsar.io.elasticsearch.ElasticSearchExtractTest, org.apache.pulsar.io.elasticsearch.ElasticSearchRawRecordTest, org.apache.pulsar.io.elasticsearch.opensearch.OpenSearchSinkRawDataTest, org.apache.pulsar.io.elasticsearch.v7.ElasticSearch7SinkRawDataTest, org.apache.pulsar.io.elasticsearch.v8.ElasticSearch8SinkRawDataTest, org.apache.pulsar.io.elasticsearch.opensearch.OpenSearchSinkTest, org.apache.pulsar.io.elasticsearch.v7.ElasticSearch7SinkTest, org.apache.pulsar.io.elasticsearch.v8.ElasticSearch8SinkTest, org.apache.pulsar.io.elasticsearch.IndexNameFormatterTest, org.apache.pulsar.io.elasticsearch.JsonConverterTest, org.apache.pulsar.io.elasticsearch.RandomExponentialRetryTest, org.apache.pulsar.io.elasticsearch.client.RestClientFactoryTest, org.apache.pulsar.io.elasticsearch.opensearch.OpenSearchClientSslTest created 142 new threads. There are now 150 threads in total.
CI - Unit - Brokers - Broker Group 5
Traced leak detected ByteBuf
CI - Unit - Brokers - Broker Group 5
Traced leak detected ByteBuf
CI - Unit - Brokers - Broker Group 5
Traced leak detected ByteBuf
CI - Unit - Brokers - Broker Group 5
Traced leak detected ByteBuf
CI - Unit - Brokers - Broker Group 5
Traced leak detected ByteBuf
CI - Unit - Brokers - Broker Group 5
Traced leak detected ByteBuf
CI - Unit - Brokers - Broker Group 5
Traced leak detected ByteBuf
CI - Unit - Brokers - Broker Group 5
Traced leak detected ByteBuf
CI - Unit - Brokers - Broker Group 5
Traced leak detected ByteBuf
CI - Unit - Brokers - Broker Group 5
Netty leaks found.
CI - Unit - Brokers - Broker Group 5
Summary: Tests in class org.apache.pulsar.broker.SameAuthParamsLookupAutoClusterFailoverTest created 2 new threads. There are now 10 threads in total.
CI - Unit - Pulsar IO
Summary: Tests in class org.apache.pulsar.io.alluxio.sink.AlluxioSinkTest created 39 new threads. There are now 47 threads in total.
CI - Unit - Pulsar IO
Summary: Tests in class org.apache.pulsar.io.influxdb.InfluxDBGenericRecordSinkTest created 2 new threads. There are now 11 threads in total.
CI - Unit - Pulsar IO
Summary: Tests in class org.apache.pulsar.io.solr.SolrGenericRecordSinkTest created 1 new threads. There are now 10 threads in total.
CI - Unit - Pulsar IO
Summary: Tests in class org.apache.pulsar.io.redis.sink.RedisSinkTest created 11 new threads. There are now 20 threads in total.
CI - Unit - Pulsar IO
Summary: Tests in class org.apache.pulsar.io.flume.node.TestPollingZooKeeperConfigurationProvider created 4 new threads. There are now 12 threads in total.
CI - Unit - Pulsar IO
Summary: Tests in class org.apache.pulsar.io.flume.sink.StringSinkTest created 16 new threads. There are now 24 threads in total.
CI - Unit - Pulsar IO
Summary: Tests in class org.apache.pulsar.io.flume.source.StringSourceTest created 20 new threads. There are now 28 threads in total.
CI - Unit - Pulsar IO
Summary: Tests in class org.apache.pulsar.io.kinesis.KinesisSinkTest created 9 new threads. There are now 18 threads in total.
CI - Unit - Brokers - Client Api
Traced leak detected ByteBuf
CI - Unit - Brokers - Client Api
Netty leaks found.
CI - Unit - Brokers - Client Api
Summary: Tests in class org.apache.bookkeeper.mledger.impl.NonEntryCacheKeySharedSubscriptionV30Test created 2 new threads. There are now 10 threads in total.
CI - Unit - Pulsar Metadata
Summary: Tests in class org.apache.bookkeeper.replication.AuditorPeriodicCheckTest created 11 new threads. There are now 20 threads in total.
CI - Unit - Pulsar Metadata
Summary: Tests in class org.apache.bookkeeper.replication.TestReplicationWorker created 38 new threads. There are now 47 threads in total.
CI - Unit - Pulsar Metadata
Summary: Tests in class org.apache.bookkeeper.replication.BookieAutoRecoveryTest created 14 new threads. There are now 23 threads in total.
CI - Unit - Pulsar Metadata
Summary: Tests in class org.apache.bookkeeper.replication.AuditorBookieTest created 28 new threads. There are now 37 threads in total.
CI - Unit - Pulsar Metadata
Summary: Tests in class org.apache.bookkeeper.replication.AutoRecoveryMainTest created 18 new threads. There are now 27 threads in total.
CI - Unit - Pulsar Metadata
Summary: Tests in class org.apache.bookkeeper.replication.AuditorCheckAllLedgersTaskTest created 1 new threads. There are now 10 threads in total.
CI - Unit - Pulsar Metadata
Summary: Tests in class org.apache.bookkeeper.replication.AuditorRollingRestartTest created 47 new threads. There are now 56 threads in total.
CI - Unit - Brokers - Broker Group 3
Summary: Tests in class org.apache.pulsar.broker.admin.AdminApiTest created 1 new threads. There are now 9 threads in total.
CI - Unit - Brokers - Broker Group 3
Summary: Tests in class org.apache.pulsar.broker.admin.TenantEndpointsAuthorizationTest created 8 new threads. There are now 16 threads in total.
CI - Unit - Brokers - Broker Group 3
Summary: Tests in class org.apache.pulsar.broker.admin.ClusterEndpointsAuthorizationTest created 12 new threads. There are now 32 threads in total.
CI - Unit - Brokers - Broker Group 3
Summary: Tests in class org.apache.pulsar.broker.admin.BrokerEndpointsAuthorizationTest created 12 new threads. There are now 20 threads in total.
CI - Unit - Brokers - Client Impl
Traced leak detected ByteBuf
CI - Unit - Brokers - Client Impl
Traced leak detected ByteBuf
CI - Unit - Brokers - Client Impl
Traced leak detected ByteBuf
CI - Unit - Brokers - Client Impl
Traced leak detected ByteBuf
CI - Unit - Brokers - Client Impl
Traced leak detected ByteBuf
CI - Unit - Brokers - Client Impl
Traced leak detected ByteBuf
CI - Unit - Brokers - Client Impl
Traced leak detected ByteBuf
CI - Unit - Brokers - Client Impl
Traced leak detected ByteBuf
CI - Unit - Brokers - Client Impl
Traced leak detected ByteBuf
CI - Unit - Brokers - Client Impl
Netty leaks found.
CI - Unit - Brokers - Client Impl
Summary: Tests in class org.apache.pulsar.client.impl.ClientInterruptTest created 8 new threads. There are now 16 threads in total.
CI - Unit - Brokers - Client Impl
Summary: Tests in class org.apache.pulsar.client.impl.BrokerClientIntegrationTest created 1 new threads. There are now 9 threads in total.
CI - System - Function
Traced leak detected ByteBuf
CI - System - Function
Traced leak detected ByteBuf
CI - System - Function
Traced leak detected ByteBuf
CI - System - Function
Traced leak detected ByteBuf
CI - System - Function
Traced leak detected ByteBuf
CI - System - Function
Traced leak detected ByteBuf
CI - System - Function
Traced leak detected ByteBuf
CI - System - Function
Netty leaks found.
CI - Unit - Brokers - Broker Group 1
Traced leak detected ByteBuf
CI - Unit - Brokers - Broker Group 1
Traced leak detected ByteBuf
CI - Unit - Brokers - Broker Group 1
Traced leak detected ByteBuf
CI - Unit - Brokers - Broker Group 1
Traced leak detected ByteBuf
CI - Unit - Brokers - Broker Group 1
Traced leak detected ByteBuf
CI - Unit - Brokers - Broker Group 1
Traced leak detected ByteBuf
CI - Unit - Brokers - Broker Group 1
Traced leak detected ByteBuf
CI - Unit - Brokers - Broker Group 1
Traced leak detected ByteBuf
CI - Unit - Brokers - Broker Group 1
Traced leak detected ByteBuf
CI - Unit - Brokers - Broker Group 1
Netty leaks found.
CI - Unit - Brokers - Broker Group 1
Summary: Tests in class org.apache.pulsar.broker.intercept.BrokerInterceptorTest created 1 new threads. There are now 9 threads in total.
CI - Unit - Brokers - Broker Group 1
Summary: Tests in class org.apache.pulsar.broker.service.BrokerBkEnsemblesTest created 2 new threads. There are now 10 threads in total.
CI - Unit - Brokers - Broker Group 1
Summary: Tests in class org.apache.pulsar.broker.BrokerAdditionalServletTest created 1 new threads. There are now 9 threads in total.

Artifacts

Produced during runtime
Name Size Digest
Integration-PULSAR_K8S-container-logs
49.7 KB
sha256:c554d9c5f1710b15c93b5534afb848c4c8acc20b48742cce4e723248f9234e18
Integration-PULSAR_K8S-surefire-reports
94.6 KB
sha256:84b108f7521acb3438845f4b0666a611290d1e4119580b35168d8ad6041453c5
Jacoco-coverage-report-systests
25.4 MB
sha256:fa059b9bc40e1e2ae9c5c11e3202265ebc6e00ce170714ac1a01d3860b4c1d12
System-FUNCTION-dumps
8.25 KB
sha256:ec6e7c1e8ef8c08ece2d7c5ad1c11bb98f22ff00d894aae559646950524dea68
Unit-BROKER_CLIENT_API-dumps
5.69 KB
sha256:f9f20e915e63884ddc84c74d37ca7cee050ed00e789d49dfa9aa66c09b9edec6
Unit-BROKER_CLIENT_IMPL-dumps
49 KB
sha256:2ab86ce9a336c41b46b05f09299a8c0ea698e225b1f4cde145e7a50f41d1328a
Unit-BROKER_GROUP_1-dumps
52.6 KB
sha256:c52d52cb57b6197301c036fc2ee92d7e0d2244ae2ec2289ed75dab35367aaba8
Unit-BROKER_GROUP_2-dumps
76 KB
sha256:0b217daa490eeb4605cbcdc4c0ef3b848d0247371ffebae51c512b2deb5e590b
Unit-BROKER_GROUP_2-surefire-reports
14.4 MB
sha256:8d5da9bb4c8dd9fb0c7d8e721451451bd84f62c972c6034e9ce3c4c6afef33f3
Unit-BROKER_GROUP_3-dumps
18.6 KB
sha256:14197b2914836e6fcc8b0c6b743562626ffa117f9d92080e5dba9462096a528e
Unit-BROKER_GROUP_5-dumps
60.9 KB
sha256:06993a38c5cee3348109948ce194fdda2045d7a9cb8a760be32f57ba1f46ded5
Unit-CLIENT-dumps
49.7 KB
sha256:dd6f8c7eeb494239eabf39efd9b7ca27526ed95db3ca7158c916b0747996b697
Unit-METADATA-dumps
42.2 KB
sha256:a9e867b43eddcf18a34e861f34ede14df6a1453a780555e15fa6ff141e024c09
Unit-OTHER-dumps
17.4 KB
sha256:92a7b9d855456d8fa31d2872413e700e75a433004e5d873de2e331ae9e8559d2
Unit-OTHER-surefire-reports
3.41 MB
sha256:dc3f64fac80d99c693a89696b8d71d5d6dbbf42ef77d1e30ae0f3517132149b6
Unit-PROXY-dumps
49.6 KB
sha256:ba6cb22854f3ff4b985225f001ece237c3e704374d1b992e922ac2db4ab37514
Unit-PROXY-surefire-reports
2.93 MB
sha256:2bccc178684f42a58bab08e05062b3407ff5cb1ce854126bc2056595afcaff6a
Unit-PULSAR_IO-dumps
40 KB
sha256:281fd1b19f3a1ae11b577b97f711c1727fa744fa9b4be6441d3f985067205c78
Unit-PULSAR_IO_ELASTIC-dumps
13.9 KB
sha256:bdacce90d6ab410ee130fd0ee264b4adb808693c7190ce46b5857f4b7a3507c8
coverage_and_deps_inttest_CLI.tar.zst
89.2 MB
sha256:be03b0092003afbac0c4890bcf279a9f498e425fb1675d9bffc7fafebed1395b
coverage_and_deps_inttest_MESSAGING.tar.zst
369 KB
sha256:e5f0b85fc53df1543479138602df7947c1e0b82b6cf88b0c21fd30f094ed8fd7
coverage_and_deps_inttest_METRICS.tar.zst
308 KB
sha256:e7f7aacdba630ace12cbde49d74c431f6261f6f504c1dab28abdaceb8bae750d
coverage_and_deps_inttest_STANDALONE.tar.zst
302 KB
sha256:aa6609bf3273c95c00af30b009ffa75c163fa24bb9b447364d0951e9e998808c
coverage_and_deps_inttest_TRANSACTION.tar.zst
308 KB
sha256:ff68e11360ebf487589b132678dd091f4d6143a005805cfcd8780927f7ab70e0
coverage_and_deps_inttest_UPGRADE.tar.zst
302 KB
sha256:db15eb61aadd7c8ad98b0716d8c6c154be412f485e8bc5fa9a95d000037132c4
coverage_and_deps_unittest_BROKER_CLIENT_API.tar.zst
2.37 MB
sha256:f85d50fb4e8f63e261a4b7bfc81d7729c17a32d6977b7f9423494ff8369ea7af
coverage_and_deps_unittest_BROKER_CLIENT_IMPL.tar.zst
2.37 MB
sha256:ca9b540e009d099548d879edede95c6491bd87163f8ce034128765fe20b9ad07
coverage_and_deps_unittest_BROKER_GROUP_1.tar.zst
2.6 MB
sha256:5b4ca709c724dd817bc83f17759d64fce322743273b9c4cd3d788747bb01d65d
coverage_and_deps_unittest_BROKER_GROUP_3.tar.zst
2.37 MB
sha256:ff19a9f66c375f6b7d34f0a62004b8ca774483854ac88cee0f64848558b3fc4d
coverage_and_deps_unittest_BROKER_GROUP_4.tar.zst
2.23 MB
sha256:a820e18c7a6a92ecff81af0c661cef30c802b9c9272b2db40734781e0011c01a
coverage_and_deps_unittest_BROKER_GROUP_5.tar.zst
2.31 MB
sha256:5d8e05cdf36ef76ac44a0359bec4164f4bb42f9bfca141fdf23d2ae5c9f3f3fc
coverage_and_deps_unittest_CLIENT.tar.zst
708 KB
sha256:091709dd4de94c087e5329d0d6d805b0bca3d430d512966f5252a5ecaed56ee5
coverage_and_deps_unittest_METADATA.tar.zst
272 KB
sha256:eea08c875ce2023e5705a3958d090317a2407983b2b2c79ff6ca3658dda3c2ba
coverage_and_deps_unittest_PULSAR_IO.tar.zst
63.4 MB
sha256:4984b0891b075aade4b31e586e8afd49421d1670b02571273169933854e860f7
coverage_and_deps_unittest_PULSAR_IO_ELASTIC.tar.zst
91.2 KB
sha256:21634642db7866fbcf6492e30bbad12a5a3fdc28b6e25223937c2dbc8bf1503e
coverage_and_deps_unittest_PULSAR_IO_KAFKA_CONNECT.tar.zst
217 KB
sha256:2c2df1379fe6e4529f1163cc22de1e99d49145ab79dbcc2ea66d0cb77b12b83a
pulsar-java-test-image.zst
297 MB
sha256:39ed7011f6528b09dadd0413c0f180bb1af257478c6d8c2886417e91d02a0e06
pulsar-maven-repository-binaries.tar.zst
98 MB
sha256:144cddbaefe11958bec323c1b968364ed4e32c6f54d3ddc8054507a47d0b0e29
pulsar-server-distribution.tar.zst
235 MB
sha256:f17bae5d66419efcfb3695e785bcb79369cfcf318b00338ecb0c08e111f6d440