[GitHub] [pulsar] wolfstudy commented on issue #5357: [functions][Issue:5350]Fix pulsar can't load the customized SerDe
wolfstudy commented on issue #5357: [functions][Issue:5350]Fix pulsar can't load the customized SerDe URL: https://github.com/apache/pulsar/pull/5357#issuecomment-546571922 @sijie PTAL This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] wolfstudy commented on issue #5357: [functions][Issue:5350]Fix pulsar can't load the customized SerDe
wolfstudy commented on issue #5357: [functions][Issue:5350]Fix pulsar can't load the customized SerDe URL: https://github.com/apache/pulsar/pull/5357#issuecomment-546571753 run cpp tests This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[pulsar] branch master updated: Update resources.js (#5468)
This is an automated email from the ASF dual-hosted git repository.
sijie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 43984ba Update resources.js (#5468)
43984ba is described below
commit 43984bacd1e318b7a3c00aa358d4acef7a20e7a3
Author: Jennifer Huang <47805623+jennifer88hu...@users.noreply.github.com>
AuthorDate: Sat Oct 26 11:50:42 2019 +0800
Update resources.js (#5468)
### Motivation
Some resources are not added to the Resources page.
### Modifications
Add more resources related to Apache Pulsar blogs and presentations.
---
site2/website/data/resources.js | 122
1 file changed, 122 insertions(+)
diff --git a/site2/website/data/resources.js b/site2/website/data/resources.js
index 6e9e108..90ccc45 100644
--- a/site2/website/data/resources.js
+++ b/site2/website/data/resources.js
@@ -50,6 +50,48 @@ module.exports = {
},
{
forum: 'StreamNative blog',
+forum_link: 'https://streamnative.io/',
+title: "Powering Tencent Billing Platform with Apache Pulsar",
+link:
'https://streamnative.io/blog/tech/2019-10-22-powering-tencent-billing-platform-with-apache-pulsar/'
+},
+{
+forum: 'StreamNative blog',
+forum_link: 'https://streamnative.io/',
+title: "Use Apache SkyWalking to Trace Apache Pulsar Messages",
+link:
'https://streamnative.io/blog/tech/2019-10-10-use-apache-skywalking-to-trace-apache-pulsar/'
+},
+{
+forum: 'StreamNative blog',
+forum_link: 'https://streamnative.io/',
+title: "StreamNative open sourced and contributed Apache Pulsar
Manager to ASF",
+link:
'https://streamnative.io/blog/tech/2019-09-24-streamnative-opensourced-pulsar-manager/'
+},
+{
+forum: 'StreamNative blog',
+forum_link: 'https://streamnative.io/',
+title: "Apache Pulsar Adoption Story in ActorCloud (IoT Platform)",
+link:
'https://streamnative.io/blog/tech/2019-09-09-apache-pulsar-adoption-in-actorcloud/'
+},
+{
+forum: 'StreamNative blog',
+forum_link: 'https://streamnative.io/',
+title: "Apache Pulsar at Yahoo!JAPAN",
+link:
'https://streamnative.io/blog/tech/2019-09-06-pular-at-yahoo-japan/'
+},
+{
+forum: 'StreamNative blog',
+forum_link: 'https://streamnative.io/',
+title: "Build a Priority-based Push Notification System Using Apache
Pulsar at GeTui",
+link:
'https://streamnative.io/blog/tech/2019-07-23-build-a-priority-based-push-notification-system-using-apache-pulsar-at-getui/'
+},
+{
+forum: 'StreamNative blog',
+forum_link: 'https://streamnative.io/',
+title: "Use Apache Pulsar as Streaming Table with 8 Lines of Code",
+link:
'https://streamnative.io/blog/tech/2019-08-28-use-apache-pulsar-as-streaming-table-with-8-lines-of-code/'
+},
+{
+forum: 'StreamNative blog',
forum_link: 'https://medium.com/streamnative/',
title: 'Apache Pulsar as One Unified Storage System for Real Time and
Historical Analysis',
link:
'https://medium.com/streamnative/apache-pulsar-as-one-storage-455222c59017'
@@ -202,6 +244,86 @@ module.exports = {
],
presentations: [
{
+ forum: 'Flink Forward Europe',
+ forum_link: 'https://europe-2019.flink-forward.org/',
+ presenter: 'Sijie Guo',
+ date: 'October 2019',
+ title: "Query Pulsar Streams using Apache Flink",
+ link:
'https://www.slideshare.net/streamnative/query-pulsar-streams-using-apache-flink'
+},
+{
+ forum: 'Strata Data Conference | New York',
+ forum_link: 'https://conferences.oreilly.com/strata/strata-ny',
+ presenter: 'Vincent Xie, Jia Zhai',
+ date: 'September 2019',
+ title: "How Orange Financial combat financial frauds over 50M
transactions a day using Apache Pulsar",
+ link:
'https://www.slideshare.net/streamnative/how-orange-financial-combat-financial-frauds-over-50m-transactions-a-day-using-apache-pulsar-176284080'
+},
+{
+ forum: 'ApacheCon NA 2019',
+ forum_link: 'https://www.apachecon.com/acna19/',
+ presenter: 'Xiaolong Ran',
+ date: 'September 2019',
+ title: "Serverless Event Streaming with Pulsar Functions",
+ link:
'https://www.slideshare.net/streamnative/serverless-event-streaming-with-pulsar-functions-171597848'
+},
+{
+ forum: 'ApacheCon NA 2019',
+ forum_link: 'https://www.apachecon.com/acna19/',
+ presenter: 'Penghui Li, Jia Zhai',
+ date: 'September 2019',
+ title: "Building Zhaopin's enterprise event center on Apache Pulsar",
+ link:
'https://www.slideshare.net/streamnative/building-zhaopins-enterprise-event-center-on-apache-pulsar'
+},
+{
+ forum: '',
+
[GitHub] [pulsar] sijie merged pull request #5468: [website] Update resources.js
sijie merged pull request #5468: [website] Update resources.js URL: https://github.com/apache/pulsar/pull/5468 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] sijie commented on issue #3555: Allow to automatically assign TCP ports when starting a broker
sijie commented on issue #3555: Allow to automatically assign TCP ports when starting a broker URL: https://github.com/apache/pulsar/pull/3555#issuecomment-546565044 @merlimat my point is to prevent mistakes like what we did in bookkeeper. 0 is only useful in tests, but it is actually harmful in production. we should provide a flag to prevent mistakes. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] tuteng commented on issue #5467: [website] Update PMC and committer info in team.js
tuteng commented on issue #5467: [website] Update PMC and committer info in team.js URL: https://github.com/apache/pulsar/pull/5467#issuecomment-546546986 run cpp tests run java8 tests This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] aahmed-se commented on issue #5328: Increase the retries count for PulsarFunctionStateTest
aahmed-se commented on issue #5328: Increase the retries count for PulsarFunctionStateTest URL: https://github.com/apache/pulsar/pull/5328#issuecomment-546545641 run java8 tests This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] aahmed-se commented on issue #5043: [zookeeper] bump zookeeper to version 3.5.5
aahmed-se commented on issue #5043: [zookeeper] bump zookeeper to version 3.5.5 URL: https://github.com/apache/pulsar/pull/5043#issuecomment-546543866 @addisonj can you rebase this on master. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] aahmed-se commented on issue #5390: Use pure-java Air-Compressor instead of JNI based libraries
aahmed-se commented on issue #5390: Use pure-java Air-Compressor instead of JNI based libraries URL: https://github.com/apache/pulsar/pull/5390#issuecomment-546543574 run java8 tests run integration tests This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[pulsar] branch master updated (c38be69 -> fbe1ed2)
This is an automated email from the ASF dual-hosted git repository. aahmed pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git. from c38be69 Use individual netty-* artifacts instead of netty-all (#3613) add fbe1ed2 Fix broken link to k8s YAML definitions (#5332) No new revisions were added by this update. Summary of changes: site2/docs/deploy-kubernetes.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-)
[GitHub] [pulsar] aahmed-se merged pull request #5332: [docs] Fix broken link to k8s YAML definitions
aahmed-se merged pull request #5332: [docs] Fix broken link to k8s YAML definitions URL: https://github.com/apache/pulsar/pull/5332 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] youurayy commented on issue #3832: io.netty.handler.codec.TooLongFrameException: Adjusted frame length exceeds 5242880: 369295620 - discarded
youurayy commented on issue #3832: io.netty.handler.codec.TooLongFrameException: Adjusted frame length exceeds 5242880: 369295620 - discarded URL: https://github.com/apache/pulsar/issues/3832#issuecomment-546494190 This happens when you try to connect with `pulsar+ssl://` to a `https://` pulsar API endpoint. The currently thrown exception is confusing. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] aahmed-se commented on issue #5334: When building docker image, copy tarball at the end to use build cache
aahmed-se commented on issue #5334: When building docker image, copy tarball at the end to use build cache URL: https://github.com/apache/pulsar/pull/5334#issuecomment-546528026 run java 8 tests This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] johnwagster commented on issue #5469: added deletion of state for Functions
johnwagster commented on issue #5469: added deletion of state for Functions URL: https://github.com/apache/pulsar/pull/5469#issuecomment-546517270 I'd be happy to add state delete to the admin cli and rest endpoints. Would you like to see that in this PR or is a separate PR alright? This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] jerrypeng commented on issue #5469: added deletion of state for Functions
jerrypeng commented on issue #5469: added deletion of state for Functions URL: https://github.com/apache/pulsar/pull/5469#issuecomment-546515667 @johnwagster it would be great if you can also add the delete functionality to the pulsar-admin CLI and a corresponding REST endpoint! This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] jerrypeng commented on issue #5469: added deletion of state for Functions
jerrypeng commented on issue #5469: added deletion of state for Functions URL: https://github.com/apache/pulsar/pull/5469#issuecomment-546515113 rerun integration tests This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] johnwagster opened a new pull request #5469: added deletion of state for Functions
johnwagster opened a new pull request #5469: added deletion of state for Functions URL: https://github.com/apache/pulsar/pull/5469 ### Motivation Adding support for state deletion for Functions. Ran into a use-case where it would be nice to be able to let go of state wherein the key is changing but the data itself is ephemeral. ### Modifications I've reflected the changes in the bookkeepr API back through in the context and state context API's so that you can delete on a put by passing null or call the new api for delete. ### Verifying this change This change added tests and can be verified as follows: - Running the unit tests available in the ContextImplTest and ContextStateImplTest ### Does this pull request potentially affect one of the following parts: - The public API: yes; added deletion to Function context and state context APIs ### Documentation - Does this pull request introduce a new feature? - yes - If yes, how is the feature documented? - JavaDocs This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] jm7647 edited a comment on issue #5454: mysql JDBC Sink - consumer error
jm7647 edited a comment on issue #5454: mysql JDBC Sink - consumer error
URL: https://github.com/apache/pulsar/issues/5454#issuecomment-546101921
This is producer code I used based on your sample - still same error:
producer = client.create_producer(
topic='pulsar-mysql-jdbc-sink-topic',
properties={"EVENT": "INSERT"},
schema=AvroSchema(Test))
r = Test(id=1, name="Hello World")
producer.send(r)
Additional observation:
Above error also makes sink stop running, it attempts to restart in a loop
but fails with same error therefor according to status it is not running any
more:
bin/pulsar-admin sinks status --tenant public --namespace default --name
pulsar-mysql-jdbc-sink
{
"numInstances" : 1,
"numRunning" : 0,
"instances" : [ {
"instanceId" : 0,
"status" : {
"running" : **false,**
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
With regards,
Apache Git Services
[GitHub] [pulsar] jerrypeng commented on issue #5463: Function runtime pluggable
jerrypeng commented on issue #5463: Function runtime pluggable URL: https://github.com/apache/pulsar/pull/5463#issuecomment-546459326 rerun integration tests This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] merlimat commented on issue #3555: Allow to automatically assign TCP ports when starting a broker
merlimat commented on issue #3555: Allow to automatically assign TCP ports when starting a broker URL: https://github.com/apache/pulsar/pull/3555#issuecomment-546441832 @sijie Binding on 0 is a common property of servers since it's supported by the OS. I don't think we need to have an extra flag to enable that since it's an explicit configuration setting that the user has to set. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[pulsar] branch master updated (d0fde69 -> c38be69)
This is an automated email from the ASF dual-hosted git repository. mmerli pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git. from d0fde69 [integration-tests]Enable messaging tests to integration tests. (#5456) add c38be69 Use individual netty-* artifacts instead of netty-all (#3613) No new revisions were added by this update. Summary of changes: distribution/server/src/assemble/LICENSE.bin.txt | 20 +++- distribution/server/src/assemble/bin.xml | 16 pom.xml| 105 +++-- pulsar-broker-shaded/pom.xml | 6 +- pulsar-broker/pom.xml | 2 +- pulsar-client-admin-shaded/pom.xml | 6 +- pulsar-client-shaded/pom.xml | 4 +- pulsar-client/pom.xml | 10 ++ pulsar-common/pom.xml | 12 ++- pulsar-functions/localrun/pom.xml | 5 - pulsar-functions/utils/pom.xml | 6 -- pulsar-functions/worker-shaded/pom.xml | 34 --- pulsar-io/kinesis/pom.xml | 5 - pulsar-io/netty/pom.xml| 8 +- .../proxy/server/ProxyWithAuthorizationTest.java | 2 +- pulsar-spark/pom.xml | 5 +- tiered-storage/file-system/pom.xml | 6 ++ 17 files changed, 133 insertions(+), 119 deletions(-)
[GitHub] [pulsar] merlimat merged pull request #3613: Use individual netty-* artifacts instead of netty-all
merlimat merged pull request #3613: Use individual netty-* artifacts instead of netty-all URL: https://github.com/apache/pulsar/pull/3613 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Jennifer88huang opened a new pull request #5468: [website] Update resources.js
Jennifer88huang opened a new pull request #5468: [website] Update resources.js URL: https://github.com/apache/pulsar/pull/5468 ### Motivation Some resources are not added to the Resources page. ### Modifications Add more resources related to Apache Pulsar blogs and presentations. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[pulsar] 01/01: Update resources.js
This is an automated email from the ASF dual-hosted git repository.
hjf pushed a commit to branch Jennifer88huang-patch-2
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit d23e090f635a5ed841b41b23805e5986439f5299
Author: Jennifer Huang <47805623+jennifer88hu...@users.noreply.github.com>
AuthorDate: Fri Oct 25 23:43:01 2019 +0800
Update resources.js
---
site2/website/data/resources.js | 122
1 file changed, 122 insertions(+)
diff --git a/site2/website/data/resources.js b/site2/website/data/resources.js
index 6e9e108..90ccc45 100644
--- a/site2/website/data/resources.js
+++ b/site2/website/data/resources.js
@@ -50,6 +50,48 @@ module.exports = {
},
{
forum: 'StreamNative blog',
+forum_link: 'https://streamnative.io/',
+title: "Powering Tencent Billing Platform with Apache Pulsar",
+link:
'https://streamnative.io/blog/tech/2019-10-22-powering-tencent-billing-platform-with-apache-pulsar/'
+},
+{
+forum: 'StreamNative blog',
+forum_link: 'https://streamnative.io/',
+title: "Use Apache SkyWalking to Trace Apache Pulsar Messages",
+link:
'https://streamnative.io/blog/tech/2019-10-10-use-apache-skywalking-to-trace-apache-pulsar/'
+},
+{
+forum: 'StreamNative blog',
+forum_link: 'https://streamnative.io/',
+title: "StreamNative open sourced and contributed Apache Pulsar
Manager to ASF",
+link:
'https://streamnative.io/blog/tech/2019-09-24-streamnative-opensourced-pulsar-manager/'
+},
+{
+forum: 'StreamNative blog',
+forum_link: 'https://streamnative.io/',
+title: "Apache Pulsar Adoption Story in ActorCloud (IoT Platform)",
+link:
'https://streamnative.io/blog/tech/2019-09-09-apache-pulsar-adoption-in-actorcloud/'
+},
+{
+forum: 'StreamNative blog',
+forum_link: 'https://streamnative.io/',
+title: "Apache Pulsar at Yahoo!JAPAN",
+link:
'https://streamnative.io/blog/tech/2019-09-06-pular-at-yahoo-japan/'
+},
+{
+forum: 'StreamNative blog',
+forum_link: 'https://streamnative.io/',
+title: "Build a Priority-based Push Notification System Using Apache
Pulsar at GeTui",
+link:
'https://streamnative.io/blog/tech/2019-07-23-build-a-priority-based-push-notification-system-using-apache-pulsar-at-getui/'
+},
+{
+forum: 'StreamNative blog',
+forum_link: 'https://streamnative.io/',
+title: "Use Apache Pulsar as Streaming Table with 8 Lines of Code",
+link:
'https://streamnative.io/blog/tech/2019-08-28-use-apache-pulsar-as-streaming-table-with-8-lines-of-code/'
+},
+{
+forum: 'StreamNative blog',
forum_link: 'https://medium.com/streamnative/',
title: 'Apache Pulsar as One Unified Storage System for Real Time and
Historical Analysis',
link:
'https://medium.com/streamnative/apache-pulsar-as-one-storage-455222c59017'
@@ -202,6 +244,86 @@ module.exports = {
],
presentations: [
{
+ forum: 'Flink Forward Europe',
+ forum_link: 'https://europe-2019.flink-forward.org/',
+ presenter: 'Sijie Guo',
+ date: 'October 2019',
+ title: "Query Pulsar Streams using Apache Flink",
+ link:
'https://www.slideshare.net/streamnative/query-pulsar-streams-using-apache-flink'
+},
+{
+ forum: 'Strata Data Conference | New York',
+ forum_link: 'https://conferences.oreilly.com/strata/strata-ny',
+ presenter: 'Vincent Xie, Jia Zhai',
+ date: 'September 2019',
+ title: "How Orange Financial combat financial frauds over 50M
transactions a day using Apache Pulsar",
+ link:
'https://www.slideshare.net/streamnative/how-orange-financial-combat-financial-frauds-over-50m-transactions-a-day-using-apache-pulsar-176284080'
+},
+{
+ forum: 'ApacheCon NA 2019',
+ forum_link: 'https://www.apachecon.com/acna19/',
+ presenter: 'Xiaolong Ran',
+ date: 'September 2019',
+ title: "Serverless Event Streaming with Pulsar Functions",
+ link:
'https://www.slideshare.net/streamnative/serverless-event-streaming-with-pulsar-functions-171597848'
+},
+{
+ forum: 'ApacheCon NA 2019',
+ forum_link: 'https://www.apachecon.com/acna19/',
+ presenter: 'Penghui Li, Jia Zhai',
+ date: 'September 2019',
+ title: "Building Zhaopin's enterprise event center on Apache Pulsar",
+ link:
'https://www.slideshare.net/streamnative/building-zhaopins-enterprise-event-center-on-apache-pulsar'
+},
+{
+ forum: '',
+ forum_link: '',
+ presenter: 'Sijie Guo',
+ date: 'August 2019',
+ title: "When Apache Pulsar meets Apache Flink",
+ link:
'https://www.slideshare.net/streamnative/when-apache-pulsar-meets-apache-flink'
+},
+{
+ forum: 'Apache Pulsar Meetup | Beijing',
+ forum_link:
[pulsar] branch Jennifer88huang-patch-2 created (now d23e090)
This is an automated email from the ASF dual-hosted git repository. hjf pushed a change to branch Jennifer88huang-patch-2 in repository https://gitbox.apache.org/repos/asf/pulsar.git. at d23e090 Update resources.js This branch includes the following new commits: new d23e090 Update resources.js The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[GitHub] [pulsar] merlimat commented on issue #5464: [Issue 5387] Update Netty version for improving memory usage
merlimat commented on issue #5464: [Issue 5387] Update Netty version for improving memory usage URL: https://github.com/apache/pulsar/pull/5464#issuecomment-546400531 @equanz Great catch on correlating #5387 with the netty memory usage issue. The netty upgrade is already part of #3613 which is also breaking down netty-all into individual modules. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] merlimat commented on issue #3613: Use individual netty-* artifacts instead of netty-all
merlimat commented on issue #3613: Use individual netty-* artifacts instead of netty-all URL: https://github.com/apache/pulsar/pull/3613#issuecomment-546398958 run java8 tests This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] merlimat merged pull request #5456: [integration-tests]Enable messaging tests to integration tests.
merlimat merged pull request #5456: [integration-tests]Enable messaging tests to integration tests. URL: https://github.com/apache/pulsar/pull/5456 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[pulsar] branch master updated (7686542 -> d0fde69)
This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 7686542 [pulsar-broker] Introduce publish rate-limiting on topic
(#3986)
add d0fde69 [integration-tests]Enable messaging tests to integration
tests. (#5456)
No new revisions were added by this update.
Summary of changes:
.../tests/integration/messaging/MessagingBase.java | 59 ---
.../messaging/NonPersistentTopicMessagingTest.java | 4 +-
.../integration/messaging/TopicMessagingBase.java | 181 -
.../{pulsar-sql.xml => pulsar-messaging.xml} | 9 +-
tests/integration/src/test/resources/pulsar.xml| 1 +
5 files changed, 106 insertions(+), 148 deletions(-)
copy tests/integration/src/test/resources/{pulsar-sql.xml =>
pulsar-messaging.xml} (72%)
[GitHub] [pulsar] Jennifer88huang opened a new pull request #5467: [website] Update PMC and committer info in team.js
Jennifer88huang opened a new pull request #5467: [website] Update PMC and committer info in team.js URL: https://github.com/apache/pulsar/pull/5467 ### Motivation Some new PMC and committers are not added to the team page. ### Modifications Add new PMC and committers info in the team.js file. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[pulsar] branch Jennifer88huang-patch-1 created (now 817220a)
This is an automated email from the ASF dual-hosted git repository. hjf pushed a change to branch Jennifer88huang-patch-1 in repository https://gitbox.apache.org/repos/asf/pulsar.git. at 817220a Update team.js This branch includes the following new commits: new 817220a Update team.js The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[pulsar] 01/01: Update team.js
This is an automated email from the ASF dual-hosted git repository.
hjf pushed a commit to branch Jennifer88huang-patch-1
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 817220ad6169a64ce5f5d1ac7612fa1e026a9df9
Author: Jennifer Huang <47805623+jennifer88hu...@users.noreply.github.com>
AuthorDate: Fri Oct 25 22:53:23 2019 +0800
Update team.js
---
site2/website/data/team.js | 36 ++--
1 file changed, 34 insertions(+), 2 deletions(-)
diff --git a/site2/website/data/team.js b/site2/website/data/team.js
index 9e86106..5dfc7d7 100644
--- a/site2/website/data/team.js
+++ b/site2/website/data/team.js
@@ -1,6 +1,11 @@
module.exports = {
committers: [
{
+ name: 'Ali Ahmed',
+ apacheId: 'aahmed',
+ roles: 'Committer'
+},
+{
name: 'Boyang Jerry Peng',
apacheId: 'jerrypeng',
org: 'Streamlio',
@@ -18,11 +23,21 @@ module.exports = {
roles: 'Committer, PMC'
},
{
+ name: 'Fangbin Sun',
+ apacheId: 'sunfangbin',
+ roles: 'Committer'
+},
+{
name: 'Francis Christopher Liu',
apacheId: 'toffer',
roles: 'Committer, PMC'
},
{
+ name: 'Guangning E',
+ apacheId: 'guangning',
+ roles: 'Committer'
+},
+{
name: 'Hiroyuki Sakai',
apacheId: 'hrsakai',
org: 'Yahoo Japan Corporation',
@@ -41,9 +56,15 @@ module.exports = {
roles: 'Committer, PMC'
},
{
+ name: 'Jennifer Huang',
+ apacheId: 'hjf',
+ org: 'StreamNative',
+ roles: 'Committer'
+},
+{
name: 'Jia Zhai',
apacheId: 'zhaijia',
- org: 'Streamlio',
+ org: 'StreamNative',
roles: 'Committer, PMC'
},
{
@@ -93,6 +114,11 @@ module.exports = {
roles: 'Committer, PMC'
},
{
+ name: 'Penghui Li',
+ apacheId: 'penghui',
+ roles: 'Committer, PMC'
+},
+{
name: 'Rajan Dhabalia',
apacheId: 'rdhabalia',
org: 'Yahoo',
@@ -125,10 +151,16 @@ module.exports = {
{
name: 'Sijie Guo',
apacheId: 'sijie',
- org: 'Streamlio',
+ org: 'StreamNative',
roles: 'Committer, PMC'
},
{
+ name: 'Xiaolong Ran',
+ apacheId: 'rxl',
+ org: 'StreamNative',
+ roles: 'Committer'
+},
+{
name: 'Yuki Shiga',
apacheId: 'yushiga',
org: 'Yahoo Japan Corporation',
[GitHub] [pulsar] yittg opened a new pull request #5466: move general schema hash to common module
yittg opened a new pull request #5466: move general schema hash to common module URL: https://github.com/apache/pulsar/pull/5466 Master Issue: #5141 Move same hash functions for client and broker to common module. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] codelipenghui commented on issue #5456: [integration-tests]Enable messaging tests to integration tests.
codelipenghui commented on issue #5456: [integration-tests]Enable messaging tests to integration tests. URL: https://github.com/apache/pulsar/pull/5456#issuecomment-546298354 run java8 tests This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] equanz commented on issue #5464: [Issue 5387] Update Netty version for improving memory usage
equanz commented on issue #5464: [Issue 5387] Update Netty version for improving memory usage URL: https://github.com/apache/pulsar/pull/5464#issuecomment-546295577 Please take another look. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] wolfstudy commented on issue #5465: [Pulsar Functions] User class constructor throws exception
wolfstudy commented on issue #5465: [Pulsar Functions] User class constructor throws exception URL: https://github.com/apache/pulsar/issues/5465#issuecomment-546295197 After I delete the files in the following two paths, the instance of function can be created normally. ``` 12:00:50.493 [public/default/test-serde-xiaolong-0] INFO org.apache.pulsar.functions.instance.JavaInstanceRunnable - Load JAR: /tmp/pulsar_functions/public/default/test-serde-xiaolong/0/pulsar-util-function-api-pack-0.10.2-all.jar 12:00:50.548 [public/default/test-serde-xiaolong-0] WARN org.apache.pulsar.common.nar.NarClassLoader - /var/folders/qz/g2fh76dx5rj4q_fbkfh1q3thgn/T/pulsar-nar/pulsar-util-function-api-pack-0.10.2-all.jar-unpacked does not contain META-INF/bundled-dependencies! ``` So, I guess after a while, the contents of these two folders may be lost. ``` private final static String HASH_FILENAME = "nar-md5sum"; ``` But the `nar-md5sum` file should still exist, otherwise it will rewrite the contents of the entire folder. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] wolfstudy opened a new issue #5465: [Pulsar Functions] User class constructor throws exception
wolfstudy opened a new issue #5465: [Pulsar Functions] User class constructor throws exception URL: https://github.com/apache/pulsar/issues/5465 **Describe the bug** A few days ago, I could use this command to create a function instance correctly, ``` ./bin/pulsar-admin functions create --retain-ordering --jar /Downloads/pulsar-util-function-api-pack-0.10.2-all.jar --classname ru.alfabank.api.utils.JournalBatchParseFunction --output-serde-classname ru.alfabank.api.utils.JournalBatchSerde --inputs test-input-topic --output test-output-topic --name test-serde-name ``` but now I re-use the same command, the creation fails, the error is as follows: ``` 12:00:50.493 [public/default/test-serde-xiaolong-0] INFO org.apache.pulsar.functions.instance.JavaInstanceRunnable - Load JAR: /tmp/pulsar_functions/public/default/test-serde-xiaolong/0/pulsar-util-function-api-pack-0.10.2-all.jar 12:00:50.548 [public/default/test-serde-xiaolong-0] WARN org.apache.pulsar.common.nar.NarClassLoader - /var/folders/qz/g2fh76dx5rj4q_fbkfh1q3thgn/T/pulsar-nar/pulsar-util-function-api-pack-0.10.2-all.jar-unpacked does not contain META-INF/bundled-dependencies! 12:00:50.549 [public/default/test-serde-xiaolong-0] INFO org.apache.pulsar.functions.instance.JavaInstanceRunnable - Initialize function class loader for function test-serde-xiaolong at function cache manager 12:00:50.553 [public/default/test-serde-xiaolong-0] ERROR org.apache.pulsar.functions.instance.JavaInstanceRunnable - [public/default/test-serde-xiaolong:0] Uncaught exception in Java Instance java.lang.RuntimeException: User class constructor throws exception at org.apache.pulsar.functions.utils.Reflections.createInstance(Reflections.java:131) ~[pulsar-functions-utils.jar:2.5.0-SNAPSHOT] at org.apache.pulsar.functions.instance.JavaInstanceRunnable.setupJavaInstance(JavaInstanceRunnable.java:195) ~[pulsar-functions-instance.jar:?] at org.apache.pulsar.functions.instance.JavaInstanceRunnable.run(JavaInstanceRunnable.java:242) [pulsar-functions-instance.jar:?] at java.lang.Thread.run(Thread.java:748) [?:1.8.0_201] Caused by: java.lang.reflect.InvocationTargetException at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) ~[?:1.8.0_201] at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) ~[?:1.8.0_201] at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) ~[?:1.8.0_201] at java.lang.reflect.Constructor.newInstance(Constructor.java:423) ~[?:1.8.0_201] at org.apache.pulsar.functions.utils.Reflections.createInstance(Reflections.java:123) ~[pulsar-functions-utils.jar:2.5.0-SNAPSHOT] ... 3 more Caused by: java.lang.NoClassDefFoundError: com/ibm/as400/access/AS400Bin4 at ru.alfabank.utils.eq.journal.JournalBatchParser.(JournalBatchParser.java:24) ~[?:?] at ru.alfabank.utils.eq.journal.JournalBatchParser.defaultParser(JournalBatchParser.java:50) ~[?:?] at ru.alfabank.api.utils.JournalBatchParseFunction.(JournalBatchParseFunction.java:13) ~[?:?] at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) ~[?:1.8.0_201] at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) ~[?:1.8.0_201] at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) ~[?:1.8.0_201] at java.lang.reflect.Constructor.newInstance(Constructor.java:423) ~[?:1.8.0_201] at org.apache.pulsar.functions.utils.Reflections.createInstance(Reflections.java:123) ~[pulsar-functions-utils.jar:2.5.0-SNAPSHOT] ... 3 more ``` **To Reproduce** This problem does not seem to be stable and reproducible. **Expected behavior** Can always create functions correctly. **Screenshots**  **Desktop (please complete the following information):** - OS: Mac OS **Additional context** Add any other context about the problem here. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] equanz edited a comment on issue #5464: [Issue 5387] Update Netty version for improving memory usage
equanz edited a comment on issue #5464: [Issue 5387] Update Netty version for improving memory usage URL: https://github.com/apache/pulsar/pull/5464#issuecomment-546287537 @aahmed-se Thank you for your review. In https://github.com/netty/netty/issues/8814 issue, problem occurred patch version update. So, update version chose just fixed one. Not for critical reason such as build failure. As follow suggestion, I'll try to update to https://mvnrepository.com/artifact/io.netty/netty-all/4.1.42.Final. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] equanz commented on issue #5464: [Issue 5387] Update Netty version for improving memory usage
equanz commented on issue #5464: [Issue 5387] Update Netty version for improving memory usage URL: https://github.com/apache/pulsar/pull/5464#issuecomment-546287537 @aahmed-se Thank you for your review. In https://github.com/netty/netty/issues/8814 issue, problem was occurred patch version update. So, update version chose just fixed one. Not for critical reason such as build failure. As follow suggestion, I'll try to update to https://mvnrepository.com/artifact/io.netty/netty-all/4.1.42.Final. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] jiazhai commented on issue #5425: website page `coding_guide` return 404
jiazhai commented on issue #5425: website page `coding_guide` return 404 URL: https://github.com/apache/pulsar/issues/5425#issuecomment-546265577 @gm7y8 sure you could do it, please feel free for it. It is very appreciate for your help. This may need a check when the `coding_guide` is removed and un-linked. Besides this, I checked use a tool: https://www.drlinkcheck.com/, and it showed there are a lot of links with issue, It would be great if you could help on them.  This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] aahmed-se commented on issue #5464: [Issue 5387] Update Netty version for improving memory usage
aahmed-se commented on issue #5464: [Issue 5387] Update Netty version for improving memory usage URL: https://github.com/apache/pulsar/pull/5464#issuecomment-546255410 https://mvnrepository.com/artifact/io.netty/netty-all/4.1.42.Final is the latest release why not just update to that. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] PierreZ commented on issue #5406: [Doc] Add *authenticateMetricsEndpoint* option in administration-prox…
PierreZ commented on issue #5406: [Doc] Add *authenticateMetricsEndpoint* option in administration-prox… URL: https://github.com/apache/pulsar/pull/5406#issuecomment-546243081 Thanks :smile: This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] sijie commented on issue #5232: Upgrade dependencies for security fixes
sijie commented on issue #5232: Upgrade dependencies for security fixes URL: https://github.com/apache/pulsar/pull/5232#issuecomment-546231812 run java8 tests This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] rdhabalia merged pull request #3986: [pulsar-broker] Introduce publish rate-limiting on topic
rdhabalia merged pull request #3986: [pulsar-broker] Introduce publish rate-limiting on topic URL: https://github.com/apache/pulsar/pull/3986 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[pulsar] branch master updated (13e35f7 -> 7686542)
This is an automated email from the ASF dual-hosted git repository.
rdhabalia pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 13e35f7 [PIP-43] Support producer to send msg with different schema
(#5165)
add 7686542 [pulsar-broker] Introduce publish rate-limiting on topic
(#3986)
No new revisions were added by this update.
Summary of changes:
conf/broker.conf | 4 +
conf/standalone.conf | 5 +
.../apache/pulsar/broker/ServiceConfiguration.java | 8 +
.../pulsar/broker/admin/impl/NamespacesBase.java | 51 ++
.../apache/pulsar/broker/admin/v1/Namespaces.java | 22 +++
.../apache/pulsar/broker/admin/v2/Namespaces.java | 21 +++
.../pulsar/broker/service/AbstractTopic.java | 98 ++-
.../pulsar/broker/service/BrokerService.java | 49 ++
.../org/apache/pulsar/broker/service/Producer.java | 11 +-
.../pulsar/broker/service/PublishRateLimiter.java | 163 ++
.../broker/service/PulsarChannelInitializer.java | 7 +
.../apache/pulsar/broker/service/ServerCnx.java| 31 +++-
.../org/apache/pulsar/broker/service/Topic.java| 8 +
.../service/nonpersistent/NonPersistentTopic.java | 16 +-
.../broker/service/persistent/PersistentTopic.java | 48 +++---
.../client/impl/MessagePublishThrottlingTest.java | 186 +
.../org/apache/pulsar/client/admin/Namespaces.java | 22 +++
.../client/admin/internal/NamespacesImpl.java | 25 +++
.../pulsar/admin/cli/PulsarAdminToolTest.java | 7 +
.../org/apache/pulsar/admin/cli/CmdNamespaces.java | 37
.../pulsar/common/policies/data/Policies.java | 5 +-
.../data/{SubscribeRate.java => PublishRate.java} | 37 ++--
22 files changed, 799 insertions(+), 62 deletions(-)
create mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PublishRateLimiter.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/MessagePublishThrottlingTest.java
copy
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/{SubscribeRate.java
=> PublishRate.java} (50%)
[GitHub] [pulsar] sijie commented on issue #5148: Validate topic name before creating partition/non partition topic via admin cli.
sijie commented on issue #5148: Validate topic name before creating partition/non partition topic via admin cli. URL: https://github.com/apache/pulsar/pull/5148#issuecomment-546230741 @jiazhai PTAL This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[pulsar] branch master updated (0281e83 -> 13e35f7)
This is an automated email from the ASF dual-hosted git repository. sijie pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git. from 0281e83 Documentation for delayed message delivery(#5293) add 13e35f7 [PIP-43] Support producer to send msg with different schema (#5165) No new revisions were added by this update. Summary of changes: .../apache/pulsar/broker/service/ServerCnx.java| 72 +- .../apache/pulsar/client/api/SimpleSchemaTest.java | 220 +- .../apache/pulsar/client/api/ProducerBuilder.java | 15 + .../java/org/apache/pulsar/client/api/Schema.java | 12 + .../client/internal/DefaultImplementation.java |7 + pulsar-client-cpp/lib/Commands.cc |4 + .../client/impl/BatchMessageContainerBase.java |9 + .../client/impl/BatchMessageContainerImpl.java | 13 + .../client/impl/BatchMessageKeyBasedContainer.java | 15 + .../org/apache/pulsar/client/impl/ClientCnx.java | 43 + .../apache/pulsar/client/impl/HandlerState.java| 10 +- .../org/apache/pulsar/client/impl/MessageImpl.java | 19 + .../apache/pulsar/client/impl/ProducerBase.java| 20 + .../pulsar/client/impl/ProducerBuilderImpl.java|8 +- .../apache/pulsar/client/impl/ProducerImpl.java| 270 +- .../pulsar/client/impl/PulsarClientImpl.java |3 + .../impl/conf/ProducerConfigurationData.java |2 + .../client/impl/schema/AutoProduceBytesSchema.java | 17 +- .../pulsar/client/impl/schema/SchemaHash.java | 39 +- .../apache/pulsar/common/api/proto/PulsarApi.java | 2643 +++- .../apache/pulsar/common/protocol/Commands.java| 44 + .../pulsar/common/protocol/PulsarDecoder.java | 22 + pulsar-common/src/main/proto/PulsarApi.proto | 21 + 23 files changed, 2718 insertions(+), 810 deletions(-) copy pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/SerDeSchema.java => pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/SchemaHash.java (55%)
[GitHub] [pulsar] sijie merged pull request #5165: [PIP-43] Support producer to send msg with different schema
sijie merged pull request #5165: [PIP-43] Support producer to send msg with different schema URL: https://github.com/apache/pulsar/pull/5165 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[pulsar] branch master updated (6f113f7 -> 0281e83)
This is an automated email from the ASF dual-hosted git repository. penghui pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git. from 6f113f7 [Cpp] Fixed negative ack tracker constructor sequence (#5453) add 0281e83 Documentation for delayed message delivery(#5293) No new revisions were added by this update. Summary of changes: site2/docs/assets/message_delay.png | Bin 0 -> 30906 bytes site2/docs/concepts-messaging.md| 30 ++ 2 files changed, 30 insertions(+) create mode 100644 site2/docs/assets/message_delay.png
[GitHub] [pulsar] codelipenghui merged pull request #5293: [ISSUE #4675][docs] Add *Delayed Message Delivery*
codelipenghui merged pull request #5293: [ISSUE #4675][docs] Add *Delayed Message Delivery* URL: https://github.com/apache/pulsar/pull/5293 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] sijie commented on issue #5165: [PIP-43] Support producer to send msg with different schema
sijie commented on issue #5165: [PIP-43] Support producer to send msg with different schema URL: https://github.com/apache/pulsar/pull/5165#issuecomment-546230233 @yittg sorry for late response. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] sijie commented on a change in pull request #5165: [PIP-43] Support producer to send msg with different schema
sijie commented on a change in pull request #5165: [PIP-43] Support producer to
send msg with different schema
URL: https://github.com/apache/pulsar/pull/5165#discussion_r338911342
##
File path:
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerBase.java
##
@@ -73,6 +81,14 @@ public MessageId send(T message) throws
PulsarClientException {
return new TypedMessageBuilderImpl<>(this, schema);
}
+// TODO: same parameterized type `T` with producer for the moment,
Review comment:
a master issue with a checklist will be good enough.
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
With regards,
Apache Git Services
[GitHub] [pulsar] aahmed-se commented on issue #5455: Update test docker scripts and library
aahmed-se commented on issue #5455: Update test docker scripts and library URL: https://github.com/apache/pulsar/pull/5455#issuecomment-546227710 run integration tests This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[pulsar] branch master updated (bf9a901 -> 6f113f7)
This is an automated email from the ASF dual-hosted git repository. aahmed pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git. from bf9a901 [pulsar-client] Fix message corruption on OOM for batch messages (#5443) add 6f113f7 [Cpp] Fixed negative ack tracker constructor sequence (#5453) No new revisions were added by this update. Summary of changes: .../include/pulsar/ConsumerConfiguration.h | 6 ++ pulsar-client-cpp/lib/ConsumerConfiguration.cc | 10 -- pulsar-client-cpp/lib/ConsumerConfigurationImpl.h | 3 ++- pulsar-client-cpp/lib/NegativeAcksTracker.cc | 18 -- pulsar-client-cpp/lib/NegativeAcksTracker.h| 2 -- pulsar-client-cpp/lib/PartitionedConsumerImpl.cc | 2 +- pulsar-client-cpp/tests/BasicEndToEndTest.cc | 4 +++- 7 files changed, 32 insertions(+), 13 deletions(-)
[GitHub] [pulsar] aahmed-se merged pull request #5453: [Cpp] Fixed negative ack tracker constructor sequence
aahmed-se merged pull request #5453: [Cpp] Fixed negative ack tracker constructor sequence URL: https://github.com/apache/pulsar/pull/5453 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] sijie commented on issue #5332: [docs] Fix broken link to k8s YAML definitions
sijie commented on issue #5332: [docs] Fix broken link to k8s YAML definitions URL: https://github.com/apache/pulsar/pull/5332#issuecomment-546226185 run integration tests This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] sijie commented on issue #5328: Increase the retries count for PulsarFunctionStateTest
sijie commented on issue #5328: Increase the retries count for PulsarFunctionStateTest URL: https://github.com/apache/pulsar/pull/5328#issuecomment-546222308 run java8 tests run integration tests This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[pulsar-manager] branch master updated: Delete codeowner (#202)
This is an automated email from the ASF dual-hosted git repository. sijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/pulsar-manager.git The following commit(s) were added to refs/heads/master by this push: new 83c59fb Delete codeowner (#202) 83c59fb is described below commit 83c59fb6f634328857f8e08cbecaa1bc83f8bbcc Author: tuteng AuthorDate: Fri Oct 25 14:33:41 2019 +0800 Delete codeowner (#202) --- .github/CODEOWNERS | 1 - 1 file changed, 1 deletion(-) diff --git a/.github/CODEOWNERS b/.github/CODEOWNERS deleted file mode 100644 index 05d97c7..000 --- a/.github/CODEOWNERS +++ /dev/null @@ -1 +0,0 @@ -* @sijie @tuteng
[GitHub] [pulsar] equanz opened a new pull request #5464: [Issue 5387] Update Netty version for improving memory usage
equanz opened a new pull request #5464: [Issue 5387] Update Netty version for improving memory usage URL: https://github.com/apache/pulsar/pull/5464 ### Motivation Want to improve memory usage to be able to create many PulsarClients and Consumers. (Fix https://github.com/apache/pulsar/issues/5387) ### Modifications Update Netty version to `4.1.34.Final` and netty-tcnative-boringssl-static version to `2.0.22.Final`. In Netty community, memory increase issue(https://github.com/netty/netty/issues/8814) was reported (at `4.1.32.Final`). It was fixed by https://github.com/netty/netty/pull/8825 (at `4.1.34.Final`). When I apply `4.1.34.Final` then memory usage was decreased correctly. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
