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(-)