- 06 3月, 2018 1 次提交
-
-
由 Sijie Guo 提交于
* Move pulsar functions dependency version to root pom and remove duplicated license headers This addresses some comments in pulsar functions PR #1314 * shade worker * Fix broken master * Upgrade the bookkeeper storage client dependency to the official bookkeeper version This removes the temp dependency in `pulsar-functions-instance` * set `protobuf2.version` in pulsar-common * provide a shaded worker * include worker dependency at broker * Embeded function worker at broker * rename 'function worker' to 'functions worker' * add "--no-functions-worker" for pulsar-client-cpp tests
-
- 05 3月, 2018 3 次提交
- 04 3月, 2018 36 次提交
-
-
由 Sijie Guo 提交于
- Remove function-composition
-
由 Sanjeev Kulkarni 提交于
-
由 Sanjeev Kulkarni 提交于
-
由 Boyang Jerry Peng 提交于
-
由 Boyang Jerry Peng 提交于
-
由 Sanjeev Kulkarni 提交于
-
由 Sanjeev Kulkarni 提交于
* Create ProcessBuilder at during start() so that start() can be called multiple times from Spawner * Fix unittest
-
由 Sijie Guo 提交于
The `compile` scope in dependency plugin means : compile, provided, and system dependencies
-
由 Sijie Guo 提交于
Example: ``` (CONNECTING) /> (CONNECTED) /> ls pulsar/functions/test test-namespace (CONNECTED) /> ls pulsar/functions/test/test-namespace function11 function12 function13 (CONNECTED) /> ls pulsar/functions/test/test-namespace/function11 8e4dcc81-3b00-4bf9-a489-1823b5514788-pulsar-functions-api-examples.jar (CONNECTED) /> ls pulsar/functions/test/test-namespace/function12 0ee8e267-74cb-4178-99ea-6c723298223c-pulsar-functions-api-examples.jar (CONNECTED) /> ls pulsar/functions/test/test-namespace/function13 8f1dea11-0070-434b-ba97-a42b44d8063c-pulsar-functions-api-examples.jar (CONNECTED) /> ```
-
由 Sijie Guo 提交于
- downloader is writing the package to a temp location - after a package is downloaded, a hardlink is created to link to the temp file. hardlink will ensure one createLink succeed. - after the hardlink is created, the temp files can be deleted. After this change, it allows concurrent downloading without interleaving with each other.
-
由 Sijie Guo 提交于
* Use `distributedlog-core-shaded` in pulsar worker * revert to db ledger storage * Include netty-all * Fix serviceUrl for functions cli
-
由 Sanjeev Kulkarni 提交于
* Move the thread construction to start to avoid illegalstate * Add more checks to see if thread var is init
-
由 Sijie Guo 提交于
-
由 Sijie Guo 提交于
-
由 Sanjeev Kulkarni 提交于
* Support parallelism parameter while running functions locally * Fixed the generation of java and python files
-
由 Sijie Guo 提交于
- the package will be generated under `dist/target/`
-
由 Sanjeev Kulkarni 提交于
-
由 Boyang Jerry Peng 提交于
-
由 Sanjeev Kulkarni 提交于
-
由 Sijie Guo 提交于
-
由 Sijie Guo 提交于
* Upgrade dlog dependency * Make pulsar functions work after rebase - bump zk version 3.5 - use the same dlog version as bookkeeper - change standalone to use sorted ledger storage manager (this is a temp fix to address the issues after rebase)
-
由 Sanjeev Kulkarni 提交于
-
由 Sanjeev Kulkarni 提交于
-
由 Sijie Guo 提交于
-
由 Sanjeev Kulkarni 提交于
-
由 Sanjeev Kulkarni 提交于
-
由 Sanjeev Kulkarni 提交于
Refactored instance related stuff into instance as well as rejiggered utils into its own module (#248) * Refactored instance related stuff into instance as well as rejiggered utils into its own module * Discard empty files
-
由 Sijie Guo 提交于
-
由 Boyang Jerry Peng 提交于
* removing snapshotting * cleaning up
-
由 Sijie Guo 提交于
-
由 Sijie Guo 提交于
- pass `WorkerService` instance around in servlet context - rename `BaseApiResource` to `FunctionApiResource` - rename `ApiV1Resource` to `FunctionApiV1Resource`
-
由 Sijie Guo 提交于
-
由 Sijie Guo 提交于
-
由 Sijie Guo 提交于
* Move all the components required for running worker (except rest endpoint) to WorkerService (#239) * start worker service
-
由 Boyang Jerry Peng 提交于
-
由 Boyang Jerry Peng 提交于
Revert "Move all the components required for running worker (except rest endpoint) to WorkerService (#239)" (#241) This reverts commit 8fd1fd1870753ea8fb2576873800380ac2cea3dd.
-