You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by mm...@apache.org on 2018/12/13 22:22:13 UTC
[pulsar] branch branch-2.2 updated (8e4b35f -> c8cf25b)
This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a change to branch branch-2.2
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 8e4b35f Update release-notes.md (#2764)
add 2254d90 Fix: deadlock on blocking ml operation (#2745)
add 11553dd Support admin-api for subscription-name with wildcard char (#2809)
add 5a75cb3 Adding option to use TLS in broker admin client. (#2831)
add 5ca5eb3 fix python functions context publish (#2844)
add 6c21eaf Make proxy advertise protocol version of client to broker (#2845)
add c81ba59 Fix Websocket Consume Messages in Partitioned Topics (#2829)
add dc8ea47 class ActiveBroker don't attribute url, use url of class Broker (#2871)
add 0da2e4a Fixed ZLib decompression in C++ client (#2854)
add 0f58b12 Fixing function latency metric arithmetic error (#2868)
add d0dbb21 Upgrade commons-collections for Security Vulnerabilities[CVE-2015-7501] (#2886)
add 74c1372 Updating libpulsar Homebrew recipe to 2.2.0 (#2896)
add a12f48b Handle broker shutdown for already deleted load-balancer znode (#2909)
add d366262 Remove conflicting log4j2 policies (#2955)
add 6f3f40b Fix zk latency metrics collector (#2916)
add bfbf2ef Fixed race condition in schema initialization in partitioned topics (#2959)
add 61cddd1 Derive np topic worker threads based on system config (#2956)
add 2fab7fe Add partitioned-topic stats internal admin-api (#2958)
add 31c607b Fix NPE caused by the race condition (#2973)
add 61ce27d Handle unknown runtime exception while reading entries (#2993)
add de3bd90 Use AbstractCASReferenceCounted to ensure entry.retain() is valid (#2995)
add 3898da5 Fix logic to validate admin calls from proxy (validateOriginalPrincipal) (#2986)
add ea105c9 [proxy] Use ProxyServlet instead of AsyncProxyServlet (#3022)
add ff927e8 Ensure broker is fully boostrapped before load manager register itself (#2935)
add 1048fdd Enable SSL of LibCurl linked to C++ library (#3024)
add 334d334 Add bookkeeper service and other fixes (#3026)
add 7c9c7d8 Fixed lookup of boost_python with boost-1.68 (#3041)
add d546a12 Issue #2751: Add check to fix NPE (#3034)
add 83b420f Update libcurl version included in docker images (#3035)
add bf0cb94 Add pulsar-build:manylinux-cp37-cp37m to pushed docker images (#3091)
add 4c89357 Fix process of calculating msgBacklog included in stats (#3092)
add f38a577 Python Client: fix `Consumer.unsubscribe` (#3093)
add 104092b [bookkeeper] bump bookkeeper version to 4.7.3 (#3129)
add cdbe63d make conf file sync with code (#3169)
add 3af1cec Modify producer handler of WebSocket to send ack to client asynchronously (#3172)
add fc10869 Enable specifying allowed offset when verifying athenz role token (#3187)
add 03d8b0f Allow the option to disable Python wrapper compilation (#3188)
add c8cf25b Release 2.2.1
No new revisions were added by this update.
Summary of changes:
buildtools/pom.xml | 2 +-
conf/broker.conf | 35 ++-
conf/log4j2.yaml | 4 -
conf/proxy.conf | 62 ++++--
dashboard/django/stats/models.py | 2 +-
.../google-kubernetes-engine/bookie.yaml | 32 ++-
.../kubernetes/google-kubernetes-engine/proxy.yaml | 2 +-
distribution/io/pom.xml | 2 +-
distribution/offloaders/pom.xml | 2 +-
distribution/pom.xml | 2 +-
distribution/server/pom.xml | 2 +-
distribution/server/src/assemble/LICENSE.bin.txt | 46 ++--
docker/grafana/pom.xml | 2 +-
docker/pom.xml | 2 +-
docker/pulsar-all/pom.xml | 2 +-
docker/pulsar-standalone/pom.xml | 2 +-
docker/pulsar/pom.xml | 2 +-
examples/flink-consumer-source/pom.xml | 2 +-
examples/pom.xml | 2 +-
jclouds-shaded/pom.xml | 2 +-
managed-ledger-shaded/pom.xml | 2 +-
managed-ledger/pom.xml | 2 +-
.../bookkeeper/mledger/impl/EntryCacheImpl.java | 30 ++-
.../apache/bookkeeper/mledger/impl/EntryImpl.java | 6 +-
.../bookkeeper/mledger/impl/ManagedCursorImpl.java | 4 +-
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 22 +-
.../mledger/util/AbstractCASReferenceCounted.java | 116 ++++++++++
.../bookkeeper/mledger/impl/ManagedCursorTest.java | 31 +++
pom.xml | 15 +-
protobuf-shaded/pom.xml | 3 +-
pulsar-broker-auth-athenz/pom.xml | 2 +-
.../AuthenticationProviderAthenz.java | 23 +-
.../AuthenticationProviderAthenzTest.java | 33 ++-
pulsar-broker-common/pom.xml | 2 +-
.../pulsar/broker/PulsarServerException.java | 9 +
.../apache/pulsar/broker/ServiceConfiguration.java | 25 ++-
.../pulsar/common/configuration/VipStatus.java | 10 +-
pulsar-broker-shaded/pom.xml | 2 +-
pulsar-broker/pom.xml | 2 +-
.../org/apache/pulsar/broker/PulsarService.java | 36 ++-
.../broker/admin/impl/PersistentTopicsBase.java | 28 +++
.../pulsar/broker/admin/v1/PersistentTopics.java | 48 ++--
.../pulsar/broker/admin/v2/PersistentTopics.java | 46 ++--
.../loadbalance/impl/ModularLoadManagerImpl.java | 2 +
.../pulsar/broker/service/BrokerService.java | 10 +-
.../service/schema/BookkeeperSchemaStorage.java | 244 ++++++++++++++-------
.../pulsar/broker/web/PulsarWebResource.java | 14 +-
.../broker/zookeeper/aspectj/ClientCnxnAspect.java | 11 +-
.../apache/pulsar/broker/admin/AdminApiTest.java | 29 +--
.../apache/pulsar/broker/admin/AdminApiTest2.java | 4 +-
.../pulsar/broker/admin/AdminApiTlsAuthTest.java | 8 +-
.../broker/admin/BrokerAdminClientTlsAuthTest.java | 164 ++++++++++++++
.../pulsar/broker/service/ReplicatorTlsTest.java | 6 +-
.../schema/PartitionedTopicsSchemaTest.java | 4 +-
.../pulsar/client/api/BrokerServiceLookupTest.java | 3 +-
.../websocket/proxy/ProxyPublishConsumeTest.java | 43 +++-
pulsar-client-admin-shaded/pom.xml | 2 +-
pulsar-client-admin/pom.xml | 2 +-
.../org/apache/pulsar/client/admin/Topics.java | 21 ++
.../pulsar/client/admin/internal/TopicsImpl.java | 35 +++
pulsar-client-auth-athenz/pom.xml | 2 +-
pulsar-client-cpp/CMakeLists.txt | 75 ++++---
pulsar-client-cpp/docker/Dockerfile | 28 ++-
pulsar-client-cpp/docker/build-wheels.sh | 1 -
pulsar-client-cpp/docker/create-images.sh | 1 -
pulsar-client-cpp/docker/push-images.sh | 2 +-
pulsar-client-cpp/homebrew/libpulsar.rb | 18 +-
pulsar-client-cpp/lib/CompressionCodec.h | 5 +
pulsar-client-cpp/lib/CompressionCodecZLib.cc | 47 +++-
pulsar-client-cpp/lib/CompressionCodecZLib.h | 6 +
pulsar-client-cpp/perf/PerfProducer.cc | 13 ++
pulsar-client-cpp/pkg/deb/Dockerfile | 25 ++-
pulsar-client-cpp/pkg/rpm/Dockerfile | 25 +--
pulsar-client-cpp/python/pulsar/__init__.py | 2 +-
pulsar-client-cpp/python/pulsar_test.py | 1 +
pulsar-client-cpp/tests/ZLibCompressionTest.cc | 65 ++++++
pulsar-client-kafka-compat/pom.xml | 2 +-
.../pulsar-client-kafka-shaded/pom.xml | 2 +-
.../pulsar-client-kafka-tests/pom.xml | 2 +-
.../pulsar-client-kafka/pom.xml | 2 +-
pulsar-client-schema/pom.xml | 2 +-
pulsar-client-shaded/pom.xml | 2 +-
pulsar-client-tools-test/pom.xml | 2 +-
pulsar-client-tools/pom.xml | 2 +-
.../pulsar/admin/cli/CmdPersistentTopics.java | 14 ++
pulsar-client/pom.xml | 2 +-
.../org/apache/pulsar/client/api/MessageId.java | 5 +
.../org/apache/pulsar/client/impl/ClientCnx.java | 10 +-
.../apache/pulsar/client/impl/MessageIdImpl.java | 31 +++
.../client/impl/PartitionedProducerImpl.java | 4 +-
.../client/impl/TypedMessageBuilderImpl.java | 5 +
pulsar-common/pom.xml | 2 +-
.../org/apache/pulsar/common/api/Commands.java | 1 -
...ats.java => PartitionedTopicInternalStats.java} | 10 +-
pulsar-discovery-service/pom.xml | 2 +-
pulsar-flink/pom.xml | 2 +-
pulsar-functions/api-java/pom.xml | 2 +-
pulsar-functions/instance/pom.xml | 2 +-
.../pulsar/functions/instance/FunctionStats.java | 2 +-
.../instance/src/main/python/contextimpl.py | 2 +-
pulsar-functions/java-examples/pom.xml | 2 +-
pulsar-functions/metrics/pom.xml | 2 +-
pulsar-functions/pom.xml | 2 +-
pulsar-functions/proto-shaded/pom.xml | 2 +-
pulsar-functions/proto/pom.xml | 2 +-
pulsar-functions/runtime-all/pom.xml | 2 +-
pulsar-functions/runtime-shaded/pom.xml | 2 +-
pulsar-functions/runtime/pom.xml | 2 +-
pulsar-functions/utils/pom.xml | 2 +-
pulsar-functions/worker/pom.xml | 2 +-
pulsar-io/aerospike/pom.xml | 2 +-
pulsar-io/cassandra/pom.xml | 2 +-
pulsar-io/core/pom.xml | 2 +-
pulsar-io/data-genenator/pom.xml | 2 +-
pulsar-io/debezium/pom.xml | 2 +-
pulsar-io/elastic-search/pom.xml | 2 +-
pulsar-io/hdfs/pom.xml | 2 +-
pulsar-io/jdbc/pom.xml | 2 +-
pulsar-io/kafka-connect-adaptor/pom.xml | 2 +-
pulsar-io/kafka/pom.xml | 2 +-
pulsar-io/kinesis/pom.xml | 2 +-
pulsar-io/pom.xml | 2 +-
pulsar-io/rabbitmq/pom.xml | 2 +-
pulsar-io/twitter/pom.xml | 2 +-
pulsar-log4j2-appender/pom.xml | 2 +-
pulsar-proxy/pom.xml | 2 +-
.../pulsar/proxy/server/AdminProxyHandler.java | 4 +-
.../pulsar/proxy/server/DirectProxyHandler.java | 13 +-
.../apache/pulsar/proxy/server/ProxyClientCnx.java | 40 ++--
.../pulsar/proxy/server/ProxyConnection.java | 28 ++-
.../org/apache/pulsar/proxy/server/ProxyTest.java | 58 +++++
pulsar-spark/pom.xml | 2 +-
pulsar-sql/pom.xml | 2 +-
pulsar-sql/presto-distribution/pom.xml | 2 +-
pulsar-sql/presto-pulsar-plugin/pom.xml | 2 +-
pulsar-sql/presto-pulsar/pom.xml | 2 +-
pulsar-storm/pom.xml | 2 +-
pulsar-testclient/pom.xml | 2 +-
pulsar-websocket/pom.xml | 2 +-
.../apache/pulsar/websocket/ConsumerHandler.java | 3 +-
.../apache/pulsar/websocket/ProducerHandler.java | 20 +-
pulsar-zookeeper-utils/pom.xml | 2 +-
.../pulsar/zookeeper/LocalBookkeeperEnsemble.java | 5 +-
pulsar-zookeeper/pom.xml | 2 +-
tests/docker-images/latest-version-image/pom.xml | 2 +-
tests/docker-images/pom.xml | 2 +-
tests/integration/pom.xml | 2 +-
tests/pom.xml | 2 +-
tests/pulsar-kafka-compat-client-test/pom.xml | 2 +-
tiered-storage/jcloud/pom.xml | 2 +-
tiered-storage/pom.xml | 2 +-
151 files changed, 1528 insertions(+), 465 deletions(-)
create mode 100644 managed-ledger/src/main/java/org/apache/bookkeeper/mledger/util/AbstractCASReferenceCounted.java
create mode 100644 pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/BrokerAdminClientTlsAuthTest.java
create mode 100644 pulsar-client-cpp/tests/ZLibCompressionTest.cc
copy pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/{PartitionedTopicStats.java => PartitionedTopicInternalStats.java} (84%)