- 30 3月, 2019 30 次提交
-
-
由 Sanjeev Kulkarni 提交于
* Retry creation of assignment topic a few times before giving up * Use Action based retry mechanism * Fix build * Catch interrupted exception * Fix unittest * Added header
-
由 Matteo Merli 提交于
-
由 Boyang Jerry Peng 提交于
* fix function termination cleanup * cleaning up
-
由 Sanjeev Kulkarni 提交于
* Simplified the workflow of functionruntime manager * Fix unittest * Took feedback into account * added missing imports
-
由 Sanjeev Kulkarni 提交于
* On publish failures, log error and count them as sys exceptions * Took feedback
-
由 Sanjeev Kulkarni 提交于
-
由 Sanjeev Kulkarni 提交于
-
由 nkurihar 提交于
-
由 Matteo Merli 提交于
* When the loadmanager leader is not available, fall through regular least loaded selection * Handle exceptions coming from mock zk in tests
-
由 Rajan Dhabalia 提交于
-
由 Rajan Dhabalia 提交于
-
由 Sanjeev Kulkarni 提交于
-
由 Boyang Jerry Peng 提交于
-
由 Boyang Jerry Peng 提交于
-
由 Boyang Jerry Peng 提交于
* report sys errors when failed to produce sucessfully * enhancing error message * adding metrics to context publish * enhancing error logging and adding java error handling * fixing tests * cleaning up * addressing comments and fix bug * cleaning up * fix bug * fix test * check is none * fix unit test * cleaning up
-
由 Matteo Merli 提交于
* In C++ allow messages that compress to <5mb to be sent with batching enabled * Fixed related test
-
由 Rajan Dhabalia 提交于
* [pulsar-broker] redelivery tracker use open hashmap * fix redel count
-
由 Matteo Merli 提交于
-
由 Boyang Jerry Peng 提交于
-
由 Fangbin Sun 提交于
* Support '--help' option of Pulsar command-line tools. * Fix a indentation * Fix a minor bug
-
由 massakam 提交于
-
由 Sijie Guo 提交于
*Motivation* Fixes #3651 `pulsar-io-debezium` is a normal module but not a connector package. it was added as a connector package by mistake at #3601. This would cause failing to load connectors during broker starts up. *Changes* - remove nar plugin from `pulsar-io-debezium` - remove `pulsar-io-debezium` from distribution - add `pulsar-io-kafka-connect-adaptor` in the website
-
由 Boyang Jerry Peng 提交于
* allow for graceful shutdown when running functions in kubernetes * cleaning up * fix unit tests
-
由 Boyang Jerry Peng 提交于
-
由 Matteo Merli 提交于
-
由 Matteo Merli 提交于
* Use default queue size in function producer * Fixed queue size
-
由 Matteo Merli 提交于
* Fixed C++ batch acks tracker to evict message from sendList array * Fixed formatting
-
由 Boyang Jerry Peng 提交于
-
由 Boyang Jerry Peng 提交于
* adding memory padding to memory limits set in kubernetes * cleaning up
-
由 Boyang Jerry Peng 提交于
* fix: add retry and wait for kubernetes creation/deletion * cleaning up * adding retry logic for cleaning up subscriptions * adjust number of retries * correcting namespace
-
- 15 2月, 2019 4 次提交
-
-
由 Matteo Merli 提交于
-
由 Matteo Merli 提交于
### Motivation Fixes the Apache RAT check to exclude the auto-generated files from Avro compiler and Avro JSON schema definitions.
-
由 Matteo Merli 提交于
### Motivation Building Python wheels is failing in the updated Docker image for Python 3.4, 3.5 and 3.6. Fixing it here by explicitly including the library defined variables.
-
由 Matteo Merli 提交于
-
- 14 2月, 2019 6 次提交
-
-
由 Fangbin Sun 提交于
-
由 Matteo Merli 提交于
-
由 Matteo Merli 提交于
-
由 Matteo Merli 提交于
### Motivation Fixed flaky test in `AuthPluginTest.testTlsDetectPulsarSslWithHostNameValidation`. The failure was due to the fact that test is creating a producer asynchronously but not waiting for the future to be completed.
-
由 Matteo Merli 提交于
-
由 Matteo Merli 提交于
* If no clusters are specified, the namespace should by default use current cluster * Don't apply to v1 local namespaces * It's better to use the isV2() check instead of isGlobal()
-