[GitHub] [pulsar] 315157973 commented on pull request #9538: Fix reading metrics will always get stuck in some cases

2021-02-08 Thread GitBox
315157973 commented on pull request #9538: URL: https://github.com/apache/pulsar/pull/9538#issuecomment-775746990 > This fix is okay for me > > Be can we also fix the NPE ? > do you have a stacktrace ? > > if we do not fix the NPE now we will forget about it > a NullPoint

[GitHub] [pulsar] wolfstudy commented on a change in pull request #9481: Allow Pulsar IO Sources to push GenericRecord instances encoded with AVRO

2021-02-08 Thread GitBox
wolfstudy commented on a change in pull request #9481: URL: https://github.com/apache/pulsar/pull/9481#discussion_r572664845 ## File path: tests/docker-images/java-test-functions/src/main/java/org/apache/pulsar/tests/integration/io/TestGenericRecordSource.java ## @@ -0,0 +1,10

[GitHub] [pulsar] anvinjain opened a new issue #9540: Pulsar client does not shutdown when messages are being produced to dead letter topic

2021-02-08 Thread GitBox
anvinjain opened a new issue #9540: URL: https://github.com/apache/pulsar/issues/9540 **Describe the bug** Pulsar client does not shutdown (deadlock occurs internally) when DLQ is configured in the consumer and failures are being produced to DLQ topic. This happens intermittently. I hav

[GitHub] [pulsar] freeznet commented on a change in pull request #9515: Initial checkin of PublishMessage/Publish

2021-02-08 Thread GitBox
freeznet commented on a change in pull request #9515: URL: https://github.com/apache/pulsar/pull/9515#discussion_r572656563 ## File path: pulsar-function-go/pf/context.go ## @@ -153,8 +156,9 @@ func (c *FunctionContext) GetUserConfMap() map[string]interface{} { } // NewOut

[GitHub] [pulsar] lhotari commented on a change in pull request #9393: Fix testBrokerSelectionForAntiAffinityGroup by increasing OverloadedThreshold

2021-02-08 Thread GitBox
lhotari commented on a change in pull request #9393: URL: https://github.com/apache/pulsar/pull/9393#discussion_r572656988 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/LinuxBrokerHostUsageImpl.java ## @@ -75,18 +75,17 @@ public LinuxBroke

[GitHub] [pulsar] lhotari commented on a change in pull request #9393: Fix testBrokerSelectionForAntiAffinityGroup by increasing OverloadedThreshold

2021-02-08 Thread GitBox
lhotari commented on a change in pull request #9393: URL: https://github.com/apache/pulsar/pull/9393#discussion_r572656526 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/LinuxBrokerHostUsageImpl.java ## @@ -75,18 +75,17 @@ public LinuxBroke

[GitHub] [pulsar] michaeljmarshall commented on a change in pull request #9393: Fix testBrokerSelectionForAntiAffinityGroup by increasing OverloadedThreshold

2021-02-08 Thread GitBox
michaeljmarshall commented on a change in pull request #9393: URL: https://github.com/apache/pulsar/pull/9393#discussion_r572653344 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/LinuxBrokerHostUsageImpl.java ## @@ -75,18 +75,17 @@ public L

[GitHub] [pulsar] lhotari edited a comment on pull request #9393: Fix testBrokerSelectionForAntiAffinityGroup by increasing OverloadedThreshold

2021-02-08 Thread GitBox
lhotari edited a comment on pull request #9393: URL: https://github.com/apache/pulsar/pull/9393#issuecomment-775735510 > Let me know if you found anything regarding this issue. My most recent commit should definitely add some stability to the `LinuxBrokerHostUsageImpl` by not calling it at

[GitHub] [pulsar] lhotari commented on pull request #9393: Fix testBrokerSelectionForAntiAffinityGroup by increasing OverloadedThreshold

2021-02-08 Thread GitBox
lhotari commented on pull request #9393: URL: https://github.com/apache/pulsar/pull/9393#issuecomment-775735510 > Let me know if you found anything regarding this issue. My most recent commit should definitely add some stability to the `LinuxBrokerHostUsageImpl` by not calling it at nearly

[GitHub] [pulsar] eolivelli opened a new pull request #9539: CI Builds for WebSite and MacOs write too much log (missing -B option)

2021-02-08 Thread GitBox
eolivelli opened a new pull request #9539: URL: https://github.com/apache/pulsar/pull/9539 The CI jobs for the WebSite and for MacOs are missing the -B option and thus Maven is printing too much logs. ![Screenshot 2021-02-09 at 08 32 02](https://user-images.githubusercontent.com/94

[GitHub] [pulsar] 315157973 opened a new pull request #9538: Fix treading metrics will always get stuck in some cases

2021-02-08 Thread GitBox
315157973 opened a new pull request #9538: URL: https://github.com/apache/pulsar/pull/9538 ### Motivation When `javaInstanceRunnable` has not been initialized yet, and client calls `FunctionsStatsGenerator#generate`, the NPE will be triggered. Since only IOException is captured here,

[pulsar] branch master updated (bd247a9 -> 40a1621)

2021-02-08 Thread zhaijia
This is an automated email from the ASF dual-hosted git repository. zhaijia pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git. from bd247a9 Adding Pandio as a user of Pulsar (#9534) add 40a1621 Remove usage of diff-only action with paths-ign

[GitHub] [pulsar] jiazhai closed issue #9526: CI is not running tests

2021-02-08 Thread GitBox
jiazhai closed issue #9526: URL: https://github.com/apache/pulsar/issues/9526 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 sp

[GitHub] [pulsar] jiazhai merged pull request #9527: [CI] Remove usage of diff-only action with paths-ignore

2021-02-08 Thread GitBox
jiazhai merged pull request #9527: URL: https://github.com/apache/pulsar/pull/9527 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 t

[GitHub] [pulsar] michaeljmarshall commented on pull request #9393: Fix testBrokerSelectionForAntiAffinityGroup by increasing OverloadedThreshold

2021-02-08 Thread GitBox
michaeljmarshall commented on pull request #9393: URL: https://github.com/apache/pulsar/pull/9393#issuecomment-775720402 > One detail that immediately caught my eye in LinuxBrokerHostUsageImpl is the usage of System.currentTimeMillis(). Replacing that with System.nanoTime() could be helpfu

[GitHub] [pulsar] 315157973 opened a new pull request #9537: Fix get-message-by-id throwing NPE when message is null

2021-02-08 Thread GitBox
315157973 opened a new pull request #9537: URL: https://github.com/apache/pulsar/pull/9537 Fixes #9518 ### Modifications Add friendly reminder tips for command This is an automated message from the Apache Git Servic

[GitHub] [pulsar] lhotari commented on a change in pull request #9393: Fix testBrokerSelectionForAntiAffinityGroup by increasing OverloadedThreshold

2021-02-08 Thread GitBox
lhotari commented on a change in pull request #9393: URL: https://github.com/apache/pulsar/pull/9393#discussion_r572635313 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/LinuxBrokerHostUsageImpl.java ## @@ -75,18 +75,17 @@ public LinuxBroke

[GitHub] [pulsar] MarvinCai commented on a change in pull request #9514: Expire message by position.

2021-02-08 Thread GitBox
MarvinCai commented on a change in pull request #9514: URL: https://github.com/apache/pulsar/pull/9514#discussion_r572632575 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentMessageExpiryMonitor.java ## @@ -94,6 +95,32 @@ public v

[GitHub] [pulsar] michaeljmarshall commented on a change in pull request #9393: Fix testBrokerSelectionForAntiAffinityGroup by increasing OverloadedThreshold

2021-02-08 Thread GitBox
michaeljmarshall commented on a change in pull request #9393: URL: https://github.com/apache/pulsar/pull/9393#discussion_r572630364 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/LinuxBrokerHostUsageImpl.java ## @@ -75,18 +75,17 @@ public L

[GitHub] [pulsar] MarvinCai commented on a change in pull request #9514: Expire message by position.

2021-02-08 Thread GitBox
MarvinCai commented on a change in pull request #9514: URL: https://github.com/apache/pulsar/pull/9514#discussion_r572629751 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/PersistentTopics.java ## @@ -462,7 +462,47 @@ public void expireTopicMessage

[GitHub] [pulsar] michaeljmarshall commented on a change in pull request #9393: Fix testBrokerSelectionForAntiAffinityGroup by increasing OverloadedThreshold

2021-02-08 Thread GitBox
michaeljmarshall commented on a change in pull request #9393: URL: https://github.com/apache/pulsar/pull/9393#discussion_r572629004 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/LinuxBrokerHostUsageImpl.java ## @@ -75,18 +75,17 @@ public L

[GitHub] [pulsar] MarvinCai commented on a change in pull request #9514: Expire message by position.

2021-02-08 Thread GitBox
MarvinCai commented on a change in pull request #9514: URL: https://github.com/apache/pulsar/pull/9514#discussion_r572628292 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java ## @@ -3017,6 +3026,82 @@ private void internal

[GitHub] [pulsar] congbobo184 removed a comment on pull request #9490: [Transaction] Transaction buffer snapshot implementation.

2021-02-08 Thread GitBox
congbobo184 removed a comment on pull request #9490: URL: https://github.com/apache/pulsar/pull/9490#issuecomment-774675011 This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [pulsar] MarvinCai commented on a change in pull request #9514: Expire message by position.

2021-02-08 Thread GitBox
MarvinCai commented on a change in pull request #9514: URL: https://github.com/apache/pulsar/pull/9514#discussion_r572617093 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java ## @@ -3017,6 +3026,82 @@ private void internal

[GitHub] [pulsar] MarvinCai commented on a change in pull request #9514: Expire message by position.

2021-02-08 Thread GitBox
MarvinCai commented on a change in pull request #9514: URL: https://github.com/apache/pulsar/pull/9514#discussion_r572615999 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java ## @@ -3017,6 +3026,82 @@ private void internal

[GitHub] [pulsar] congbobo184 commented on pull request #9490: [Transaction] Transaction buffer snapshot implementation.

2021-02-08 Thread GitBox
congbobo184 commented on pull request #9490: URL: https://github.com/apache/pulsar/pull/9490#issuecomment-775693354 /pulsarbot run-failure-checks This is an automated message from the Apache Git Service. To respond to the mes

[GitHub] [pulsar] wangjialing218 commented on pull request #9536: [Build] build with unix lineEnding in Windows

2021-02-08 Thread GitBox
wangjialing218 commented on pull request #9536: URL: https://github.com/apache/pulsar/pull/9536#issuecomment-775685268 /pulsarbot run-failure-checks This is an automated message from the Apache Git Service. To respond to the

[GitHub] [pulsar-client-go] wolfstudy opened a new pull request #463: Update 0.4.0 changelog file

2021-02-08 Thread GitBox
wolfstudy opened a new pull request #463: URL: https://github.com/apache/pulsar-client-go/pull/463 Signed-off-by: xiaolongran Update 0.4.0 changelog file This is an automated message from the Apache Git Service. T

[GitHub] [pulsar-client-go] wolfstudy commented on a change in pull request #402: Add VPC(Virtual Private Cloud)support for go sdk

2021-02-08 Thread GitBox
wolfstudy commented on a change in pull request #402: URL: https://github.com/apache/pulsar-client-go/pull/402#discussion_r572599417 ## File path: pulsar/internal/lookup_service_test.go ## @@ -117,9 +117,10 @@ func TestLookupSuccess(t *testing.T) { expectedReq

svn commit: r45937 - in /dev/pulsar/pulsar-client-go-0.4.0-candidate-1: ./ apache-pulsar-client-go-0.4.0-src.tar.gz apache-pulsar-client-go-0.4.0-src.tar.gz.asc apache-pulsar-client-go-0.4.0-src.tar.g

2021-02-08 Thread rxl
Author: rxl Date: Tue Feb 9 04:35:14 2021 New Revision: 45937 Log: Staging artifacts and signature for Pulsar Client Go release 0.4.0-candidate-1 Added: dev/pulsar/pulsar-client-go-0.4.0-candidate-1/ dev/pulsar/pulsar-client-go-0.4.0-candidate-1/apache-pulsar-client-go-0.4.0-src.tar.gz

[pulsar-client-go] annotated tag v0.4.0-candidate-1 updated (25f3075 -> 6bc2f64)

2021-02-08 Thread rxl
This is an automated email from the ASF dual-hosted git repository. rxl pushed a change to annotated tag v0.4.0-candidate-1 in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git. *** WARNING: tag v0.4.0-candidate-1 was modified! *** from 25f3075 (commit) to 6bc2f64

[GitHub] [pulsar] YanshuoH commented on issue #9491: failed to delete topic with HTTP 500 Internal Server Error

2021-02-08 Thread GitBox
YanshuoH commented on issue #9491: URL: https://github.com/apache/pulsar/issues/9491#issuecomment-775653246 @codelipenghui And do we have an ETA for the 2.6.4 release? Thanks. This is an automated message from the Apache Git

[pulsar-client-go] branch branch-0.4.0 created (now 25f3075)

2021-02-08 Thread rxl
This is an automated email from the ASF dual-hosted git repository. rxl pushed a change to branch branch-0.4.0 in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git. at 25f3075 Fix unsubscribe blocked when consumer is closing or has closed (#457) No new revisions were a

[GitHub] [pulsar] freeznet commented on pull request #9513: [Go Functions] Cache producers with sync.Map

2021-02-08 Thread GitBox
freeznet commented on pull request #9513: URL: https://github.com/apache/pulsar/pull/9513#issuecomment-775649448 Just as you said, all send failures are fatal, but this is limited within `goInstance`’s `producer`. For user who get `producer` from `context.outputMessage()`, it might differe

[GitHub] [pulsar] codelipenghui commented on issue #9477: Force delete subscription is not working

2021-02-08 Thread GitBox
codelipenghui commented on issue #9477: URL: https://github.com/apache/pulsar/issues/9477#issuecomment-775641098 @munir131 Have you closed all the consumers under the subscription? By default, the subscription will be created automatically when the active consumer reconnects to the broker

[GitHub] [pulsar] codelipenghui commented on issue #9478: Delete the old data of the same key in topic, so as to clean up the disk space 【topic compaction enhance】

2021-02-08 Thread GitBox
codelipenghui commented on issue #9478: URL: https://github.com/apache/pulsar/issues/9478#issuecomment-775640149 @jack-tristan Yes, you can use topic compaction to achieve your requirement. This is an automated message from t

[GitHub] [pulsar] codelipenghui edited a comment on issue #9483: Support for nested types in pulsar.schema.Record

2021-02-08 Thread GitBox
codelipenghui edited a comment on issue #9483: URL: https://github.com/apache/pulsar/issues/9483#issuecomment-775638143 @congbobo184 Could you please help check if the Java client support nested type? @BewareMyPower Please help take a look at this issue, seems the problem occurs on the

[GitHub] [pulsar] codelipenghui commented on issue #9483: Support for nested types in pulsar.schema.Record

2021-02-08 Thread GitBox
codelipenghui commented on issue #9483: URL: https://github.com/apache/pulsar/issues/9483#issuecomment-775638143 @congbobo184 Could you please help take a look at this issue? This is an automated message from the Apache Git S

[GitHub] [pulsar-client-go] yuanweikang2020 commented on issue #462: goroutine leak

2021-02-08 Thread GitBox
yuanweikang2020 commented on issue #462: URL: https://github.com/apache/pulsar-client-go/issues/462#issuecomment-775637212 > thanks @yuanweikang2020 for this issue, can you provide more context how to reproduce or verify this issue? when pulsar is failure, pulsar client reconnect

[GitHub] [pulsar] codelipenghui commented on issue #9491: failed to delete topic with HTTP 500 Internal Server Error

2021-02-08 Thread GitBox
codelipenghui commented on issue #9491: URL: https://github.com/apache/pulsar/issues/9491#issuecomment-775636218 @lichuan6 I have marked #7356 for the 2.6.4 release. We might release a minor version 2.6.4 for fixing some issues that 2.6.3 have.

[GitHub] [pulsar] wangjialing218 opened a new pull request #9536: [Build] build with unix lineEnding in Windows

2021-02-08 Thread GitBox
wangjialing218 opened a new pull request #9536: URL: https://github.com/apache/pulsar/pull/9536 ### Motivation When build pulsar in Windows using "mvn clean install -DskipTests" and upload the tar.gz file in /distribution/server/target to Linux server, the package can not be executed be

[GitHub] [pulsar] congbobo184 commented on pull request #9401: [Broker] Support enable subscription types.

2021-02-08 Thread GitBox
congbobo184 commented on pull request #9401: URL: https://github.com/apache/pulsar/pull/9401#issuecomment-775633359 /pulsarbot run-failure-checks This is an automated message from the Apache Git Service. To respond to the mes

[GitHub] [pulsar-client-go] wolfstudy commented on pull request #402: Add VPC(Virtual Private Cloud)support for go sdk

2021-02-08 Thread GitBox
wolfstudy commented on pull request #402: URL: https://github.com/apache/pulsar-client-go/pull/402#issuecomment-775627473 @xixiss Move this change to 0.5.0 This is an automated message from the Apache Git Service. To respond

[GitHub] [pulsar-client-go] freeznet commented on issue #462: goroutine leak

2021-02-08 Thread GitBox
freeznet commented on issue #462: URL: https://github.com/apache/pulsar-client-go/issues/462#issuecomment-775620416 thanks @yuanweikang2020 for this issue, can you provide more context how to reproduce or verify this issue? ---

[GitHub] [pulsar-client-go] wolfstudy commented on pull request #433: Issue #432 propagate disableForceTopicCreation

2021-02-08 Thread GitBox
wolfstudy commented on pull request #433: URL: https://github.com/apache/pulsar-client-go/pull/433#issuecomment-775619352 @flowchartsman Thanks your work for this, the change LGTM +1, and can you merge master code and fix test case? Please make sure the CI is ok. -

[GitHub] [pulsar-client-go] wolfstudy commented on pull request #454: Make backoff policy configurable and use uniformly

2021-02-08 Thread GitBox
wolfstudy commented on pull request #454: URL: https://github.com/apache/pulsar-client-go/pull/454#issuecomment-775617205 > @merlimat > If this features is intentionally restrained to avoid the risk of misconfiguration, it's ok to close this PR, I'll do stricter timeout checking in my a

[pulsar-client-go] branch master updated: Fix unsubscribe blocked when consumer is closing or has closed (#457)

2021-02-08 Thread rxl
This is an automated email from the ASF dual-hosted git repository. rxl pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git The following commit(s) were added to refs/heads/master by this push: new 25f3075 Fix unsubscribe blocked when con

[GitHub] [pulsar-client-go] wolfstudy merged pull request #457: Fix unsubscribe blocked when consumer is closing or has closed

2021-02-08 Thread GitBox
wolfstudy merged pull request #457: URL: https://github.com/apache/pulsar-client-go/pull/457 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

[GitHub] [pulsar] gaoran10 commented on pull request #9532: [Broker] Async read entries with max size bytes

2021-02-08 Thread GitBox
gaoran10 commented on pull request #9532: URL: https://github.com/apache/pulsar/pull/9532#issuecomment-775614960 /pulsarbot run-failure-checks This is an automated message from the Apache Git Service. To respond to the messag

[pulsar-client-go] branch master updated: asynchronized send timeout checking (#460)

2021-02-08 Thread rxl
This is an automated email from the ASF dual-hosted git repository. rxl pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git The following commit(s) were added to refs/heads/master by this push: new 0e76dc2 asynchronized send timeout check

[GitHub] [pulsar-client-go] wolfstudy closed issue #458: MaxReconnectToBroker caused infinite sendTimeout failure even after broker recovered

2021-02-08 Thread GitBox
wolfstudy closed issue #458: URL: https://github.com/apache/pulsar-client-go/issues/458 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

[GitHub] [pulsar-client-go] wolfstudy merged pull request #460: asynchronized send timeout checking without pending queue lock

2021-02-08 Thread GitBox
wolfstudy merged pull request #460: URL: https://github.com/apache/pulsar-client-go/pull/460 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

[GitHub] [pulsar] limingnihao commented on issue #9535: Add metrics for the cursor ack state

2021-02-08 Thread GitBox
limingnihao commented on issue #9535: URL: https://github.com/apache/pulsar/issues/9535#issuecomment-775614404 I will fix this issue, please assign it to me. This is an automated message from the Apache Git Service. To respon

[GitHub] [pulsar] wolfstudy commented on pull request #9529: [Issue9364] Fix the metric data of msgDelayed for partitioned topics is not aggregated

2021-02-08 Thread GitBox
wolfstudy commented on pull request #9529: URL: https://github.com/apache/pulsar/pull/9529#issuecomment-775611812 Thanks @limingnihao work for this. This is an automated message from the Apache Git Service. To respond to the

[pulsar] branch master updated (b5e153a -> bd247a9)

2021-02-08 Thread mmerli
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 b5e153a [Doc] Add descriptions for function runtime and context (#9516) add bd247a9 Adding Pandio as a user o

[GitHub] [pulsar] merlimat merged pull request #9534: [docs] Adding Pandio as a user of Pulsar

2021-02-08 Thread GitBox
merlimat merged pull request #9534: URL: https://github.com/apache/pulsar/pull/9534 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

[GitHub] [pulsar] saosir removed a comment on pull request #9134: Fix UnAckedMessageTracker timeout send redelivery messages

2021-02-08 Thread GitBox
saosir removed a comment on pull request #9134: URL: https://github.com/apache/pulsar/pull/9134#issuecomment-774808767 /pulsarbot run-failure-checks This is an automated message from the Apache Git Service. To respond

[pulsar-test-infra] branch master updated: Set 'changed_only' to 'no' if commits cannot be found in diff-only action (#16)

2021-02-08 Thread zhaijia
This is an automated email from the ASF dual-hosted git repository. zhaijia pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/pulsar-test-infra.git The following commit(s) were added to refs/heads/master by this push: new a3014b8 Set 'changed_only' to 'no'

[GitHub] [pulsar] tuhaihe commented on pull request #9534: [docs] Adding Pandio as a user of Pulsar

2021-02-08 Thread GitBox
tuhaihe commented on pull request #9534: URL: https://github.com/apache/pulsar/pull/9534#issuecomment-775599141 @odmarkj Great! thanks for your PR! This is an automated message from the Apache Git Service. To respond to the

[pulsar] branch master updated (1c0d264 -> b5e153a)

2021-02-08 Thread liuyu
This is an automated email from the ASF dual-hosted git repository. liuyu pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git. from 1c0d264 [Doc] Add descriptions for numListenerThreads (#9525) add b5e153a [Doc] Add descriptions for function r

[GitHub] [pulsar] Anonymitaet merged pull request #9516: [Doc] Add descriptions for function runtime and context

2021-02-08 Thread GitBox
Anonymitaet merged pull request #9516: URL: https://github.com/apache/pulsar/pull/9516 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

[GitHub] [pulsar] jiazhai commented on pull request #9533: [C++] Removed usages of boost::regex

2021-02-08 Thread GitBox
jiazhai commented on pull request #9533: URL: https://github.com/apache/pulsar/pull/9533#issuecomment-775597246 @BewareMyPower Would you please also help review this PR? This is an automated message from the Apache Git Servic

[pulsar] branch master updated (c7f19f57 -> 1c0d264)

2021-02-08 Thread liuyu
This is an automated email from the ASF dual-hosted git repository. liuyu pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git. from c7f19f57 [Issue9364] Fix the metric data of msgDelayed for partitioned topics is not aggregated (#9529) add 1c0d

[GitHub] [pulsar] Anonymitaet merged pull request #9525: [Doc] Add descriptions for numListenerThreads

2021-02-08 Thread GitBox
Anonymitaet merged pull request #9525: URL: https://github.com/apache/pulsar/pull/9525 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

[GitHub] [pulsar] Anonymitaet closed issue #9423: Does Java client support multiple listener threads in Pulsar

2021-02-08 Thread GitBox
Anonymitaet closed issue #9423: URL: https://github.com/apache/pulsar/issues/9423 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 th

[pulsar] branch master updated (c27f7a3 -> c7f19f57)

2021-02-08 Thread penghui
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 c27f7a3 Optimize built-in source/sink startup Part 2 (#9500) add c7f19f57 [Issue9364] Fix the metric data of m

[GitHub] [pulsar] codelipenghui merged pull request #9529: [Issue9364] Fix the metric data of msgDelayed for partitioned topics is not aggregated

2021-02-08 Thread GitBox
codelipenghui merged pull request #9529: URL: https://github.com/apache/pulsar/pull/9529 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 g

[GitHub] [pulsar] codelipenghui closed issue #9364: [Deliver Message] The metric data of msgDelayed for partitioned topics is not aggregated

2021-02-08 Thread GitBox
codelipenghui closed issue #9364: URL: https://github.com/apache/pulsar/issues/9364 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

[GitHub] [pulsar] codelipenghui opened a new issue #9535: Add metrics for the cursor ack state

2021-02-08 Thread GitBox
codelipenghui opened a new issue #9535: URL: https://github.com/apache/pulsar/issues/9535 **Is your enhancement request related to a problem? Please describe.** The acknowledgment state is persistent to the Ledger or Zookeeper(can't persistent to the Ledger). But currently, we don't

[GitHub] [pulsar] freeznet commented on pull request #9377: [fix #9315] Add downloadDirectory support to function k8s runtime

2021-02-08 Thread GitBox
freeznet commented on pull request #9377: URL: https://github.com/apache/pulsar/pull/9377#issuecomment-775569935 /pulsarbot run-failure-checks This is an automated message from the Apache Git Service. To respond to the messag

[GitHub] [pulsar] MarvinCai commented on pull request #9381: Expose ReachedEndOfTopic in Reader/Consumer API

2021-02-08 Thread GitBox
MarvinCai commented on pull request #9381: URL: https://github.com/apache/pulsar/pull/9381#issuecomment-775562536 /pulsarbot run-failure-checks This is an automated message from the Apache Git Service. To respond to the messa

[GitHub] [pulsar] MarvinCai commented on a change in pull request #9524: [Doc] Update pulsar-client cli doc with newer options.

2021-02-08 Thread GitBox
MarvinCai commented on a change in pull request #9524: URL: https://github.com/apache/pulsar/pull/9524#discussion_r572453421 ## File path: site2/docs/reference-cli-tools.md ## @@ -315,6 +315,10 @@ Options |`-m`, `--messages`|Comma-separated string of messages to send; either -

[GitHub] [pulsar] MarvinCai commented on a change in pull request #9524: [Doc] Update pulsar-client cli doc with newer options.

2021-02-08 Thread GitBox
MarvinCai commented on a change in pull request #9524: URL: https://github.com/apache/pulsar/pull/9524#discussion_r572453421 ## File path: site2/docs/reference-cli-tools.md ## @@ -315,6 +315,10 @@ Options |`-m`, `--messages`|Comma-separated string of messages to send; either -

[GitHub] [pulsar] MarvinCai commented on a change in pull request #9524: [Doc] Update pulsar-client cli doc with newer options.

2021-02-08 Thread GitBox
MarvinCai commented on a change in pull request #9524: URL: https://github.com/apache/pulsar/pull/9524#discussion_r572451483 ## File path: site2/docs/reference-cli-tools.md ## @@ -335,7 +339,10 @@ Options |`-s`, `--subscription-name`|Subscription name|| |`-t`, `--subscription

[GitHub] [pulsar] MarvinCai commented on pull request #9524: [Doc] Update pulsar-client cli doc with newer options.

2021-02-08 Thread GitBox
MarvinCai commented on pull request #9524: URL: https://github.com/apache/pulsar/pull/9524#issuecomment-775527166 > @MarvinCai thank you very much for adding the content. Does it apply only to 2.7.1 and 2.8.0? We haven't update the doc for this client cli for a while I think, I'm not

[GitHub] [pulsar] odmarkj commented on issue #8772: Python pulsar-client schema support for pulsar function's output

2021-02-08 Thread GitBox
odmarkj commented on issue #8772: URL: https://github.com/apache/pulsar/issues/8772#issuecomment-775526281 I did something similar myself here, if it helps: https://github.com/pandio-com/pulsar-python-functions/blob/master/functions/python-schema/src/PythonSchema.py --

[GitHub] [pulsar] MarvinCai commented on pull request #9381: Expose ReachedEndOfTopic in Reader/Consumer API

2021-02-08 Thread GitBox
MarvinCai commented on pull request #9381: URL: https://github.com/apache/pulsar/pull/9381#issuecomment-775512362 /pulsarbot run-failure-checks This is an automated message from the Apache Git Service. To respond to the messa

[GitHub] [pulsar] nlu90 commented on pull request #9246: [fix #8089] expose PulsarAdmin client through Function Context

2021-02-08 Thread GitBox
nlu90 commented on pull request #9246: URL: https://github.com/apache/pulsar/pull/9246#issuecomment-775491410 sorry for the late reply. @sijie I just notice this change and am wondering the necessity of exposing the whole admin client from functions to users. Maybe we can have some

[GitHub] [pulsar] odmarkj opened a new pull request #9534: [docs] Adding Pandio as a user of Pulsar

2021-02-08 Thread GitBox
odmarkj opened a new pull request #9534: URL: https://github.com/apache/pulsar/pull/9534 *(If this PR fixes a github issue, please add `Fixes #`.)* Fixes # *(or if this PR is one task of a github issue, please add `Master Issue: #` to link to the master issue.)*

[GitHub] [pulsar] zzzming commented on a change in pull request #9515: Initial checkin of PublishMessage/Publish

2021-02-08 Thread GitBox
zzzming commented on a change in pull request #9515: URL: https://github.com/apache/pulsar/pull/9515#discussion_r572385903 ## File path: pulsar-function-go/pf/context.go ## @@ -25,18 +25,21 @@ import ( "time" "github.com/apache/pulsar-client-go/pulsar" +

[GitHub] [pulsar] merlimat opened a new pull request #9533: [C++] Removed usages of boost::regex

2021-02-08 Thread GitBox
merlimat opened a new pull request #9533: URL: https://github.com/apache/pulsar/pull/9533 ### Motivation Remove boost::regex which is the only remaining runtime boost dependency. ### Changes Removed the usage of `boost::regex`, substituting with `std::regex`. We only ne

[GitHub] [pulsar] eolivelli commented on issue #9526: CI is not running tests

2021-02-08 Thread GitBox
eolivelli commented on issue #9526: URL: https://github.com/apache/pulsar/issues/9526#issuecomment-775464166 What's the status of this issue? This is an automated message from the Apache Git Service. To respond to the mes

[GitHub] [pulsar] eolivelli commented on pull request #9500: Optimize built-in source/sink startup Part 2

2021-02-08 Thread GitBox
eolivelli commented on pull request #9500: URL: https://github.com/apache/pulsar/pull/9500#issuecomment-775456712 Great! I believe that this work will speed up a lot the integration tests Thanks This is an automate

[pulsar] branch master updated: Optimize built-in source/sink startup Part 2 (#9500)

2021-02-08 Thread jerrypeng
This is an automated email from the ASF dual-hosted git repository. jerrypeng 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 c27f7a3 Optimize built-in source/sink startu

[GitHub] [pulsar] jerrypeng merged pull request #9500: Optimize built-in source/sink startup Part 2

2021-02-08 Thread GitBox
jerrypeng merged pull request #9500: URL: https://github.com/apache/pulsar/pull/9500 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

[GitHub] [pulsar] jerrypeng commented on a change in pull request #9500: Optimize built-in source/sink startup Part 2

2021-02-08 Thread GitBox
jerrypeng commented on a change in pull request #9500: URL: https://github.com/apache/pulsar/pull/9500#discussion_r572351249 ## File path: pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/thread/ThreadRuntime.java ## @@ -84,34 +95,82 @@ this.

[GitHub] [pulsar] nlu90 commented on a change in pull request #9500: Optimize built-in source/sink startup Part 2

2021-02-08 Thread GitBox
nlu90 commented on a change in pull request #9500: URL: https://github.com/apache/pulsar/pull/9500#discussion_r572336779 ## File path: pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/thread/ThreadRuntime.java ## @@ -84,34 +95,82 @@ this.secr

[GitHub] [pulsar] nlu90 commented on a change in pull request #9515: Initial checkin of PublishMessage/Publish

2021-02-08 Thread GitBox
nlu90 commented on a change in pull request #9515: URL: https://github.com/apache/pulsar/pull/9515#discussion_r572329150 ## File path: pulsar-function-go/pf/instance.go ## @@ -75,6 +75,29 @@ func newGoInstance() *goInstance { return producer } +

[GitHub] [pulsar] nlu90 commented on a change in pull request #9519: [Functions] Call the corresponding restart according to the componenttype. #9502

2021-02-08 Thread GitBox
nlu90 commented on a change in pull request #9519: URL: https://github.com/apache/pulsar/pull/9519#discussion_r572319901 ## File path: pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionRuntimeManager.java ## @@ -440,8 +450,19 @@ public synchroniz

[GitHub] [pulsar] lhotari commented on pull request #9393: Fix testBrokerSelectionForAntiAffinityGroup by increasing OverloadedThreshold

2021-02-08 Thread GitBox
lhotari commented on pull request #9393: URL: https://github.com/apache/pulsar/pull/9393#issuecomment-775386084 The code in `LinuxBrokerHostUsageImpl` rings some bells. I faced some issues earlier where the method to read the Linux `/proc` and `/sys/fs` files with `Files.readAllBytes` was

[GitHub] [pulsar] lhotari commented on pull request #9393: Fix testBrokerSelectionForAntiAffinityGroup by increasing OverloadedThreshold

2021-02-08 Thread GitBox
lhotari commented on pull request #9393: URL: https://github.com/apache/pulsar/pull/9393#issuecomment-775365369 > I plan to take a look at the `LinuxBrokerHostUsageImpl` class later. I wonder if there is a bug in that code because we saw that `Infinity` value for CPU usage in the logs abov

[pulsar] branch master updated (02d9c62 -> f4f31e2)

2021-02-08 Thread aahmed
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 02d9c62 ignore when repl subs is disable by broker (#9523) add f4f31e2 Remove jsoncpp references (#9522) No n

[GitHub] [pulsar] aahmed-se merged pull request #9522: Remove jsoncpp references

2021-02-08 Thread GitBox
aahmed-se merged pull request #9522: URL: https://github.com/apache/pulsar/pull/9522 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

[pulsar] branch master updated (7fd3218 -> 02d9c62)

2021-02-08 Thread mmerli
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 7fd3218 [pulsar-broker] namespace resources use metadata-store api (#9351) add 02d9c62 ignore when repl subs

[GitHub] [pulsar] merlimat merged pull request #9523: Ignore When Replicated Subscription is Disabled by Broker

2021-02-08 Thread GitBox
merlimat merged pull request #9523: URL: https://github.com/apache/pulsar/pull/9523 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

[GitHub] [pulsar] lhotari commented on pull request #9393: Fix testBrokerSelectionForAntiAffinityGroup by increasing OverloadedThreshold

2021-02-08 Thread GitBox
lhotari commented on pull request #9393: URL: https://github.com/apache/pulsar/pull/9393#issuecomment-775359872 > I'm guessing the `Azure VM` @lhotari references above is a linux machine, but it'd be good to confirm. @michaeljmarshall yes, it's a VM running Ubuntu Linux. There's [Git

[GitHub] [pulsar] gaoran10 opened a new pull request #9532: [Broker] Async read entries with max size bytes

2021-02-08 Thread GitBox
gaoran10 opened a new pull request #9532: URL: https://github.com/apache/pulsar/pull/9532 ### Motivation Currently, we could specify the param `maxSizeBytes` when reading entries by the method `asyncReadEntriesOrWait`, but this method will be blocked when there are no entries to rea

[pulsar] branch master updated (efb2089 -> 7fd3218)

2021-02-08 Thread rdhabalia
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 efb2089 [Issue9507][testclient] add --batch-index-ack for the pulsar-perf (#9521) add 7fd3218 [pulsar-brok

[GitHub] [pulsar] rdhabalia merged pull request #9351: [pulsar-broker] namespace resources use metadata-store api

2021-02-08 Thread GitBox
rdhabalia merged pull request #9351: URL: https://github.com/apache/pulsar/pull/9351 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

[GitHub] [pulsar] joncashe commented on issue #9242: Issue with offload on 2.7.0 migrating from 2.6.1

2021-02-08 Thread GitBox
joncashe commented on issue #9242: URL: https://github.com/apache/pulsar/issues/9242#issuecomment-775326486 > Yes, the broker logs could help us to find more Infomation. > > And I have some questions, please take a look. > > 1. If the topic didn't set the namespace offload poli

  1   2   >