- 28 8月, 2019 3 次提交
-
-
由 Yong Zhang 提交于
## Motivation Currently, In Pulsar Kerberos authentication, The server type part of pulsar node principle is hard coded as "broker" and "proxy". The expected principle for pulsar nodes would be like "broker/brokera.host.name@your.com" or "proxy/proxyb.host.name@your.com". But some times, user may want to re-use existing principle like "u-service/host.name@some.com", to test and play around, then "u-service" will not match service type of "broker" or "proxy", and the authentication will be rejected. This change is to remove the check of "broker" or "proxy" service type check. ## Modifaction Remove the check of "broker" or "proxy" service type check. (cherry picked from commit f5b20cd3)
-
由 Boyang Jerry Peng 提交于
* Fix: predicate pushdown for Pulsar SQL NPE * fix unit test (cherry picked from commit ac10b006)
-
- 27 8月, 2019 34 次提交
-
-
由 Matteo Merli 提交于
Upgrading to Mockito 2.28 and PowerMock 2.0. This a pre-step to be able to run CI with Java 11 / 12 (cherry picked from commit 108780c7)
-
由 tuteng 提交于
Fixes https://github.com/apache/pulsar/issues/4228 Master Issue: https://github.com/apache/pulsar/issues/4228 ### Motivation Use Pulsar schema in pulsar kafka client. ### Modifications Support schema of pulsar for pulsar kafka client ### Verifying this change Add Unit test (cherry picked from commit 99d3c11e)
-
由 Sijie Guo 提交于
*Motivation* Currently producers uses `System.currentTimeMillis()` as publish timestamp by default. However at some use cases, producers would like to a different way for generating publish timestamp. E.g. in a database use case, a producer might be use HLC (Hybrid Logic Clock) as publish timestamp; in integration tests, it might require the producer to use a deterministic way to generate publish timestamp. *Changes* This PR introduces a `clock` in building the client. This allows applications to override the system clock with its own implementation. *Verify the change* Add unit test to test customized clock in both batch and non-batch cases. (cherry picked from commit 7397b960)
-
由 tuteng 提交于
* ### Motivation When installing the pulsar-client-2.5.0 using the image openjdk:8-jdk-slim, for debian 10 systems, python3.7 will be installed when apt-get install python3 is executed. When installing the client using pip3, the following exception will be thrown ``` cat /etc/issue Debian GNU/Linux 10 \n \l root@40fdedf3f3c3:/# python3 Python 3.7.3 (default, Apr 3 2019, 05:39:12) [GCC 8.3.0] on linux Type "help", "copyright", "credits" or "license" for more information. >>> root@40fdedf3f3c3:/# pip3 install pulsar_client-2.5.0-cp35-cp35m-manylinux1_x86_64.whl ERROR: pulsar_client-2.5.0-cp35-cp35m-manylinux1_x86_64.whl is not a supported wheel on this platform. ``` ### Modifications Install Use pip3.5 instead of pip3. * Deleute no used tools * Fix Docker command (cherry picked from commit 0a59b4ce)
-
由 Sijie Guo 提交于
*Motivation* pulsar-all and pulsar-standalone dont tag correct as pulsar image. so it fails `docker/publish.sh` *Modifications* Tag no-repo for both latest and the release version for both pulsar-all and pulsar-standalone *Verify this change* After patching this change, `docker/publish.sh` works as expected. (cherry picked from commit d2164ebf)
-
由 Ivan Kelly 提交于
feca5bbb changed topic delete logic to delete the schema when the topic is deleted (though this only seems to be enabled for idle topic GC). This exposed a bug in compatibility checking whereby if the a subscription tries to attach to the topic, even if using the same schema as had been used previously, a compatibility exception will be thrown. This is because the topic still appears to have a schema, even though there is no actual schema data, just a tombstone. I've changed the logic to return no schema if the schema read back is a tombstone. The issue doesn't affect producers because the check was already correct there. I've also updated the check for transitive compatibility to remove the prefix of schemas before the deleted schema. Previously this was throwing an NPE on the broker as it couldn't decode the deleted schema. This issue was discovered by failures in the healthcheck. The check period (5 minutes) was longer than the GC period (60 seconds). I would expect it to hit quite often in other scenarios also. (cherry picked from commit d77980d2)
-
由 Matteo Merli 提交于
* Fixed the default port for https and http in admin client * Fixed test expectation * Removed space added by mistake (cherry picked from commit c15c867c)
-
由 Matteo Merli 提交于
### Motivation Fixes #4655 Some compiler will have defined a macro for `DEBUG` and it will clash with the enum value name. Adding prefix to avoid the macro replacement. (cherry picked from commit da4e9323)
-
由 Boyang Jerry Peng 提交于
* fix issue when submitting NAR via file url * fix unit tests * add more specific errors * fix test (cherry picked from commit e8025d50)
-
由 Easyfan Zheng 提交于
C++ client producer sendAsync() method will be blocked forever, if enough batched messages sent timeout. (#4569) (#4657) (cherry picked from commit 2f686157)
-
由 massakam 提交于
### Motivation Currently, the partitioned-stats API response includes stats for each partition. However, if the number of partitions and clients is large, the size of the response will be very large. In such cases, it is useful to have a query parameter to get a response that does not include stats for each partition. ```sh $ curl -s http://localhost:8080/admin/persistent/sample/standalone/ns1/pt1/partitioned-stats | jq . { "msgRateIn": 0, "msgThroughputIn": 0, "msgRateOut": 0, "msgThroughputOut": 0, "averageMsgSize": 0, "storageSize": 0, "publishers": [], "subscriptions": { "sub1": { "msgRateOut": 0, "msgThroughputOut": 0, "msgRateRedeliver": 0, "msgBacklog": 0, "blockedSubscriptionOnUnackedMsgs": false, "msgDelayed": 0, "unackedMessages": 0, "msgRateExpired": 0, "consumers": [], "isReplicated": false } }, "replication": {}, "metadata": { "partitions": 2 }, "partitions": { "persistent://sample/standalone/ns1/pt1-partition-1": { "msgRateIn": 0, "msgThroughputIn": 0, "msgRateOut": 0, "msgThroughputOut": 0, "averageMsgSize": 0, "storageSize": 0, "publishers": [], "subscriptions": { "sub1": { "msgRateOut": 0, "msgThroughputOut": 0, "msgRateRedeliver": 0, "msgBacklog": 0, "blockedSubscriptionOnUnackedMsgs": false, "msgDelayed": 0, "unackedMessages": 0, "msgRateExpired": 0, "consumers": [], "isReplicated": false } }, "replication": {}, "deduplicationStatus": "Disabled" }, "persistent://sample/standalone/ns1/pt1-partition-0": { "msgRateIn": 0, "msgThroughputIn": 0, "msgRateOut": 0, "msgThroughputOut": 0, "averageMsgSize": 0, "storageSize": 0, "publishers": [], "subscriptions": { "sub1": { "msgRateOut": 0, "msgThroughputOut": 0, "msgRateRedeliver": 0, "msgBacklog": 0, "blockedSubscriptionOnUnackedMsgs": false, "msgDelayed": 0, "unackedMessages": 0, "msgRateExpired": 0, "consumers": [], "isReplicated": false } }, "replication": {}, "deduplicationStatus": "Disabled" } } } ``` ### Modifications Added query parameter named `perPartition` to the partitioned-stats API. The default value is true. (cherry picked from commit 977b1a85)
-
由 Rajan Dhabalia 提交于
### Motivation Broker throws NPE when pulsar-admin tries to fetch stats-internal for topic with reader. ``` Caused by: java.lang.NullPointerException at org.apache.bookkeeper.mledger.impl.ManagedCursorImpl.getProperties(ManagedCursorImpl.java:234) ~[classes/:?] at org.apache.pulsar.broker.service.persistent.PersistentTopic.lambda$getInternalStats$48(PersistentTopic.java:1461) ~[classes/:?] at java.lang.Iterable.forEach(Iterable.java:75) ~[?:1.8.0_92] at org.apache.pulsar.broker.service.persistent.PersistentTopic.getInternalStats(PersistentTopic.java:1446) ~[classes/:?] at org.apache.pulsar.broker.admin.impl.PersistentTopicsBase.internalGetInternalStats(PersistentTopicsBase.java:621) ~[classes/:?] at org.apache.pulsar.broker.admin.v2.PersistentTopics.getInternalStats(PersistentTopics.java:430) ~[classes/:?] at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:1.8.0_92] ``` (cherry picked from commit b306552f)
-
由 Matteo Merli 提交于
(cherry picked from commit eea53b7b)
-
由 Boyang Jerry Peng 提交于
* Improve and add authorization to function download and upload * cleaning up * fix bug (cherry picked from commit 20cf7393)
-
由 Rajan Dhabalia 提交于
### Motivation due to some issue if broker fails to complete topic-loading then getting stats of that topic blocks web-thread. ``` "pulsar-web-30-13" #242 prio=5 os_prio=0 tid=0x00002b0b3c001000 nid=0x2540 waiting on condition [0x00002b0aa7d0a000] java.lang.Thread.State: WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x000000072560a180> (a java.util.concurrent.CompletableFuture$Signaller) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) at java.util.concurrent.CompletableFuture$Signaller.block(CompletableFuture.java:1693) at java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3323) at java.util.concurrent.CompletableFuture.waitingGet(CompletableFuture.java:1729) at java.util.concurrent.CompletableFuture.join(CompletableFuture.java:1934) at org.apache.pulsar.broker.admin.impl.PersistentTopicsBase.getTopicReference(PersistentTopicsBase.java:1253) at org.apache.pulsar.broker.admin.impl.PersistentTopicsBase.internalGetStats(PersistentTopicsBase.java:592) at org.apache.pulsar.broker.admin.v1.PersistentTopics.getStats(PersistentTopics.java:240) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) ``` (cherry picked from commit f272df92)
-
由 Boyang Jerry Peng 提交于
(cherry picked from commit c0a57d0e)
-
由 Yijie Shen 提交于
[Client] Consumer for a single partition of a PartitionedTopic should be set with correct partitionIndex (#4591) This PR fixes #4586 by getting `partitionIndex` from topic name. (cherry picked from commit 5de6e6ba)
-
由 Rajan Dhabalia 提交于
(cherry picked from commit fd5d5c2f)
-
由 Rajan Dhabalia 提交于
(cherry picked from commit 20d24996)
-
由 Boyang Jerry Peng 提交于
* Adding null check for function/source/sink configs * adding more checks * fix tests (cherry picked from commit ed7cdca5)
-
由 Boyang Jerry Peng 提交于
* Refactoring Function Component implementation * cleaning up (cherry picked from commit 95df0928)
-
由 rshermanTHG 提交于
(cherry picked from commit ce8f60a3)
-
由 Boyang Jerry Peng 提交于
(cherry picked from commit 362be2a9)
-
由 Boyang Jerry Peng 提交于
(cherry picked from commit 5a10c4ac)
-
由 Rajan Dhabalia 提交于
(cherry picked from commit 8bff6183)
-
由 Sijie Guo 提交于
* Issue #4602: SchemaInfo properties are lost when registering schema using admin api *Motivation* The properties are not uploaded when using admin api. *Modifications* Add the missing `properties` *Verify this change* Add unit test to cover this change * Change protected method to public method (cherry picked from commit aeb4c3d6)
-
由 Yijie Shen 提交于
(cherry picked from commit 9db3a786)
-
由 Jia Zhai 提交于
-
- 27 6月, 2019 1 次提交
-
-
由 lipenghui 提交于
Exclude go module configs check in apache-rat.
-
- 26 6月, 2019 2 次提交