Home / apache / pulsar
Repository Analysis

apache/pulsar

Apache Pulsar - distributed pub-sub messaging system

2.7 Likely human-written View on GitHub
2.7
Adjusted Score
2.7
Raw Score
100%
Time Factor
2026-05-30
Last Push
15,261
Stars
Java
Language
1,056,296
Lines of Code
5031
Files
594
Pattern Hits
2026-05-31
Scan Date

Score History

Severity Breakdown

CRITICAL 224HIGH 13MEDIUM 9LOW 348

Pattern Findings

594 matches across 14 categories. Click a row to expand file-level details.

Hallucination Indicators224 hits · 2430 pts
SeverityFileLineSnippet
CRITICAL…g/apache/pulsar/websocket/proxy/ProxyRoleAuthTest.java392 org.apache.pulsar.common.policies.data.ClusterData.builder()
CRITICAL…g/apache/pulsar/websocket/proxy/ProxyRoleAuthTest.java406 org.apache.pulsar.common.policies.data.TenantInfoImpl.builder()
CRITICAL…ction/pendingack/impl/MetadataPendingAckStoreTest.java158 new org.apache.pulsar.broker.transaction.metadata.TxnEvent(
CRITICAL…ction/pendingack/impl/MetadataPendingAckStoreTest.java185 new org.apache.pulsar.broker.transaction.metadata.TxnEvent(
CRITICAL…ction/pendingack/impl/MetadataPendingAckStoreTest.java237 return new org.apache.pulsar.metadata.api.ScanConsumer() {
CRITICAL…saction/buffer/impl/MetadataTransactionBufferTest.java204 new org.apache.pulsar.broker.transaction.metadata.SegmentWatermark(5, 0),
CRITICAL…saction/buffer/impl/MetadataTransactionBufferTest.java229 new org.apache.pulsar.broker.transaction.metadata.SegmentWatermark(5, 0),
CRITICAL…saction/buffer/impl/MetadataTransactionBufferTest.java261 new org.apache.pulsar.broker.transaction.metadata.SegmentWatermark(5, 0),
CRITICAL…saction/buffer/impl/MetadataTransactionBufferTest.java336 new org.apache.pulsar.broker.transaction.metadata.SegmentWatermark(5, 0),
CRITICAL…saction/buffer/impl/MetadataTransactionBufferTest.java371 new org.apache.pulsar.metadata.api.ScanConsumer() {
CRITICAL…lsar/broker/loadbalance/SimpleLoadManagerImplTest.java296 new org.apache.pulsar.policies.data.loadbalancer.LoadReport();
CRITICAL…lsar/broker/loadbalance/SimpleLoadManagerImplTest.java373 new org.apache.pulsar.policies.data.loadbalancer.LoadReport();
CRITICAL…lsar/broker/loadbalance/SimpleLoadManagerImplTest.java426 new org.apache.pulsar.policies.data.loadbalancer.LoadReport();
CRITICAL…lsar/broker/loadbalance/SimpleLoadManagerImplTest.java430 new org.apache.pulsar.policies.data.loadbalancer.LoadReport();
CRITICAL…xtensions/AntiAffinityNamespaceGroupExtensionTest.java99 org.apache.commons.lang3.reflect.FieldUtils.readDeclaredField(antiAffinityGroupPolicyHelper,
CRITICAL…sar/broker/resourcegroup/ResourceGroupServiceTest.java92 new org.apache.pulsar.common.policies.data.ResourceGroup();
CRITICAL…sar/broker/resourcegroup/ResourceGroupServiceTest.java152 new org.apache.pulsar.common.policies.data.ResourceGroup();
CRITICAL…sar/broker/resourcegroup/ResourceGroupServiceTest.java166 new org.apache.pulsar.common.policies.data.ResourceGroup();
CRITICAL…sar/broker/resourcegroup/ResourceGroupServiceTest.java281 service.resourceGroupCreate(rg, new org.apache.pulsar.common.policies.data.ResourceGroup());
CRITICAL…sar/broker/resourcegroup/ResourceGroupServiceTest.java350 rgs.resourceGroupCreate(rgName, new org.apache.pulsar.common.policies.data.ResourceGroup());
CRITICAL…sar/broker/resourcegroup/ResourceGroupServiceTest.java430 rgs.resourceGroupCreate(rg, new org.apache.pulsar.common.policies.data.ResourceGroup());
CRITICAL…sar/broker/resourcegroup/ResourceGroupServiceTest.java471 rgs.resourceGroupCreate(rg, new org.apache.pulsar.common.policies.data.ResourceGroup());
CRITICAL…sar/broker/resourcegroup/ResourceGroupServiceTest.java507 rgs.resourceGroupCreate(rg, new org.apache.pulsar.common.policies.data.ResourceGroup());
CRITICAL…r/resourcegroup/ResourceGroupUsageAggregationTest.java252 new org.apache.pulsar.common.policies.data.ResourceGroup();
CRITICAL…broker/resourcegroup/ResourceGroupRateLimiterTest.java44 new org.apache.pulsar.common.policies.data.ResourceGroup();
CRITICAL…ker/resourcegroup/RGUsageMTAggrWaitForAllMsgsTest.java783 new org.apache.pulsar.common.policies.data.ResourceGroup();
CRITICAL…/org/apache/pulsar/broker/admin/TopicPoliciesTest.java4691 org.apache.pulsar.common.util.ObjectMapperFactory.getThreadLocal().writeValueAsBytes(policies),
CRITICAL…che/pulsar/broker/intercept/BrokerInterceptorTest.java281 javax.ws.rs.core.Response.noContent().build().getStatus());
CRITICAL…roker/service/OpenTelemetryTracingIntegrationTest.java149 io.opentelemetry.api.common.AttributeKey.stringKey("messaging.system")), "pulsar");
CRITICAL…roker/service/OpenTelemetryTracingIntegrationTest.java158 io.opentelemetry.api.common.AttributeKey.stringKey("messaging.system")), "pulsar");
CRITICAL…roker/service/OpenTelemetryTracingIntegrationTest.java160 io.opentelemetry.api.common.AttributeKey.stringKey("messaging.pulsar.acknowledgment.type")),
CRITICAL…roker/service/OpenTelemetryTracingIntegrationTest.java267 io.opentelemetry.api.common.AttributeKey.stringKey("messaging.pulsar.acknowledgment.type")),
CRITICAL…roker/service/OpenTelemetryTracingIntegrationTest.java315 io.opentelemetry.api.common.AttributeKey.stringKey(
CRITICAL…roker/service/OpenTelemetryTracingIntegrationTest.java369 io.opentelemetry.api.common.AttributeKey.stringKey(
CRITICAL…roker/service/OpenTelemetryTracingIntegrationTest.java519 io.opentelemetry.api.common.AttributeKey.stringKey(
CRITICAL…roker/service/OpenTelemetryTracingIntegrationTest.java624 io.opentelemetry.api.common.AttributeKey.stringKey(
CRITICAL…roker/service/OpenTelemetryTracingIntegrationTest.java678 io.opentelemetry.api.common.AttributeKey.stringKey(
CRITICAL…roker/service/OpenTelemetryTracingIntegrationTest.java750 io.opentelemetry.api.common.AttributeKey.stringKey(
CRITICAL…roker/service/OpenTelemetryTracingIntegrationTest.java814 io.opentelemetry.api.common.AttributeKey.stringKey("messaging.system")));
CRITICAL…roker/service/OpenTelemetryTracingIntegrationTest.java816 io.opentelemetry.api.common.AttributeKey.stringKey("messaging.system")), "pulsar");
CRITICAL…schema/ProtobufNativeSchemaCompatibilityCheckTest.java33 getSchemaData(org.apache.pulsar.client.api.schema.proto.Test.TestMessage.getDescriptor());
CRITICAL…schema/ProtobufNativeSchemaCompatibilityCheckTest.java36 getSchemaData(org.apache.pulsar.client.api.schema.proto.Test.SubMessage.getDescriptor());
CRITICAL…oker/service/scalable/ScalableTopicControllerTest.java536 org.apache.pulsar.common.scalable.SegmentInfo seg0 = new org.apache.pulsar.common.scalable.SegmentInfo(
CRITICAL…oker/service/scalable/ScalableTopicControllerTest.java538 org.apache.pulsar.common.scalable.HashRange.of(0x0000, 0x3FFF),
CRITICAL…oker/service/scalable/ScalableTopicControllerTest.java543 org.apache.pulsar.common.scalable.SegmentInfo seg1 = new org.apache.pulsar.common.scalable.SegmentInfo(
CRITICAL…oker/service/scalable/ScalableTopicControllerTest.java545 org.apache.pulsar.common.scalable.HashRange.of(0x4000, 0x7FFF),
CRITICAL…oker/service/scalable/ScalableTopicControllerTest.java549 org.apache.pulsar.common.scalable.SegmentInfo seg2 = new org.apache.pulsar.common.scalable.SegmentInfo(
CRITICAL…oker/service/scalable/ScalableTopicControllerTest.java551 org.apache.pulsar.common.scalable.HashRange.of(0x8000, 0xFFFF),
CRITICAL…oker/service/scalable/ScalableTopicControllerTest.java616 new org.apache.pulsar.client.admin.PulsarAdminException.NotFoundException(
CRITICAL…oker/service/scalable/ScalableTopicControllerTest.java633 new org.apache.pulsar.client.admin.PulsarAdminException(
CRITICAL…oker/service/scalable/ScalableTopicControllerTest.java653 new org.apache.pulsar.client.admin.PulsarAdminException(
CRITICAL…oker/service/scalable/ScalableTopicControllerTest.java702 clock.set(startMs + java.util.concurrent.TimeUnit.MINUTES.toMillis(1) + 1_000L);
CRITICAL…oker/service/scalable/ScalableTopicControllerTest.java788 new org.apache.pulsar.common.policies.data.Policies();
CRITICAL…oker/service/scalable/ScalableTopicControllerTest.java790 new org.apache.pulsar.common.policies.data.RetentionPolicies(
CRITICAL…che/pulsar/broker/stats/MetricsAuthenticationTest.java57 Client client = javax.ws.rs.client.ClientBuilder.newClient(new ClientConfig().register(LoggingFeature.class));
CRITICAL…che/pulsar/broker/stats/MetricsAuthenticationTest.java66 Client client = javax.ws.rs.client.ClientBuilder.newClient(new ClientConfig().register(LoggingFeature.class));
CRITICAL…pulsar/broker/stats/OpenTelemetryCustomLabelsTest.java228 .get(io.opentelemetry.api.common.AttributeKey.stringKey("sla_tier")) != null);
CRITICAL…t/java/org/apache/pulsar/io/PulsarFunctionTlsTest.java213 org.apache.pulsar.functions.worker.scheduler.RoundRobinScheduler.class.getName());
CRITICAL…java/org/apache/pulsar/io/PulsarFunctionAdminTest.java198 org.apache.pulsar.functions.worker.scheduler.RoundRobinScheduler.class.getName());
CRITICAL…t/java/org/apache/pulsar/io/AbstractPulsarE2ETest.java291 org.apache.pulsar.functions.worker.scheduler.RoundRobinScheduler.class.getName());
164 more matches not shown…
Over-Commented Block255 hits · 254 pts
SeverityFileLineSnippet
LOW.asf.yaml1#
LOWcodecov.yml1#
LOWdocker/get-version.sh1#!/usr/bin/env bash
LOWdocker/publish.sh1#!/usr/bin/env bash
LOWdocker/build.sh1#!/usr/bin/env bash
LOWdocker/pulsar/scripts/apply-config-from-env.py1#!/usr/bin/env python3
LOWdocker/pulsar/scripts/gen-yml-from-env.py1#!/usr/bin/env python3
LOWdocker/pulsar/scripts/update-ini-from-env.py1#!/usr/bin/env python3
LOWdocker/pulsar/scripts/generate-zookeeper-config.sh1#!/usr/bin/env bash
LOWdocker/pulsar/scripts/update-rocksdb-conf-from-env.py1#!/usr/bin/env python3
LOW…er/pulsar/scripts/apply-config-from-env-with-prefix.py1#!/usr/bin/env bash
LOW…er/pulsar/scripts/apply-config-from-env-with-prefix.py21############################################################
LOWdocker/pulsar/scripts/watch-znode.py1#!/usr/bin/env python3
LOWdocker/pulsar/scripts/pulsar-zookeeper-ruok.sh1#!/usr/bin/env bash
LOW…ar/build-scripts/remove-unnecessary-native-binaries.sh1#!/usr/bin/env sh
LOW…saction/buffer/impl/MetadataTransactionBufferTest.java181 // (committed) or never existed. Either way: visible/committed-default.
LOW…ce/extensions/channel/ServiceUnitStateChannelTest.java2021 // targeting this broker to Owned, simulating the broker-restart recovery scenario.
LOW…apache/pulsar/broker/service/OneWayReplicatorTest.java1781 });
LOW…apache/pulsar/broker/service/OneWayReplicatorTest.java1821 log.info().attr("topicConnected", topicConnected).attr("topicDisconnected", topicDisconnected).log("done");
LOW…va/org/apache/pulsar/broker/service/BrokerService.java3901
LOW…istentStickyKeyDispatcherMultipleConsumersClassic.java461 // when consumer1 get message 2,3, the broker will not dispatch messages to consumer1
LOW…r/broker/service/scalable/ScalableTopicController.java281 }
LOW…stats/prometheus/metrics/PrometheusTextFormatUtil.java61 // quantile="0.75"} NaN
LOWpulsar-function-go/golangci.yml1#
LOWpulsar-function-go/pb/Request.pb.go1//
LOWpulsar-function-go/pb/Function.pb.go1//
LOWpulsar-function-go/pb/InstanceCommunication_grpc.pb.go1//
LOWpulsar-function-go/pb/doc.go1//
LOWpulsar-function-go/pb/doc.go21// uses for the client/broker wire protocol.
LOWpulsar-function-go/pb/generate.sh1#!/usr/bin/env bash
LOWpulsar-function-go/pb/generate.sh21# Bash script to automate the generation of the api package using Docker.
LOWpulsar-function-go/pb/generate.sh101// distributed with this work for additional information
LOWpulsar-function-go/pb/generate.sh161cat <<EOF >"${outDir}/doc.go"
LOWpulsar-function-go/pb/generate.sh181// Package ${pkg} provides the protocol buffer messages that Pulsar
LOWpulsar-function-go/pb/InstanceCommunication.pb.go1//
LOWpulsar-function-go/pb/InstanceCommunication.pb.go61 //
LOWpulsar-function-go/pf/function_test.go1//
LOWpulsar-function-go/pf/instanceConf.go1//
LOWpulsar-function-go/pf/topicName.go1//
LOWpulsar-function-go/pf/instance.go1//
LOWpulsar-function-go/pf/util_test.go1//
LOWpulsar-function-go/pf/topicName_test.go1//
LOWpulsar-function-go/pf/mockMessage_test.go1//
LOWpulsar-function-go/pf/util.go1//
LOWpulsar-function-go/pf/logAppender.go1//
LOWpulsar-function-go/pf/context_test.go1//
LOWpulsar-function-go/pf/stats.go1//
LOWpulsar-function-go/pf/instance_test.go1//
LOWpulsar-function-go/pf/instanceConf_test.go1//
LOWpulsar-function-go/pf/context.go1//
LOWpulsar-function-go/pf/instanceControlServicer_test.go1//
LOWpulsar-function-go/pf/instanceControlServicer.go1//
LOWpulsar-function-go/pf/function.go1//
LOWpulsar-function-go/pf/function.go141 return val, err
LOWpulsar-function-go/pf/stats_test.go1//
LOWpulsar-function-go/examples/outputFunc/outputFunc.go1//
LOW…unction-go/examples/exclamationFunc/exclamationFunc.go1//
LOWpulsar-function-go/examples/contextFunc/contextFunc.go1//
LOWpulsar-function-go/examples/publishFunc/publishFunc.go1//
LOWpulsar-function-go/examples/logFunc/logFunc.go1//
195 more matches not shown…
Cross-File Repetition12 hits · 60 pts
SeverityFileLineSnippet
HIGHpip/pip-259.md0the maximum size in bytes of the request header. larger headers will allow for more and/or larger cookies plus larger fo
HIGHpip/pip-259.md0the maximum size in bytes of the request header. larger headers will allow for more and/or larger cookies plus larger fo
HIGH…org/apache/pulsar/proxy/server/ProxyConfiguration.java0the maximum size in bytes of the request header. larger headers will allow for more and/or larger cookies plus larger fo
HIGH…ava/org/apache/pulsar/broker/ServiceConfiguration.java0the maximum size in bytes of the request header. larger headers will allow for more and/or larger cookies plus larger fo
HIGH…ance/src/main/python/InstanceCommunication_pb2_grpc.py0missing associated documentation comment in .proto file.
HIGH…ance/src/main/python/InstanceCommunication_pb2_grpc.py0missing associated documentation comment in .proto file.
HIGH…ance/src/main/python/InstanceCommunication_pb2_grpc.py0missing associated documentation comment in .proto file.
HIGH…ance/src/main/python/InstanceCommunication_pb2_grpc.py0missing associated documentation comment in .proto file.
HIGH…ance/src/main/python/InstanceCommunication_pb2_grpc.py0missing associated documentation comment in .proto file.
HIGH…ance/src/main/python/InstanceCommunication_pb2_grpc.py0missing associated documentation comment in .proto file.
HIGH…ance/src/main/python/InstanceCommunication_pb2_grpc.py0missing associated documentation comment in .proto file.
HIGH…ance/src/main/python/InstanceCommunication_pb2_grpc.py0missing associated documentation comment in .proto file.
Verbosity Indicators29 hits · 47 pts
SeverityFileLineSnippet
LOW…apache/pulsar/broker/service/OneWayReplicatorTest.java1498 // Step 1: Inject an error to make the replicator is not able to work.
LOW…apache/pulsar/broker/service/OneWayReplicatorTest.java1502 // Step 2: Send one message, since the replicator does not work anymore, this message will not be replicated.
LOW…apache/pulsar/broker/service/OneWayReplicatorTest.java1512 // Step 3: Unload topic, the replicator will be re-created.
LOW…lsar/client/api/v5/V5MultiBrokerScalableTopicTest.java345 // Step 1: force controller materialization + leader election on every broker.
LOW…lsar/client/api/v5/V5MultiBrokerScalableTopicTest.java350 // Step 2: wait until each broker's metadata store sees the controller-lock znode.
LOW…org/apache/pulsar/broker/namespace/OwnershipCache.java169 // If we're not the owner, we need to check if anybody else is
LOW…sar/broker/service/schema/BookkeeperSchemaStorage.java350 // Step 1: Store the schema data into a new BookKeeper ledger
LOW…sar/broker/service/schema/BookkeeperSchemaStorage.java360 // Step 2: Create the schema locator z-node pointing to the ledger
LOW…sar/broker/service/schema/BookkeeperSchemaStorage.java368 // Step 3: Handle failure by cleaning up the orphan ledger
LOW…r/broker/service/scalable/ScalableTopicController.java423 // Step 3: Terminate the parent segment topic so producers get TopicTerminated
LOW…r/broker/service/scalable/ScalableTopicController.java426 // Step 4: Atomic metadata update (only after topics + cursors are ready + parent terminated)
LOW…r/broker/service/scalable/ScalableTopicController.java436 // Step 5: Notify subscriptions of layout change (triggers consumer reassignment)
LOW…r/broker/service/scalable/ScalableTopicController.java462 // Step 1: Read the scalable topic's subscriptions from metadata (single source of
LOW…r/broker/service/scalable/ScalableTopicController.java468 // Step 2: Terminate both parent segment topics
LOW…r/broker/service/scalable/ScalableTopicController.java472 // Step 3: Atomic metadata update (only after topic + cursors are ready + parents terminated)
LOW…r/broker/service/scalable/ScalableTopicController.java412 // Step 1: Read the scalable topic's subscriptions from metadata (the single source
LOW…broker/authentication/ProxySaslAuthenticationTest.java227 // Step 1: Create Admin Client
LOW…broker/authentication/ProxySaslAuthenticationTest.java269 // Step 3: Pass correct client params
LOW…ache/pulsar/proxy/server/ProxyForwardAuthDataTest.java88 // Step 1: Create Admin Client
LOW…ache/pulsar/proxy/server/ProxyForwardAuthDataTest.java102 // Step 2: Run Pulsar Proxy without forwarding authData - expect Exception
LOW…ache/pulsar/proxy/server/ProxyForwardAuthDataTest.java136 // Step 3: Create proxy with forwardAuthData enabled
LOW…che/pulsar/proxy/server/ProxyRolesEnforcementTest.java186 // Step 1: Create Admin Client
LOW…che/pulsar/proxy/server/ProxyRolesEnforcementTest.java202 // Step 2: Try to use proxy Client as a normal Client - expect exception
LOW…che/pulsar/proxy/server/ProxyRolesEnforcementTest.java212 // Step 3: Run Pulsar Proxy and pass proxy params as client params - expect exception
LOW…che/pulsar/proxy/server/ProxyRolesEnforcementTest.java252 // Step 4: Pass correct client params
LOW…pache/pulsar/proxy/server/ProxyAuthenticationTest.java272 // Step 1: Create Admin Client
LOW…pache/pulsar/proxy/server/ProxyAuthenticationTest.java288 // Step 2: Try to use proxy Client as a normal Client - expect exception
LOW…pache/pulsar/proxy/server/ProxyAuthenticationTest.java317 // Step 3: Pass correct client params and use multiple connections
LOW…pache/pulsar/proxy/server/ProxyAuthenticationTest.java324 // Step 4: Ensure that all client contexts share the same auth provider
Unused Imports24 hits · 24 pts
SeverityFileLineSnippet
LOW…atest-version-image/python-examples/producer_schema.py22
LOW…atest-version-image/python-examples/consumer_schema.py22
LOW…functions/python-examples/avro_schema_test_function.py22
LOW…tions/instance/src/test/python/test_python_instance.py28
LOW…tions/instance/src/main/python/python_instance_main.py34
LOW…ions/instance/src/main/python/prometheus_client_fix.py20
LOW…ions/instance/src/main/python/prometheus_client_fix.py28
LOW…ions/instance/src/main/python/prometheus_client_fix.py30
LOW…ions/instance/src/main/python/prometheus_client_fix.py30
LOW…ions/instance/src/main/python/prometheus_client_fix.py30
LOW…ions/instance/src/main/python/prometheus_client_fix.py31
LOW…ions/instance/src/main/python/prometheus_client_fix.py32
LOW…ions/instance/src/main/python/prometheus_client_fix.py32
LOW…ions/instance/src/main/python/prometheus_client_fix.py35
LOW…ions/instance/src/main/python/prometheus_client_fix.py37
LOW…ions/instance/src/main/python/prometheus_client_fix.py37
LOW…ions/instance/src/main/python/prometheus_client_fix.py37
LOW…ions/instance/src/main/python/prometheus_client_fix.py38
LOW…ions/instance/src/main/python/prometheus_client_fix.py38
LOW…ions/instance/src/main/python/prometheus_client_fix.py38
LOW…sar-functions/instance/src/main/python/Function_pb2.py9
LOW…ance/src/main/python/InstanceCommunication_pb2_grpc.py4
LOW…/instance/src/main/python/InstanceCommunication_pb2.py9
LOW…/instance/src/main/python/InstanceCommunication_pb2.py17
Hyper-Verbose Identifiers21 hits · 22 pts
SeverityFileLineSnippet
LOW…pache/pulsar/socks5/handler/CommandRequestHandler.java40public class CommandRequestHandler extends SimpleChannelInboundHandler<DefaultSocks5CommandRequest> {
LOW…/pulsar/socks5/handler/PasswordAuthRequestHandler.java32public class PasswordAuthRequestHandler extends SimpleChannelInboundHandler<DefaultSocks5PasswordAuthRequest> {
LOW…pache/pulsar/socks5/handler/InitialRequestHandler.java31public class InitialRequestHandler extends SimpleChannelInboundHandler<DefaultSocks5InitialRequest> {
LOW…va/org/apache/pulsar/client/api/MockBrokerService.java86 private class GenericResponseHandler extends AbstractHandler {
LOW…tions/instance/src/test/python/test_python_instance.py75 def test_context_ack_partitionedtopic(self):
LOW…tions/instance/src/test/python/test_secretsprovider.py35 def test_cleartext_secretsprovider(self):
LOW…tions/instance/src/test/python/test_secretsprovider.py44 def test_environment_secretsprovider(self):
LOW…tions/instance/src/main/python/python_instance_main.py59def generate_arguments_parser():
LOW…r-functions/instance/src/main/python/function_stats.py111 def get_total_processed_successfully(self):
LOW…r-functions/instance/src/main/python/function_stats.py117 def get_total_user_exceptions(self):
LOW…r-functions/instance/src/main/python/function_stats.py149 def incr_total_processed_successfully(self):
LOW…r-functions/instance/src/main/python/function_stats.py153 def incr_total_sys_exceptions(self, exception):
LOW…r-functions/instance/src/main/python/function_stats.py158 def incr_total_user_exceptions(self, exception):
LOW…r-functions/instance/src/main/python/function_stats.py193 def report_user_exception_prometheus(self, exception):
LOW…r-functions/instance/src/main/python/function_stats.py211 def report_system_exception_prometheus(self, exception):
LOW…lsar-functions/instance/src/main/python/contextimpl.py73 def set_current_message_context(self, message, topic):
LOW…lsar-functions/instance/src/main/python/contextimpl.py89 def get_current_message_topic_name(self):
LOW…lsar-functions/instance/src/main/python/contextimpl.py100 def get_message_partition_index(self):
LOW…lsar-functions/instance/src/main/python/contextimpl.py156 def get_output_serde_class_name(self):
LOW…-functions/instance/src/main/python/python_instance.py132 def process_spawner_health_check_timer(self):
LOW…e/pulsar/functions/worker/FunctionMetaDataManager.java61public class FunctionMetaDataManager implements AutoCloseable {
AI Slop Vocabulary5 hits · 15 pts
SeverityFileLineSnippet
MEDIUM…va/org/apache/pulsar/broker/service/ServerCnxTest.java1367 // This test is an example of https://github.com/apache/pulsar/issues/19332. Essentially, we're passing
MEDIUMbin/pulsar-admin-common.sh140# Netty cannot utilize resources from the memory pool and must frequently allocate native memory.
MEDIUM…e/pulsar/common/util/collections/BitSetRecyclable.java32 * Provides {@link BitSetRecyclable#resetWords(long[])} method and leverage with netty recycler.
MEDIUM…tor/NameAndConfigBasedSecretsProviderConfigurator.java50 // environment variables way. Essentially the secretName/secretPath is
MEDIUM…onfigurator/KubernetesSecretsProviderConfigurator.java69 // environment variables way. Essentially the secretName/secretPath
Self-Referential Comments4 hits · 12 pts
SeverityFileLineSnippet
MEDIUMpulsar-functions/instance/src/main/python/log.py31# Create the logger
MEDIUM…ance/src/main/python/InstanceCommunication_pb2_grpc.py117 # This class is part of an EXPERIMENTAL API.
MEDIUMsrc/update_python_protobuf_stubs_with_docker.sh23# Create an inline docker container with alpine:3.23 base image and mount the current directory to it as the
MEDIUMsrc/update_python_protobuf_stubs.sh29# Create a temporary virtual environment to avoid polluting the global Python environment
Deep Nesting6 hits · 6 pts
SeverityFileLineSnippet
LOWdocker/pulsar/scripts/update-ini-from-env.py30
LOWdocker/pulsar/scripts/update-rocksdb-conf-from-env.py34
LOW…tions/instance/src/main/python/python_instance_main.py149
LOW…-functions/instance/src/main/python/python_instance.py247
LOW…-functions/instance/src/main/python/python_instance.py367
LOW…-functions/instance/src/main/python/python_instance.py543
Cross-Language Confusion1 hit · 5 pts
SeverityFileLineSnippet
HIGH…er/pulsar/scripts/apply-config-from-env-with-prefix.py38SCRIPT_DIR="$(cd "$(dirname "${BASH_SOURCE[0]}")" >/dev/null 2>&1 && pwd)"
Excessive Try-Catch Wrapping5 hits · 5 pts
SeverityFileLineSnippet
LOWpulsar-functions/instance/src/main/python/util.py44 except Exception as e:
LOWpulsar-functions/instance/src/main/python/util.py49 except Exception as e:
LOW…-functions/instance/src/main/python/python_instance.py282 except Exception as e:
LOW…-functions/instance/src/main/python/python_instance.py295 except Exception as e:
LOW…-functions/instance/src/main/python/python_instance.py593 except Exception as e:
Slop Phrases3 hits · 4 pts
SeverityFileLineSnippet
LOW.github/workflows/pulsar-ci.yaml31 # if cron expression is changed, make sure to update the expression in jdk_major_version step in preconditions job
LOW.github/workflows/pulsar-ci-flaky.yaml31 # if cron expression is changed, make sure to update the expression in jdk_major_version step in preconditions job
LOW…tions/instance/src/main/python/python_instance_main.py314 # make sure to close all non-daemon threads before this!
Fake / Example Data4 hits · 4 pts
SeverityFileLineSnippet
LOW…mon/compression/CompressorCodecBackwardCompatTest.java34 "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Cras id massa odio. Duis commodo ligula sed "
LOW…mon/compression/CompressorCodecBackwardCompatTest.java34 "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Cras id massa odio. Duis commodo ligula sed "
LOW…che/pulsar/common/compression/CompressorCodecTest.java35 private static final String text = "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Cras id massa odio. "
LOW…che/pulsar/common/compression/CompressorCodecTest.java35 private static final String text = "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Cras id massa odio. "
Example Usage Blocks1 hit · 2 pts
SeverityFileLineSnippet
LOWgradle/setup-test-gpg.sh24# Usage: