- 22 5月, 2019 2 次提交
-
-
由 Jerry Peng 提交于
-
由 Matteo Merli 提交于
-
- 19 5月, 2019 26 次提交
-
-
由 Matteo Merli 提交于
* By default, auto configure the size of Bookie read/write cache * Updated ref docs
-
由 tuteng 提交于
-
由 Matteo Merli 提交于
-
由 Like 提交于
-
由 Rajan Dhabalia 提交于
[pulsar-function] fix broken backward compatibility with v1-namespace while registering function (#4224)
-
由 Ivan Kelly 提交于
The sendTimer_ may not be initialized if connection doesn't come up correctly.
-
由 Matteo Merli 提交于
-
由 Ezequiel Lovelle 提交于
* Revert "[cpp client] implement reference count for close() (#3863)" This reverts commit ee98e8b2. * Revert Prevent dup consumers and refCount for cpp client Revert "[cpp client] Bugfix prevent dup consumer for same topic subscription" Revert "[Issue #3226][cpp client] Prevent dup consumers on same client cnx" This reverts commit fff02e2a. This reverts commit 762e0ab9. * Revert "Feature - implement reference count for ConsumerImpl (#3795)" This reverts commit ff4db8db. * Revert Prevent dup consumers and refCount for java client Revert "Prevent dup consumers on same client cnx with shared subscription" Revert "[java client] Bugfix prevent dup consumers for same topic subscribe" This reverts commit 231db030. This reverts commit fb5dcd9a.
-
由 Rajan Dhabalia 提交于
### Motivation Function worker uses bookie and zookeeper to store function's executable. However, function doesn't support authentication while connecting to bookie so, dbLog initialize fails when bookie requires auth&auth. ### Modification Add bk-client authentication param to worker-config.
-
由 Boyang Jerry Peng 提交于
* Optimizing performance for download * fixing update and create * fix upload * remove commented out code * remove blank lines * fix error messages * fix for sources and sinks * fix getting exception * fix auth headers * cleaning up * fix print messages
-
由 Matteo Merli 提交于
-
由 massakam 提交于
* Set actual topic name to partitioned consumer * Change dummy topic name prefix
-
由 Boyang Jerry Peng 提交于
* fix bug in source and sink cli update * fix import * fix logic * fix tests
-
由 Boyang Jerry Peng 提交于
### Motivation Only initialize factory once in the beginning
-
由 massakam 提交于
-
由 Boyang Jerry Peng 提交于
-
由 Boyang Jerry Peng 提交于
-
由 Matteo Merli 提交于
-
由 Ivan Kelly 提交于
When a python functions instance is started with state enabled, it crashes because the state client cannot connect to the state endpoints. This is because the state client is *never* given the state endpoints, so there's no way it ever could connect.
-
由 Sanjeev Kulkarni 提交于
-
由 Yoann Ciabaud 提交于
-
由 tuteng 提交于
Fixes #3987 ### Motivation Config will not appear null when create tenant use pulsar-admin create foo3, but use the following command, config is null. ``` curl -X PUT http://localhost:8080/admin/v2/tenants/foo3 ``` ### Modifications Handle config is null when create tenant use curl. ### Verifying this change Test pass ``` curl -X PUT http://localhost:8080/admin/v2/tenants/foo3 curl -X GET http://localhost:8080/admin/v2/tenants/foo3 {"adminRoles":[],"allowedClusters":[]} ```
-
由 Ali Ahmed 提交于
We require a certain version of bookkeeper client to operate python function state correctly.
-
由 Boyang Jerry Peng 提交于
Improve error handling for triggering function when input data does not conform with input topic schema (#3995)
-
由 Ezequiel Lovelle 提交于
*Motivation* Trying to fix #3975 When a reset of a cursor is performed with some timestamp on a non-durable consumer the message finder will fail with null pointer exception due to `cursor.getName()` being null. *Modifications* - Add method overloading for `newNonDurableCursor()` with subscription name. - Fix method getNonDurableSubscription to call `newNonDurableCursor()` with proper subscription name - Add test to assert issue.
-
由 Rajan Dhabalia 提交于
### Motivation Log Producer/Consumer Id when broker logs "Producer/consumer is already connected" to help in debugging when client is keep failing to create producer and broker is keep logging the same error.
-
- 07 5月, 2019 1 次提交
-
-
由 冉小龙 提交于
* Fixed conversion of unix timestamp to golang time (#3659) * fix cannot use size (type _Ctype_int) as type _Ctype_ulong Signed-off-by: Nxiaolong.ran <ranxiaolong716@gmail.com>
-
- 03 5月, 2019 1 次提交
-
-
由 Sijie Guo 提交于
*Motivation* AlwaysCompatible flag doesn't work in 2.3.1 because the flag is using NeverSchemaValidator *Modifications* Change to use AlwaysSchemaValidator
-
- 09 4月, 2019 4 次提交
-
-
由 massakam 提交于
-
由 Matteo Merli 提交于
-
由 Matteo Merli 提交于
-
由 Sanjeev Kulkarni 提交于
-
- 05 4月, 2019 4 次提交
-
-
由 Matteo Merli 提交于
-
由 Matteo Merli 提交于
-
由 Matteo Merli 提交于
* Fixed issue with Authorization header missing after client gets redirected * Use AsyncHttpClient instead * Fixed merge issue * Convert headers after body to not break multipart encoding * Fixed tests * Added missing property file for AsyncHttpClient in the shaded jar * Moved ahc.properties into org.asynchttpclient.config * One value was missing from properties file * Also add default file for non-shaded scenario * Another missing AHC config key * Print topic load exception * Removed constraint on unit tests executor
-
由 Sanjeev Kulkarni 提交于
-
- 02 4月, 2019 2 次提交
-
-
由 Matteo Merli 提交于
-
由 Yuvaraj L 提交于
* Exposing getSchemaVersion in the client by making it public. * Implemented getSchemaVersion in TopicMessageImpl.java * Changed the release version
-