- 30 3月, 2019 40 次提交
-
-
由 Matteo Merli 提交于
-
由 Matteo Merli 提交于
-
由 Matteo Merli 提交于
-
由 Boyang Jerry Peng 提交于
* fix: function config cleanupSubscription update bug * add and fix unit tests
-
由 Boyang Jerry Peng 提交于
* propagate default resource values in Pulsar Functions * fix unit tests
-
由 Matteo Merli 提交于
* Fixed Reader.HasNext() in Go client * Fixed formatting * Removed commented code
-
由 Ezequiel Lovelle 提交于
Fixes #3743 issue. Return previous instance of a consumer in the subscription processed should only be considered with the scope of the same topic. Modifications: - Remove optimization of duplicated consumers for multi topics subscribe and pattern topics subscribe, this should be handled with a different approach. - Filter consumers for the same topic name. - Filter consumers which are connected to broker, this is not necessary to fix this issue but is a good thing to do. - Add test that verifies that same subscription will allow different consumers instance for different topics.
-
由 Sanjeev Kulkarni 提交于
* Expose Secrets in Source/SinkContext * Fix unittest
-
由 Sanjeev Kulkarni 提交于
* Allow users to update everything in inputspecs except for isregexpattern * Added more tests and fixed a bug caught by them
-
由 Matteo Merli 提交于
### Motivation Use at least 8 threads to avoid having Jetty go into threads starving and having the possibility of getting into a deadlock where a Jetty thread is waiting for another HTTP call to complete in same thread. This solve the issues of requests timing out when the broker is making REST calls to itself. Such examples are when running in standalone mode and creating a function.
-
由 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
-