You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2021/11/10 12:09:58 UTC
[pulsar] branch master updated (8551868 -> 1ea381d)
This is an automated email from the ASF dual-hosted git repository.
penghui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 8551868 Remove unused code in PersistentTopic.java (#12715)
add 1ea381d [Code optimization] Delete unused import (#12690)
No new revisions were added by this update.
Summary of changes:
.../org/apache/bookkeeper/mledger/impl/LedgerMetadataUtils.java | 1 -
.../apache/bookkeeper/mledger/impl/ReadOnlyManagedLedgerImpl.java | 1 -
.../apache/pulsar/broker/authentication/AuthenticationService.java | 1 -
.../apache/pulsar/broker/authorization/AuthorizationProvider.java | 1 -
.../apache/pulsar/broker/authorization/AuthorizationService.java | 2 --
.../broker/authorization/MultiRolesTokenAuthorizationProvider.java | 1 -
.../pulsar/broker/authorization/PulsarAuthorizationProvider.java | 5 +----
.../java/org/apache/pulsar/broker/resources/BookieResources.java | 1 -
.../java/org/apache/pulsar/broker/resources/BrokerResources.java | 7 +------
.../org/apache/pulsar/broker/resources/LocalPoliciesResources.java | 1 -
.../java/org/apache/pulsar/broker/resources/PulsarResources.java | 1 -
.../org/apache/pulsar/broker/resources/ResourceGroupResources.java | 2 +-
.../java/org/apache/pulsar/broker/resources/TenantResources.java | 2 --
.../java/org/apache/pulsar/broker/resources/TopicResources.java | 1 -
.../apache/pulsar/broker/validator/MultipleListenerValidator.java | 3 ---
.../pulsar/common/configuration/PulsarConfigurationLoader.java | 1 -
.../java/org/apache/pulsar/client/impl/MessageBuilderImpl.java | 1 -
.../apache/pulsar/client/api/interceptor/ProducerInterceptor.java | 1 -
.../main/java/org/apache/pulsar/admin/cli/CmdPersistentTopics.java | 2 --
.../src/main/java/org/apache/pulsar/admin/cli/CmdSinks.java | 1 -
.../src/main/java/org/apache/pulsar/admin/cli/CmdTopics.java | 1 -
.../src/main/java/org/apache/pulsar/admin/cli/utils/CmdUtils.java | 2 --
.../src/main/java/org/apache/pulsar/client/cli/CmdConsume.java | 1 -
.../org/apache/pulsar/client/cli/CmdGenerateDocumentation.java | 1 -
.../src/main/java/org/apache/pulsar/client/cli/CmdProduce.java | 1 -
.../main/java/org/apache/pulsar/client/impl/BackoffBuilder.java | 2 --
.../java/org/apache/pulsar/client/impl/BatchMessageIdImpl.java | 1 -
.../src/main/java/org/apache/pulsar/client/impl/ClientCnx.java | 2 --
.../java/org/apache/pulsar/client/impl/ConsumerInterceptors.java | 1 -
.../client/impl/NonPersistentAcknowledgmentGroupingTracker.java | 1 -
.../src/main/java/org/apache/pulsar/client/impl/ProducerBase.java | 1 -
.../java/org/apache/pulsar/client/impl/ProducerInterceptors.java | 1 -
.../java/org/apache/pulsar/client/impl/TopicMessageIdImpl.java | 1 -
.../org/apache/pulsar/client/impl/auth/AuthenticationToken.java | 1 -
.../apache/pulsar/client/impl/schema/NativeAvroBytesSchema.java | 1 -
.../pulsar/client/impl/schema/generic/GenericSchemaImpl.java | 1 -
.../java/org/apache/pulsar/client/impl/schema/util/SchemaUtil.java | 1 -
.../pulsar/common/policies/data/NamespaceIsolationDataImpl.java | 3 ---
.../java/org/apache/pulsar/common/policies/data/TopicPolicies.java | 1 -
.../data/stats/NonPersistentPartitionedTopicStatsImpl.java | 3 ---
.../src/main/java/org/apache/pulsar/common/stats/Rate.java | 2 +-
.../main/java/org/apache/pulsar/common/util/SecurityUtility.java | 1 -
.../java/org/apache/pulsar/functions/instance/JavaInstance.java | 1 -
.../org/apache/pulsar/functions/instance/JavaInstanceRunnable.java | 4 ----
.../functions/instance/state/PulsarMetadataStateStoreImpl.java | 3 +--
.../pulsar/functions/instance/stats/FunctionStatsManager.java | 1 -
.../apache/pulsar/functions/instance/stats/SinkStatsManager.java | 1 -
.../apache/pulsar/functions/instance/stats/SourceStatsManager.java | 1 -
.../main/java/org/apache/pulsar/functions/source/PulsarSource.java | 1 -
.../org/apache/pulsar/functions/source/PulsarSourceConfig.java | 7 -------
.../src/main/java/org/apache/pulsar/functions/LocalRunner.java | 2 --
.../pulsar/functions/auth/KubernetesSecretsTokenAuthProvider.java | 1 -
.../org/apache/pulsar/functions/runtime/JavaInstanceStarter.java | 1 -
.../java/org/apache/pulsar/functions/runtime/RuntimeUtils.java | 1 -
.../pulsar/functions/runtime/kubernetes/KubernetesRuntime.java | 1 -
.../apache/pulsar/functions/runtime/process/ProcessRuntime.java | 4 ----
.../pulsar/functions/runtime/process/ProcessRuntimeFactory.java | 1 -
.../pulsar/functions/runtime/thread/ThreadRuntimeFactory.java | 3 ---
.../main/java/org/apache/pulsar/io/dynamodb/DynamoDBSource.java | 2 --
.../java/org/apache/pulsar/io/dynamodb/DynamoDBSourceConfig.java | 1 -
.../java/org/apache/pulsar/io/elasticsearch/ElasticSearchSink.java | 1 -
.../apache/pulsar/io/kafka/connect/PulsarKafkaSinkTaskContext.java | 2 --
.../java/org/apache/pulsar/io/kafka/ByteBufferSchemaWrapper.java | 1 -
.../src/main/java/org/apache/pulsar/io/kafka/KafkaBytesSource.java | 2 --
.../main/java/org/apache/pulsar/io/kinesis/KinesisSinkConfig.java | 2 +-
.../java/org/apache/pulsar/io/kinesis/KinesisSourceConfig.java | 1 -
.../main/java/org/apache/pulsar/io/kinesis/fbs/EncryptionCtx.java | 2 +-
.../main/java/org/apache/pulsar/io/kinesis/fbs/EncryptionKey.java | 2 +-
.../src/main/java/org/apache/pulsar/io/kinesis/fbs/KeyValue.java | 2 +-
.../src/main/java/org/apache/pulsar/io/kinesis/fbs/Message.java | 2 +-
.../java/org/apache/pulsar/metadata/api/MetadataStoreFactory.java | 2 --
.../apache/pulsar/metadata/api/extended/MetadataStoreExtended.java | 2 --
.../pulsar/metadata/coordination/impl/LeaderElectionImpl.java | 6 ------
.../org/apache/pulsar/metadata/impl/AbstractMetadataStore.java | 2 +-
.../apache/pulsar/metadata/impl/FaultInjectionMetadataStore.java | 1 -
.../org/apache/pulsar/metadata/impl/PulsarZooKeeperClient.java | 2 --
.../org/apache/pulsar/proxy/server/BrokerDiscoveryProvider.java | 4 ----
.../main/java/org/apache/pulsar/proxy/server/ProxyConnection.java | 1 -
.../decoder/protobufnative/PulsarProtobufNativeColumnDecoder.java | 1 -
.../apache/pulsar/sql/presto/util/NoStrictCacheSizeAllocator.java | 1 -
.../org/apache/pulsar/proxy/socket/client/PerformanceClient.java | 1 -
.../coordinator/impl/MLTransactionMetadataStoreProvider.java | 3 ---
.../src/main/java/org/apache/pulsar/websocket/ConsumerHandler.java | 4 ----
.../java/org/apache/bookkeeper/client/PulsarMockBookKeeper.java | 1 -
.../java/org/apache/bookkeeper/client/PulsarMockLedgerHandle.java | 1 -
testmocks/src/main/java/org/apache/zookeeper/MockZooKeeper.java | 2 --
.../offload/filesystem/impl/FileSystemManagedLedgerOffloader.java | 1 -
87 files changed, 11 insertions(+), 143 deletions(-)