pulsar-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rdhaba...@apache.org
Subject [pulsar] branch branch-2.2 updated (7a439b3 -> 8e4b35f)
Date Fri, 12 Oct 2018 18:25:41 GMT
This is an automated email from the ASF dual-hosted git repository.

rdhabalia pushed a change to branch branch-2.2
in repository https://gitbox.apache.org/repos/asf/pulsar.git.


 discard 7a439b3  Update release-notes.md (#2764)
    omit dd50929  Fixed apache-rat validations
    omit 9a46975  Release 2.2.0
     add dd4f71d   [clients][kafka] Fix topic name & race condition on kafka wrapper (#2746)
     add f718128  All grpc calls should have timeouts (#2747)
     add 90aa408  Fix getstatus logic in kubernetes runtime (#2748)
     add 83da460  Avoid shading netty in managed-ledger-shaded (#2741)
     add b22f59c  Fixed apache-rat validations (#2753)
     add 95f67d0   [python] MessageId.serialize() should return bytes instead of str  (#2750)
     add 8d396c3  [c++] Fixed virtual destructors (#2754)
     add 6d6155e  fix: function update and related tests are broken (#2755)
     add 362f795  change constructor access for ConsumerBuilderImpl (#2759)
     add 18c26e0  Do not create any producer if the output type of a function is void (#2756)
     add 6e9b6c2  Issue #2757: Kafka source connector should just transfer bytes (#2761)
     add 4ed2e33  Fix Topic Pattern functionality for Python functions (#2760)
     add 591df49  Fix IdentitySerde (#2762)
     add 6b15a6b  Bumped version to 2.3.0-SNAPSHOT (#2765)
     add 11a6982  Fixed link and spacing for python docs (#2763)
     add 04bd8bd  fix classname flag in python function example (#2766)
     add a51e6d1  Remove `install_usercode_dependencies` from java instance main (#2768)
     add fa589ed  [website] make sure 2.1.1 documentation reflects to the features in 2.1.1
(#2769)
     add 60a6a7b  Added script to change the project version in 1 command (#2772)
     add 89ccde0  Metrics Collector Agent for Functions running in Kubernetes (#2773)
     add ec51612  Enhance publish method to allow properties (#2777)
     add 412859d  Fix the variable name for getting current topic name (#2776)
     add 592737a  For externally managed functions, function worker should not do metrics
management (#2775)
     add 9bf3357  Make Pulsar Docker have very short ttl cache time so that bookie changes
etc are reacted to quickly (#2774)
     add f077f9d  Fixed shading of Netty (#2783)
     add 3a66808  Added ability to specify compression while publishing (#2781)
     add a1a1abe  add initialize routine to FunctionRuntimeManager (#2784)
     add b6a25f0  fix: unsafe cast of schema to JSONSchema (#2779)
     add c2977be  Java Client - Threads to inherit daemon status from thread creating the
client (#2770)
     add 7d2a012  Refresh ZK cache based on insertion time rather than access (#2785)
     new 8add794  Release 2.2.0
     new 8e4b35f  Update release-notes.md (#2764)

This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version.  This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:

 * -- * -- B -- O -- O -- O   (7a439b3)
            \
             N -- N -- N   refs/heads/branch-2.2 (8e4b35f)

You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.

Any revisions marked "omit" are not gone; other references still
refer to them.  Any revisions marked "discard" are gone forever.

The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 buildtools/src/main/resources/log4j2.xml           |   1 +
 distribution/server/src/assemble/bin.xml           |   5 +
 docker/pulsar/Dockerfile                           |   1 +
 managed-ledger-shaded/pom.xml                      |  29 ++-
 protobuf-shaded/pom.xml                            |   1 +
 pulsar-broker-shaded/pom.xml                       |   4 +-
 .../pulsar/broker/admin/impl/FunctionsBase.java    |   2 +-
 .../org/apache/pulsar/io/PulsarSinkE2ETest.java    |   2 +-
 pulsar-client-admin-shaded/pom.xml                 |   4 +-
 pulsar-client-cpp/include/pulsar/CryptoKeyReader.h |   2 +-
 pulsar-client-cpp/include/pulsar/Logger.h          |   2 +
 pulsar-client-cpp/include/pulsar/TopicMetadata.h   |   2 +
 pulsar-client-cpp/lib/Hash.h                       |   2 +
 pulsar-client-cpp/python/pulsar/__init__.py        |  12 +-
 .../python/pulsar/functions/context.py             |   5 +-
 pulsar-client-cpp/python/pulsar/functions/serde.py |  16 +-
 pulsar-client-cpp/python/pulsar_test.py            |   6 +
 pulsar-client-cpp/python/src/message.cc            |  34 ++-
 .../pulsar-client-kafka-shaded/pom.xml             |   1 +
 .../clients/consumer/PulsarKafkaConsumer.java      |  37 ++-
 pulsar-client-schema/pom.xml                       |   4 +-
 pulsar-client-shaded/pom.xml                       |   4 +-
 .../pulsar/client/impl/ConsumerBuilderImpl.java    |   2 +-
 .../apache/pulsar/client/impl/ProducerImpl.java    |   4 +-
 .../pulsar/client/impl/PulsarClientImpl.java       |  10 +-
 .../pulsar/client/util/ExecutorProvider.java       |   9 +-
 .../apache/pulsar/functions/sink/PulsarSink.java   |   6 +-
 .../instance/src/main/python/contextimpl.py        |  14 +-
 .../instance/src/main/python/python_instance.py    |   7 +-
 .../pulsar/functions/sink/PulsarSinkTest.java      |  12 +-
 pulsar-functions/metrics/pom.xml                   |  38 +++
 .../functions/metrics/PrometheusMetricsServer.java | 137 ++++++++++
 .../functions/metrics/sink/AbstractWebSink.java    |   6 +-
 .../src/main/proto/InstanceCommunication.proto     |   1 +
 .../pulsar/functions/runtime/JavaInstanceMain.java |   3 -
 .../functions/runtime/KubernetesRuntime.java       | 100 +++++++-
 .../runtime/KubernetesRuntimeFactory.java          |  11 +-
 .../pulsar/functions/runtime/ProcessRuntime.java   |  11 +-
 .../pulsar/functions/runtime/RuntimeUtils.java     |   9 +-
 .../functions/runtime/KubernetesRuntimeTest.java   |  19 +-
 .../functions/worker/FunctionAssignmentTailer.java |  16 +-
 .../functions/worker/FunctionMetaDataManager.java  |   4 +-
 .../functions/worker/FunctionRuntimeManager.java   | 168 ++++++++++---
 .../pulsar/functions/worker/SchedulerManager.java  |   5 +-
 .../pulsar/functions/worker/WorkerConfig.java      |   1 +
 .../pulsar/functions/worker/WorkerService.java     |   3 +
 .../functions/worker/rest/api/FunctionsImpl.java   |   8 +-
 .../worker/rest/api/v2/FunctionApiV2Resource.java  |   2 +-
 .../worker/FunctionRuntimeManagerTest.java         | 132 +++++++++-
 .../functions/worker/SchedulerManagerTest.java     |  37 ++-
 .../pulsar/io/kafka/KafkaAbstractSource.java       |   6 +-
 ...afkaStringSource.java => KafkaBytesSource.java} |  23 +-
 .../resources/META-INF/services/pulsar-io.yaml     |   2 +-
 pulsar-spark/pom.xml                               |   3 -
 pulsar-sql/presto-distribution/LICENSE             |   8 -
 pulsar-sql/presto-distribution/pom.xml             |   2 +-
 .../pulsar/sql/presto/TestPulsarConnector.java     |  16 +-
 .../apache/pulsar/zookeeper/ZooKeeperCache.java    |   6 +-
 site2/docs/client-libraries-python.md              |   2 +-
 site2/docs/functions-quickstart.md                 |   2 +-
 .../client-libraries-cpp.md                        |   8 +-
 .../client-libraries-python.md                     |   2 +-
 .../version-2.1.0-incubating/io-quickstart.md      |   2 +-
 .../version-2.1.1-incubating/adaptors-kafka.md     |   2 -
 .../client-libraries-python.md                     |   2 +-
 .../cookbooks-tiered-storage.md                    | 125 ++--------
 .../version-2.1.1-incubating/deploy-bare-metal.md  |   4 +-
 .../version-2.1.1-incubating/functions-api.md      |  65 ++---
 .../functions-deploying.md                         |  20 +-
 .../functions-guarantees.md                        |   4 +-
 .../version-2.1.1-incubating/functions-overview.md |  24 +-
 .../functions-quickstart.md                        |  10 +-
 .../version-2.1.1-incubating/io-managing.md        |  20 +-
 .../version-2.1.1-incubating/io-quickstart.md      |   2 +-
 .../reference-pulsar-admin.md                      | 277 +++++----------------
 .../sql-deployment-configurations.md               | 151 -----------
 .../sql-getting-started.md                         | 143 -----------
 .../version-2.1.1-incubating/sql-overview.md       |  25 --
 .../version-2.1.1-incubating-sidebars.json         | 116 +++++++++
 .../set-project-version.sh                         |  21 +-
 ...luster-2-bookie-1-broker-unstarted-with-s3.yaml | 164 ------------
 tests/integration/pom.xml                          |  11 +
 .../integration/functions/PulsarFunctionsTest.java |  78 +++++-
 .../functions/utils/CommandGenerator.java          |  22 +-
 .../topologies/PulsarStandaloneTestBase.java       |   1 -
 tests/pom.xml                                      |   1 +
 .../pom.xml                                        |  92 +------
 .../integration/compat/kafka/KafkaApiTest.java     |  83 +++---
 88 files changed, 1242 insertions(+), 1254 deletions(-)
 create mode 100644 pulsar-functions/metrics/src/main/java/org/apache/pulsar/functions/metrics/PrometheusMetricsServer.java
 copy pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/{KafkaStringSource.java =>
KafkaBytesSource.java} (53%)
 delete mode 100644 site2/website/versioned_docs/version-2.1.1-incubating/sql-deployment-configurations.md
 delete mode 100644 site2/website/versioned_docs/version-2.1.1-incubating/sql-getting-started.md
 delete mode 100644 site2/website/versioned_docs/version-2.1.1-incubating/sql-overview.md
 create mode 100644 site2/website/versioned_sidebars/version-2.1.1-incubating-sidebars.json
 copy docker/pulsar/scripts/pulsar-zookeeper-ruok.sh => src/set-project-version.sh (66%)
 delete mode 100644 tests/integration-tests-topologies/src/main/resources/cube-definitions/single-cluster-2-bookie-1-broker-unstarted-with-s3.yaml
 copy tests/{integration => pulsar-kafka-compat-client-test}/pom.xml (58%)
 rename tests/{integration => pulsar-kafka-compat-client-test}/src/test/java/org/apache/pulsar/tests/integration/compat/kafka/KafkaApiTest.java
(88%)


Mime
View raw message