Unit test use bkshade jar #2

ArvinDevel · 2017-10-10T02:08:51Z

Modifications

can run unit test directly use bk-shade jar

* Support setting private key content in athenz client plugin * added privateKey field to authParams in athenz client plugin

* Remove Managed Ledger metadata text format * MockZookeeper should store values as byte[] and not convert to String

…apache#714) * Add msgAck and redelivery debug-logs And add topic-name in debug-logs

…no change in code logic (apache#724)

* Validate dynamic-configuration value while updating or init

…apache#726) * Handle NPE at load-manager when leader couldn't find available broker * avoid throwing exception * return empty lookup-result if broker not found

- add `event_time` field in message metadata proto - expose `setEventTime` in MessageBuilder - expose `getEventTime` in Message - add event_time test cases for message & message builder

* Update `protobuf/README.md` *Problem*: the cpp protobuf files are automatically generated by Cmake. we don't need extra instructions for generating cpp files. *Solution*: Remove the content about cpp from `protobuf/README.md` * Update comment - "C++ code is automatically generated by cmake" * Address comment

* Added reader endpoint description to WebSocket.md * Fixed sample code in WebSocket.md * Use on('message',listener) in node.js sample code

* Reader API for C++ clienReader API for C++ clientt * Fixed compile error with listener function * Fixed compile errors and PR comments * Fixed conversion between MessageId and BatchMessageId * Removed usage of std::tie * Revert change in BatchMessageId since it breaks the tracker * Increase available permits only once

…che#754)

…s disabled (apache#748)

BK changes: * Issue apache#372: Allow to configure advertised address in bookies * Fix DoubleByteBuf readableBytes()

* Create pulsar-functions module (#1) * Create pulsar-functions module * rename `sdk` package to `api` * Added the first cut of the Java interface for Pulsar functions (#2) * Added a simple Instance to run the exposed user interfaces * Addressed pr comments plus added tests * Remove unused import

* Create pulsar-functions module (#1) * Create pulsar-functions module * rename `sdk` package to `api` * Added the first cut of the Java interface for Pulsar functions (#2) * Added the first cut of the Spawner * Added more func * Use already existing FunctionConfig * ompiling version * Rationalized the use of data structures * Completed Spawner * Fixed the unittest

* Create pulsar-functions module (#1) * Create pulsar-functions module * rename `sdk` package to `api` * Added the first cut of the Java interface for Pulsar functions (#2) * Make Spawner class public, Use Lombok for getter/setter

* Create pulsar-functions module (#1) * Create pulsar-functions module * rename `sdk` package to `api` * Added the first cut of the Java interface for Pulsar functions (#2) * Added a simple example

* Create pulsar-functions module (#1) * Create pulsar-functions module * rename `sdk` package to `api` * Added the first cut of the Java interface for Pulsar functions (#2) * 1. Start only when there is a subscriber 2. subscription is shared

* Create pulsar-functions module (#1) * Create pulsar-functions module * rename `sdk` package to `api` * Added the first cut of the Java interface for Pulsar functions (#2) * Added join interface to Spawner.

* Create pulsar-functions module (#1) * Create pulsar-functions module * rename `sdk` package to `api` * Added the first cut of the Java interface for Pulsar functions (#2) * Refactored serialization/deserialization into an interface

* Create pulsar-functions module (#1) * Create pulsar-functions module * rename `sdk` package to `api` * Added the first cut of the Java interface for Pulsar functions (#2) * Added a simple String based serde

* Create pulsar-functions module (#1) * Create pulsar-functions module * rename `sdk` package to `api` * Added the first cut of the Java interface for Pulsar functions (#2) * Don't wait for the result. Instead chain it via CompletedFuture

* Create pulsar-functions module (#1) * Create pulsar-functions module * rename `sdk` package to `api` * Added the first cut of the Java interface for Pulsar functions (#2) * Cleaned up the logic of supported types

* Create pulsar-functions module (#1) * Create pulsar-functions module * rename `sdk` package to `api` * Added the first cut of the Java interface for Pulsar functions (#2) * Fix void type handling

* Create pulsar-functions module (#1) * Create pulsar-functions module * rename `sdk` package to `api` * Added the first cut of the Java interface for Pulsar functions (#2) * Added a way to limit the number of outstanding tuples read but still not executed

* Create pulsar-functions module (#1) * Create pulsar-functions module * rename `sdk` package to `api` * Added the first cut of the Java interface for Pulsar functions (#2) * Introduced the concept of systemException to differentiate from userException

* Create pulsar-functions module (#1) * Create pulsar-functions module * rename `sdk` package to `api` * Added the first cut of the Java interface for Pulsar functions (#2) * Refactor cli to establish a base FunctionCommand interface that all subcommands can piggyback

* Create pulsar-functions module (#1) * Create pulsar-functions module * rename `sdk` package to `api` * Added the first cut of the Java interface for Pulsar functions (#2) * Made our function hierarchy match pulsar's * Replace cluster with tenant

* Create pulsar-functions module (#1) * Create pulsar-functions module * rename `sdk` package to `api` * Added the first cut of the Java interface for Pulsar functions (#2) * Added the first cut of the pulsar submit * Working

* Create pulsar-functions module (#1) * Create pulsar-functions module * rename `sdk` package to `api` * Added the first cut of the Java interface for Pulsar functions (#2) * Fix compilation issue

* Create pulsar-functions module (#1) * Create pulsar-functions module * rename `sdk` package to `api` * Added the first cut of the Java interface for Pulsar functions (#2) * Made ack async

* Create pulsar-functions module (#1) * Create pulsar-functions module * rename `sdk` package to `api` * Added the first cut of the Java interface for Pulsar functions (#2) * In case of Kstream style running, we dont need to spawn a executor service to run the message * Update comment

* Create pulsar-functions module (#1) * Create pulsar-functions module * rename `sdk` package to `api` * Added the first cut of the Java interface for Pulsar functions (#2) * Reconciled the interface between worker and client with Jerry * Fixed the update method

* Create pulsar-functions module (#1) * Create pulsar-functions module * rename `sdk` package to `api` * Added the first cut of the Java interface for Pulsar functions (#2) * Adhere to rest semantics

* Create pulsar-functions module (#1) * Create pulsar-functions module * rename `sdk` package to `api` * Added the first cut of the Java interface for Pulsar functions (#2) * Adhere to rest semantics * Complete the list of functions supported by cli

* Create pulsar-functions module (#1) * Create pulsar-functions module * rename `sdk` package to `api` * Added the first cut of the Java interface for Pulsar functions (#2) * Adhere to rest semantics * Convert create function to a post request

* Create pulsar-functions module (#1) * Create pulsar-functions module * rename `sdk` package to `api` * Added the first cut of the Java interface for Pulsar functions (#2) * Adhere to rest semantics * Print the return values for get/list functions. Also print some statements on success

* Create pulsar-functions module (#1) * Create pulsar-functions module * rename `sdk` package to `api` * Added the first cut of the Java interface for Pulsar functions (#2) * Adhere to rest semantics * Renamed FunctionState to FunctionMetaData

hrsakai and others added 30 commits August 25, 2017 10:02

Support setting private key content in athenz client plugin (apache#672)

21a618a

* Support setting private key content in athenz client plugin * added privateKey field to authParams in athenz client plugin

Fix: msg rate acquire permit for msg/bytes (apache#716)

a64d795

add namespace site section and fix headers (apache#719)

1a6ffbf

Remove Managed Ledger metadata text format (apache#394)

3751baf

* Remove Managed Ledger metadata text format * MockZookeeper should store values as byte[] and not convert to String

add msgAck and redelivery debug-logs And add topic-name in debug-logs (…

df93a42

…apache#714) * Add msgAck and redelivery debug-logs And add topic-name in debug-logs

CPP Client: Small fixes to make the code work with older libraries - …

aeeeb56

…no change in code logic (apache#724)

Validate dynamic-configuration value while updating or init (apache#725)

aa40ebb

* Validate dynamic-configuration value while updating or init

Handle NPE at load-manager when leader couldn't find available broker (…

f8b051a

…apache#726) * Handle NPE at load-manager when leader couldn't find available broker * avoid throwing exception * return empty lookup-result if broker not found

Issue 733: Event Time support in java client (apache#734)

070ebc0

- add `event_time` field in message metadata proto - expose `setEventTime` in MessageBuilder - expose `getEventTime` in Message - add event_time test cases for message & message builder

fix code sample (apache#740)

6ca3373

Managed-ledger admin update zk with the stat-version (apache#741)

dec05d8

Added reader endpoint description to WebSocket.md (apache#729)

5f5015b

* Added reader endpoint description to WebSocket.md * Fixed sample code in WebSocket.md * Use on('message',listener) in node.js sample code

Include a pre-built protoc in pulsar-build docker image (apache#743)

a9cca05

Position Reader on a specific message within a batch (apache#720)

f740f34

Make navbar more mobile friendly (apache#728)

9c75f8f

Add user-defined properties to cursor position (apache#744)

8c0d399

Added links to blog posts (apache#723)

6d2f798

Add msg ack-hole metrics to internal-stats and broker-stats (apache#750)

3a775cf

Add configuration to enable throttling for non-backlog consumers (apa…

817898e

…che#754)

Broker side deduplication (apache#751)

bdbb121

Avoid storing ack-msg range while switching-ledger (apache#756)

6e3ba01

Consider cluster-throttling config when namespace-policy throttling i…

c19a1ce

…s disabled (apache#748)

Added Python wrapper for C++ reader API (apache#718)

5cf010e

Updated bookkeper version to 4.3.1.72 (apache#757)

a8abd98

BK changes: * Issue apache#372: Allow to configure advertised address in bookies * Fix DoubleByteBuf readableBytes()

Pulsar Clients: Added a mandatory stop to the Backoff logic (apache#747)

0acfe57

Execute Python client lib unit tests during build (apache#722)

540b9bc

Parse authParamsString on plugin side (apache#671) (apache#721)

2a04683

Issue apache#735: Event Time support in c++ client (apache#736)

8f15858

sijie pushed a commit that referenced this pull request Mar 4, 2018

Added the first cut of the Java interface for Pulsar functions (#2)

9a56774

sijie pushed a commit that referenced this pull request Mar 4, 2018

Asyncack (apache#37)

7fbe342

* Create pulsar-functions module (#1) * Create pulsar-functions module * rename `sdk` package to `api` * Added the first cut of the Java interface for Pulsar functions (#2) * Made ack async

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Unit test use bkshade jar #2

Unit test use bkshade jar #2

ArvinDevel commented Oct 10, 2017

Unit test use bkshade jar #2

Unit test use bkshade jar #2

Conversation

ArvinDevel commented Oct 10, 2017

Modifications