Re: [PR] [feat][ci] Add Trivy container scan Github workflow [pulsar]

2024-02-28 Thread via GitHub
merlimat commented on code in PR #22063: URL: https://github.com/apache/pulsar/pull/22063#discussion_r1507133706 ## .github/workflows/ci-trivy-container-scan.yaml: ## @@ -0,0 +1,92 @@ +# +# Licensed to the Apache Software Foundation (ASF) under one +# or more contributor

Re: [PR] [improve][broker]PIP-340 Optimization of Probe Implementation for Automatic Failover [pulsar]

2024-02-28 Thread via GitHub
merlimat commented on PR #22133: URL: https://github.com/apache/pulsar/pull/22133#issuecomment-1970564711 The idea for `ControlledClusterFailover` is to move the control of whether a cluster is "healthy" outside of the Pulsar scope. You just need to implement a HTTP service that will tell

Re: [PR] [improve][broker]PIP-340 Optimization of Probe Implementation for Automatic Failover [pulsar]

2024-02-28 Thread via GitHub
merlimat commented on PR #22133: URL: https://github.com/apache/pulsar/pull/22133#issuecomment-1970562678 @yyj8 Wouldn't this already be covered by the `ControlledClusterFailover` mechanism?

Re: [PR] [improve] [broker] apply topK machanism to ModularLoadManagerImpl. [pulsar]

2024-02-28 Thread via GitHub
thetumbled commented on code in PR #21085: URL: https://github.com/apache/pulsar/pull/21085#discussion_r1506916208 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java: ## @@ -1139,6 +1143,29 @@ public void

Re: [PR] [improve] [broker] apply topK machanism to ModularLoadManagerImpl. [pulsar]

2024-02-28 Thread via GitHub
thetumbled commented on code in PR #21085: URL: https://github.com/apache/pulsar/pull/21085#discussion_r1506916208 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java: ## @@ -1139,6 +1143,29 @@ public void

Re: [PR] [fix][offload] Fix Offload readHandle cannot close multi times. [pulsar]

2024-02-28 Thread via GitHub
dao-jun commented on code in PR #22162: URL: https://github.com/apache/pulsar/pull/22162#discussion_r1507115485 ## pulsar-common/src/main/java/org/apache/pulsar/common/util/FutureUtil.java: ## @@ -348,20 +348,28 @@ public static void safeRunAsync(Runnable runnable,

Re: [PR] [fix][offload] Fix Offload readHandle cannot close multi times. [pulsar]

2024-02-28 Thread via GitHub
dao-jun commented on code in PR #22162: URL: https://github.com/apache/pulsar/pull/22162#discussion_r1507115272 ## tiered-storage/file-system/src/main/java/org/apache/bookkeeper/mledger/offload/filesystem/impl/FileStoreBackedReadHandleImpl.java: ## @@ -93,14 +103,20 @@ public

Re: [PR] [fix][offload] Fix Offload readHandle cannot close multi times. [pulsar]

2024-02-28 Thread via GitHub
lhotari commented on code in PR #22162: URL: https://github.com/apache/pulsar/pull/22162#discussion_r1507109877 ## tiered-storage/file-system/src/main/java/org/apache/bookkeeper/mledger/offload/filesystem/impl/FileStoreBackedReadHandleImpl.java: ## @@ -93,14 +103,20 @@ public

Re: [PR] [fix][offload] Fix Offload readHandle cannot close multi times. [pulsar]

2024-02-28 Thread via GitHub
lhotari commented on code in PR #22162: URL: https://github.com/apache/pulsar/pull/22162#discussion_r1507107989 ## pulsar-common/src/main/java/org/apache/pulsar/common/util/FutureUtil.java: ## @@ -348,20 +348,28 @@ public static void safeRunAsync(Runnable runnable,

Re: [PR] [fix][offload] Fix Offload readHandle cannot close multi times. [pulsar]

2024-02-28 Thread via GitHub
dao-jun closed pull request #22162: [fix][offload] Fix Offload readHandle cannot close multi times. URL: https://github.com/apache/pulsar/pull/22162 -- 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

Re: [PR] [fix][offload] Fix Offload readHandle cannot close multi times. [pulsar]

2024-02-28 Thread via GitHub
dao-jun commented on code in PR #22162: URL: https://github.com/apache/pulsar/pull/22162#discussion_r1507079349 ## pulsar-common/src/main/java/org/apache/pulsar/common/util/FutureUtil.java: ## @@ -347,4 +347,21 @@ public static void safeRunAsync(Runnable runnable,

Re: [PR] [fix][offload] Fix Offload readHandle cannot close multi times. [pulsar]

2024-02-28 Thread via GitHub
dao-jun commented on code in PR #22162: URL: https://github.com/apache/pulsar/pull/22162#discussion_r1507074601 ## tiered-storage/file-system/src/main/java/org/apache/bookkeeper/mledger/offload/filesystem/impl/FileStoreBackedReadHandleImpl.java: ## @@ -93,14 +103,20 @@ public

Re: [PR] [improve][broker]PIP-340 Optimization of Probe Implementation for Automatic Failover [pulsar]

2024-02-28 Thread via GitHub
yyj8 commented on PR #22133: URL: https://github.com/apache/pulsar/pull/22133#issuecomment-1970481292 > Your proposal seems to make sense a lot of sense, but the naming is perhaps not optimal. When looking at the changes, this looks like an active/passive status for a cluster and having

Re: [PR] [fix][offload] Fix Offload readHandle cannot close multi times. [pulsar]

2024-02-28 Thread via GitHub
lhotari commented on code in PR #22162: URL: https://github.com/apache/pulsar/pull/22162#discussion_r1507064238 ## tiered-storage/file-system/src/main/java/org/apache/bookkeeper/mledger/offload/filesystem/impl/FileStoreBackedReadHandleImpl.java: ## @@ -93,14 +103,20 @@ public

[PR] [fix][broker] Handle PendingAckHandle recover failed. [pulsar]

2024-02-28 Thread via GitHub
dao-jun opened a new pull request, #21760: URL: https://github.com/apache/pulsar/pull/21760 ### Motivation If a `PersistentSubscription`'s `PendingAckHandle` recover failed, the subscription won't be removed from the topic, and the consumers can't be added to the subscription.

Re: [PR] [fix][broker] Handle PendingAckHandle recover failed. [pulsar]

2024-02-28 Thread via GitHub
dao-jun closed pull request #21760: [fix][broker] Handle PendingAckHandle recover failed. URL: https://github.com/apache/pulsar/pull/21760 -- 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

[PR] [feat][monitor] PIP-222: Add PartitionMetadataRequest metrics [pulsar]

2024-02-28 Thread via GitHub
dao-jun opened a new pull request, #21771: URL: https://github.com/apache/pulsar/pull/21771 PIP: https://github.com/apache/pulsar/issues/18319 ### Motivation https://github.com/apache/pulsar/issues/18319 ### Modifications ### Verifying this change

Re: [PR] [feat][monitor] PIP-222: Add PartitionMetadataRequest metrics [pulsar]

2024-02-28 Thread via GitHub
dao-jun closed pull request #21771: [feat][monitor] PIP-222: Add PartitionMetadataRequest metrics URL: https://github.com/apache/pulsar/pull/21771 -- 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

[PR] [feat][monitor] PIP-223: Add metrics for all rest endpoints. [pulsar]

2024-02-28 Thread via GitHub
dao-jun opened a new pull request, #21772: URL: https://github.com/apache/pulsar/pull/21772 PIP: https://github.com/apache/pulsar/issues/18560 ### Motivation https://github.com/apache/pulsar/issues/18560 ### Modifications ### Verifying this change

Re: [PR] [feat][monitor] PIP-223: Add metrics for all rest endpoints. [pulsar]

2024-02-28 Thread via GitHub
dao-jun closed pull request #21772: [feat][monitor] PIP-223: Add metrics for all rest endpoints. URL: https://github.com/apache/pulsar/pull/21772 -- 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

Re: [PR] [improve][broker]PIP-340 Optimization of Probe Implementation for Automatic Failover [pulsar]

2024-02-28 Thread via GitHub
yyj8 commented on PR #22133: URL: https://github.com/apache/pulsar/pull/22133#issuecomment-1970477995 > @yyj8 One of the challenges is making this proposal consistent with the Blue-Green deployment feature. PIP-188 #16551 (please note that this PIP was filed before we switched to use

Re: [PR] [fix][Offload] fix indexEntries NullPointerException error [pulsar]

2024-02-28 Thread via GitHub
dao-jun commented on PR #22035: URL: https://github.com/apache/pulsar/pull/22035#issuecomment-1970446043 related PR: https://github.com/apache/pulsar/pull/22162 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[PR] [fix][offload] Fix Offload readHandle cannot close multi times. [pulsar]

2024-02-28 Thread via GitHub
dao-jun opened a new pull request, #22162: URL: https://github.com/apache/pulsar/pull/22162 Fixes https://github.com/apache/pulsar/pull/22035 Main Issue: #xyz PIP: #xyz ### Motivation Make `FileStoreBackedReadHandleImpl`,

(pulsar) branch master updated (c7cedc6828e -> 72cedb7020c)

2024-02-28 Thread yubiao
This is an automated email from the ASF dual-hosted git repository. yubiao pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git from c7cedc6828e [improve][fn] Add missing "exception" argument to some `log.error` (#22140) add 72cedb7020c [fix]

Re: [PR] [fix] [broker] print non log when delete partitioned topic failed [pulsar]

2024-02-28 Thread via GitHub
poorbarcode merged PR #22153: URL: https://github.com/apache/pulsar/pull/22153 -- 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. To unsubscribe, e-mail:

Re: [PR] [fix] [broker] print non log when delete partitioned topic failed [pulsar]

2024-02-28 Thread via GitHub
poorbarcode commented on PR #22153: URL: https://github.com/apache/pulsar/pull/22153#issuecomment-1970389301 Merging -- 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. To

Re: [PR] [fix][Offload] fix indexEntries NullPointerException error [pulsar]

2024-02-28 Thread via GitHub
dao-jun commented on PR #22035: URL: https://github.com/apache/pulsar/pull/22035#issuecomment-1970388475 Closing `Handle` multiple times does indeed occur frequently, because `ledger#closeAsync` is called by async thread when read entries failed, if there are some ongoing read operations,

(pulsar) branch branch-3.2 updated: [fix][cli] Fix the bug when set-retention specified size with -T (#22150)

2024-02-28 Thread technoboy
This is an automated email from the ASF dual-hosted git repository. technoboy pushed a commit to branch branch-3.2 in repository https://gitbox.apache.org/repos/asf/pulsar.git The following commit(s) were added to refs/heads/branch-3.2 by this push: new 0fedaf7fb05 [fix][cli] Fix the bug

Re: [PR] [fix] [broker] print non log when delete partitioned topic failed [pulsar]

2024-02-28 Thread via GitHub
poorbarcode commented on PR #22153: URL: https://github.com/apache/pulsar/pull/22153#issuecomment-1970385248 @lhotari > UPDATE: it seems that before, the log "Topic deleted successfully due to inactivity" could get printed before the operation had completed since thenApply was

[PR] [improve][cli] Remove cli unnecessary code [pulsar]

2024-02-28 Thread via GitHub
crossoverJie opened a new pull request, #22161: URL: https://github.com/apache/pulsar/pull/22161 ### Motivation Repeat with the code here:

(pulsar) branch branch-3.2 updated: [improve][fn] Add missing "exception" argument to some `log.error` (#22140)

2024-02-28 Thread technoboy
This is an automated email from the ASF dual-hosted git repository. technoboy pushed a commit to branch branch-3.2 in repository https://gitbox.apache.org/repos/asf/pulsar.git The following commit(s) were added to refs/heads/branch-3.2 by this push: new 846e675df34 [improve][fn] Add

Re: [I] [Bug] Broker memory leak [pulsar]

2024-02-28 Thread via GitHub
dao-jun commented on issue #22157: URL: https://github.com/apache/pulsar/issues/22157#issuecomment-1970344518 > The heap dump has reached 13GB and cannot be uploaded compress it and upload to cloud driver, such as 百度云? it is very important to locate the root cause -- This is an

Re: [I] [Bug] Pulsar3.2 Compile Fail [pulsar]

2024-02-28 Thread via GitHub
sherlock-lin closed issue #22159: [Bug] Pulsar3.2 Compile Fail URL: https://github.com/apache/pulsar/issues/22159 -- 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. To

(pulsar) branch branch-3.2 updated: [fix][broker] Return getOwnerAsync without waiting on source broker upon Assigning and Releasing and handle role change during role init (#22112)

2024-02-28 Thread heesung
This is an automated email from the ASF dual-hosted git repository. heesung pushed a commit to branch branch-3.2 in repository https://gitbox.apache.org/repos/asf/pulsar.git The following commit(s) were added to refs/heads/branch-3.2 by this push: new 00e97aef5d8 [fix][broker] Return

(pulsar) branch branch-3.2 updated: [fix][broker][branch-3.2] Set ServiceUnitStateChannel topic compaction threshold explicitly, improve getOwnerAsync, and fix other bugs (#22064) (#22160)

2024-02-28 Thread heesung
This is an automated email from the ASF dual-hosted git repository. heesung pushed a commit to branch branch-3.2 in repository https://gitbox.apache.org/repos/asf/pulsar.git The following commit(s) were added to refs/heads/branch-3.2 by this push: new cea035320a6 [fix][broker][branch-3.2]

Re: [PR] [fix][broker][branch-3.2] Set ServiceUnitStateChannel topic compaction threshold explicitly, improve getOwnerAsync, and fix other bugs (#22064) [pulsar]

2024-02-28 Thread via GitHub
heesung-sn merged PR #22160: URL: https://github.com/apache/pulsar/pull/22160 -- 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. To unsubscribe, e-mail:

Re: [I] [Bug] Broker memory leak [pulsar]

2024-02-28 Thread via GitHub
graysonzeng commented on issue #22157: URL: https://github.com/apache/pulsar/issues/22157#issuecomment-1970339024 The heap dump has reached 13GB and cannot be uploaded -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

Re: [PR] [fix][broker][branch-3.2] Set ServiceUnitStateChannel topic compaction threshold explicitly, improve getOwnerAsync, and fix other bugs (#22064) [pulsar]

2024-02-28 Thread via GitHub
github-actions[bot] commented on PR #22160: URL: https://github.com/apache/pulsar/pull/22160#issuecomment-1970337643 @heesung-sn Please add the following content to your PR description and select a checkbox: ``` - [ ] `doc` - [ ] `doc-required` - [ ] `doc-not-needed` - [ ]

[PR] [fix][broker][branch-3.2] Set ServiceUnitStateChannel topic compaction threshold explicitly, improve getOwnerAsync, and fix other bugs (#22064) [pulsar]

2024-02-28 Thread via GitHub
heesung-sn opened a new pull request, #22160: URL: https://github.com/apache/pulsar/pull/22160 PR: https://github.com/apache/pulsar/pull/22064 cherry picked from commit 5a614e96406335715e7c8239cab812864702d3e7 -- This is an automated message from the Apache Git Service. To respond

Re: [I] [Bug] Broker memory leak [pulsar]

2024-02-28 Thread via GitHub
dao-jun commented on issue #22157: URL: https://github.com/apache/pulsar/issues/22157#issuecomment-1970329207 could you please upload the heap dump 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

Re: [PR] Trigger verification [pulsar]

2024-02-28 Thread via GitHub
RobertIndie closed pull request #22158: Trigger verification URL: https://github.com/apache/pulsar/pull/22158 -- 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. To unsubscribe,

[I] [Bug] Pulsar3.2 Compile Fail [pulsar]

2024-02-28 Thread via GitHub
sherlock-lin opened a new issue, #22159: URL: https://github.com/apache/pulsar/issues/22159 ### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Version Pulsar3.2 ### Minimal

[PR] Trigger verification [pulsar]

2024-02-28 Thread via GitHub
RobertIndie opened a new pull request, #22158: URL: https://github.com/apache/pulsar/pull/22158 Fixes #xyz Main Issue: #xyz PIP: #xyz ### Motivation ### Modifications ### Verifying this change

[I] [Bug] Broker memory leak [pulsar]

2024-02-28 Thread via GitHub
graysonzeng opened a new issue, #22157: URL: https://github.com/apache/pulsar/issues/22157 ### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Version v3.1.1 ### Minimal reproduce

[PR] Add change log for 0.12.1 [pulsar-client-go]

2024-02-28 Thread via GitHub
RobertIndie opened a new pull request, #1189: URL: https://github.com/apache/pulsar-client-go/pull/1189 ### Motivation Add 0.12.1 change log **Note: This PR shouldn't be merged until the release vote is passed.** -- This is an automated message from the Apache Git

(pulsar-client-cpp) branch main updated: Fix blue-green migration might be stuck due to an existing reconnection (#406)

2024-02-28 Thread xyz
This is an automated email from the ASF dual-hosted git repository. xyz pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/pulsar-client-cpp.git The following commit(s) were added to refs/heads/main by this push: new 9f96eb9 Fix blue-green migration might be

Re: [I] [Bug] Flaky ExtensibleLoadManagerTest, which could also cause segfault in some platforms [pulsar-client-cpp]

2024-02-28 Thread via GitHub
BewareMyPower closed issue #405: [Bug] Flaky ExtensibleLoadManagerTest, which could also cause segfault in some platforms URL: https://github.com/apache/pulsar-client-cpp/issues/405 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

Re: [PR] Fix blue-green migration might be stuck due to an existing reconnection [pulsar-client-cpp]

2024-02-28 Thread via GitHub
BewareMyPower merged PR #406: URL: https://github.com/apache/pulsar-client-cpp/pull/406 -- 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. To unsubscribe, e-mail:

Re: [PR] [feat][ci] Add Trivy container scan Github workflow [pulsar]

2024-02-28 Thread via GitHub
onobc commented on code in PR #22063: URL: https://github.com/apache/pulsar/pull/22063#discussion_r1506920558 ## .github/workflows/ci-trivy-container-scan.yaml: ## @@ -0,0 +1,92 @@ +# +# Licensed to the Apache Software Foundation (ASF) under one +# or more contributor license

Re: [PR] [improve][broker]PIP-340 Optimization of Probe Implementation for Automatic Failover [pulsar]

2024-02-28 Thread via GitHub
yyj8 commented on PR #22133: URL: https://github.com/apache/pulsar/pull/22133#issuecomment-1970286631 > @yyj8 thanks for the contribution. The intention of the PIP process is that you'd first start the discussion on the mailing list before deciding the solution. There might be alternative

Re: [PR] [improve] [broker] apply topK machanism to ModularLoadManagerImpl. [pulsar]

2024-02-28 Thread via GitHub
thetumbled commented on code in PR #21085: URL: https://github.com/apache/pulsar/pull/21085#discussion_r1506916208 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java: ## @@ -1139,6 +1143,29 @@ public void

svn commit: r67630 - in /dev/pulsar/pulsar-client-go-0.12.1-candidate-1: ./ apache-pulsar-client-go-0.12.1-src.tar.gz apache-pulsar-client-go-0.12.1-src.tar.gz.asc apache-pulsar-client-go-0.12.1-src.t

2024-02-28 Thread zike
Author: zike Date: Thu Feb 29 02:23:04 2024 New Revision: 67630 Log: Staging artifacts and signature for Pulsar Client Go release 0.12.1-candidate-1 Added: dev/pulsar/pulsar-client-go-0.12.1-candidate-1/

[I] Pulsar Client Go Schema Registry to save scheme use for both Producer and Consumer [pulsar-client-go]

2024-02-28 Thread via GitHub
ThinhLe30 opened a new issue, #1188: URL: https://github.com/apache/pulsar-client-go/issues/1188 I'm using Avro schema and here is the example code to create a producer and consumer to send/receive messages: ```go //Create producer and send message producer, err :=

(pulsar-client-go) annotated tag v0.12.1-candidate-1 updated (a029f2d7 -> 98679f15)

2024-02-28 Thread zike
This is an automated email from the ASF dual-hosted git repository. zike pushed a change to annotated tag v0.12.1-candidate-1 in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git *** WARNING: tag v0.12.1-candidate-1 was modified! *** from a029f2d7 (commit) to

(pulsar-client-go) branch branch-0.12.0 updated: Release v0.12.1

2024-02-28 Thread zike
This is an automated email from the ASF dual-hosted git repository. zike pushed a commit to branch branch-0.12.0 in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git The following commit(s) were added to refs/heads/branch-0.12.0 by this push: new a029f2d7 Release v0.12.1

(pulsar) branch branch-3.1 updated: [fix][broker][branch-3.0] Return getOwnerAsync without waiting on source broker upon Assigning and Releasing and handle role change during role init (#22112) (#2215

2024-02-28 Thread heesung
This is an automated email from the ASF dual-hosted git repository. heesung pushed a commit to branch branch-3.1 in repository https://gitbox.apache.org/repos/asf/pulsar.git The following commit(s) were added to refs/heads/branch-3.1 by this push: new 58a45aa2d2a [fix][broker][branch-3.0]

(pulsar) branch branch-3.0 updated: [fix][broker][branch-3.0] Return getOwnerAsync without waiting on source broker upon Assigning and Releasing and handle role change during role init (#22112) (#2215

2024-02-28 Thread heesung
This is an automated email from the ASF dual-hosted git repository. heesung pushed a commit to branch branch-3.0 in repository https://gitbox.apache.org/repos/asf/pulsar.git The following commit(s) were added to refs/heads/branch-3.0 by this push: new b3b1bfb3e2a [fix][broker][branch-3.0]

Re: [PR] [fix][broker][branch-3.0] Return getOwnerAsync without waiting on source broker upon Assigning and Releasing and handle role change during role init (#22112) [pulsar]

2024-02-28 Thread via GitHub
heesung-sn merged PR #22156: URL: https://github.com/apache/pulsar/pull/22156 -- 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. To unsubscribe, e-mail:

Re: [PR] [improve] [broker] apply topK machanism to ModularLoadManagerImpl. [pulsar]

2024-02-28 Thread via GitHub
thetumbled commented on code in PR #21085: URL: https://github.com/apache/pulsar/pull/21085#discussion_r1506912336 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java: ## @@ -1139,6 +1143,29 @@ public void

(pulsar) branch branch-3.1 updated: [fix][broker][branch-3.0] Set ServiceUnitStateChannel topic compaction threshold explicitly, improve getOwnerAsync, and fix other bugs (#22064) (#22154)

2024-02-28 Thread heesung
This is an automated email from the ASF dual-hosted git repository. heesung pushed a commit to branch branch-3.1 in repository https://gitbox.apache.org/repos/asf/pulsar.git The following commit(s) were added to refs/heads/branch-3.1 by this push: new 6d2ce8966af [fix][broker][branch-3.0]

Re: [PR] [fix][broker] Return getOwnerAsync without waiting on source broker upon Assigning and Releasing and handle role change during role init (#22112) [pulsar]

2024-02-28 Thread via GitHub
github-actions[bot] commented on PR #22156: URL: https://github.com/apache/pulsar/pull/22156#issuecomment-1970271888 @heesung-sn Please add the following content to your PR description and select a checkbox: ``` - [ ] `doc` - [ ] `doc-required` - [ ] `doc-not-needed` - [ ]

(pulsar-client-go) 04/05: [Fix] Fix available permits in MessageReceived (#1181)

2024-02-28 Thread zike
This is an automated email from the ASF dual-hosted git repository. zike pushed a commit to branch branch-0.12.0 in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git commit 9fdefe2bbd2ecdd7c9f853580e829cd66f22b78e Author: Jinjun Pan <75996911+pansz...@users.noreply.github.com>

(pulsar) branch master updated: [improve][fn] Add missing "exception" argument to some `log.error` (#22140)

2024-02-28 Thread daojun
This is an automated email from the ASF dual-hosted git repository. daojun 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 c7cedc6828e [improve][fn] Add missing

(pulsar-client-go) 01/05: [Producer] respect context cancellation in Flush (#1165)

2024-02-28 Thread zike
This is an automated email from the ASF dual-hosted git repository. zike pushed a commit to branch branch-0.12.0 in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git commit 436188c9014786a22db8eb532e7d7927c5f4e080 Author: Jayant AuthorDate: Thu Feb 1 21:52:52 2024 -0500

(pulsar-client-go) 05/05: [fix] Fix Infinite Loop in Reader's `HasNext` Function (#1182)

2024-02-28 Thread zike
This is an automated email from the ASF dual-hosted git repository. zike pushed a commit to branch branch-0.12.0 in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git commit a5f06793bd4365012641a79825267a51d4ce43c9 Author: Zike Yang AuthorDate: Wed Feb 28 18:39:00 2024 +0800

(pulsar-client-go) 03/05: [feat] Support partitioned topic reader (#1178)

2024-02-28 Thread zike
This is an automated email from the ASF dual-hosted git repository. zike pushed a commit to branch branch-0.12.0 in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git commit 6ce5421b07e23ff252ba5aaa754e1a0a5bab4cc5 Author: Zike Yang AuthorDate: Fri Feb 23 15:49:08 2024 +0800

(pulsar-client-go) 02/05: [Fix] Fix Bytes Schema (#1173)

2024-02-28 Thread zike
This is an automated email from the ASF dual-hosted git repository. zike pushed a commit to branch branch-0.12.0 in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git commit 68cd09a96e82a44e11fe92b050c9674143f1e5cc Author: Peter Hull

(pulsar-client-go) branch branch-0.12.0 updated (0f0d5a86 -> a5f06793)

2024-02-28 Thread zike
This is an automated email from the ASF dual-hosted git repository. zike pushed a change to branch branch-0.12.0 in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git from 0f0d5a86 Fix SIGSEGV with zstd compression enabled (#1164) new 436188c9 [Producer] respect

Re: [PR] [improve][fn] Add missing "exception" argument to some `log.error` [pulsar]

2024-02-28 Thread via GitHub
dao-jun merged PR #22140: URL: https://github.com/apache/pulsar/pull/22140 -- 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. To unsubscribe, e-mail:

(pulsar) branch branch-3.0 updated: [fix][broker][branch-3.0] Set ServiceUnitStateChannel topic compaction threshold explicitly, improve getOwnerAsync, and fix other bugs (#22064) (#22154)

2024-02-28 Thread heesung
This is an automated email from the ASF dual-hosted git repository. heesung pushed a commit to branch branch-3.0 in repository https://gitbox.apache.org/repos/asf/pulsar.git The following commit(s) were added to refs/heads/branch-3.0 by this push: new 6df02655a3c [fix][broker][branch-3.0]

Re: [PR] [fix][broker][branch-3.0] Set ServiceUnitStateChannel topic compaction threshold explicitly, improve getOwnerAsync, and fix other bugs (#22064) [pulsar]

2024-02-28 Thread via GitHub
heesung-sn merged PR #22154: URL: https://github.com/apache/pulsar/pull/22154 -- 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. To unsubscribe, e-mail:

Re: [PR] [improve] [broker] apply topK machanism to ModularLoadManagerImpl. [pulsar]

2024-02-28 Thread via GitHub
heesung-sn commented on code in PR #21085: URL: https://github.com/apache/pulsar/pull/21085#discussion_r1506894322 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java: ## @@ -1139,6 +1143,29 @@ public void

(pulsar-site) branch main updated: Docs sync done from apache/pulsar (#3b3c713)

2024-02-28 Thread urfree
This is an automated email from the ASF dual-hosted git repository. urfree pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/pulsar-site.git The following commit(s) were added to refs/heads/main by this push: new d59def68c723 Docs sync done from apache/pulsar

Re: [PR] [improve][broker] Change log level to reduce duplicated logs [pulsar]

2024-02-28 Thread via GitHub
mattisonchao commented on PR #22147: URL: https://github.com/apache/pulsar/pull/22147#issuecomment-1970219741 >In this case, the file doesn't even seem to exist. Could we avoid the exception in the first place by checking with java.nio.file.Files#isReadable if the file exists and is

Re: [PR] [improve][broker] Change log level to reduce duplicated logs [pulsar]

2024-02-28 Thread via GitHub
mattisonchao commented on PR #22147: URL: https://github.com/apache/pulsar/pull/22147#issuecomment-1970206408 > @mattisonchao Can you explain why this log is printed so many times? Because the broker needs to report the load data constantly and then this judgement method will invoke

Re: [PR] [feat][cli] Add a cli tool to check whether the input schema is validated [pulsar]

2024-02-28 Thread via GitHub
codelipenghui commented on PR #22151: URL: https://github.com/apache/pulsar/pull/22151#issuecomment-1970197713 +1 for adding a proposal for the new API And I'd like to validate the schema at the broker side for couple of reasons 1. Users might don't want to use Pulsar Admin

Re: [D] Decrease docs content font size from 18px to 16px [pulsar]

2024-02-28 Thread via GitHub
GitHub user visortelle edited a discussion: Decrease docs content font size from 18px to 16px It's a minor question, but probably resonates with someone who reads the docs often. When I visit Pulsar docs, I often feel that something is wrong with the font size and want to press CMD + - to

Re: [PR] [fix][broker] Set ServiceUnitStateChannel topic compaction threshold explicitly, improve getOwnerAsync, and fix other bugs (#22064) [pulsar]

2024-02-28 Thread via GitHub
heesung-sn commented on PR #22154: URL: https://github.com/apache/pulsar/pull/22154#issuecomment-1969937142 this PR will show load balance test flaky without this PR`https://github.com/apache/pulsar/pull/22112/` (I can cherry-pick thishttps://github.com/apache/pulsar/pull/22112/ after this

Re: [PR] [fix][broker] Set ServiceUnitStateChannel topic compaction threshold explicitly, improve getOwnerAsync, and fix other bugs [pulsar]

2024-02-28 Thread via GitHub
heesung-sn commented on PR #22064: URL: https://github.com/apache/pulsar/pull/22064#issuecomment-1969927766 @lhotari plz review this cherry-pick PR : https://github.com/apache/pulsar/pull/22154 -- This is an automated message from the Apache Git Service. To respond to the message, please

Re: [PR] [fix][broker] Set ServiceUnitStateChannel topic compaction threshold explicitly, improve getOwnerAsync, and fix other bugs (#22064) [pulsar]

2024-02-28 Thread via GitHub
github-actions[bot] commented on PR #22154: URL: https://github.com/apache/pulsar/pull/22154#issuecomment-1969926723 @heesung-sn Please add the following content to your PR description and select a checkbox: ``` - [ ] `doc` - [ ] `doc-required` - [ ] `doc-not-needed` - [ ]

[PR] [fix][broker] Set ServiceUnitStateChannel topic compaction threshold explicitly, improve getOwnerAsync, and fix other bugs (#22064) [pulsar]

2024-02-28 Thread via GitHub
heesung-sn opened a new pull request, #22154: URL: https://github.com/apache/pulsar/pull/22154 (cherry picked from commit 5a614e96406335715e7c8239cab812864702d3e7) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

Re: [PR] [fix][broker] Fix broker not starting when both transactions and the Extensible Load Manager are enabled [pulsar]

2024-02-28 Thread via GitHub
heesung-sn merged PR #22139: URL: https://github.com/apache/pulsar/pull/22139 -- 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. To unsubscribe, e-mail:

(pulsar) branch master updated (f33a3f4ad9e -> 3b3c713192b)

2024-02-28 Thread heesung
This is an automated email from the ASF dual-hosted git repository. heesung pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git from f33a3f4ad9e [fix][cli] Fix the bug when set-retention specified size with -T (#22150) add 3b3c713192b

Re: [D] how pulsar functions and parallel runtime works when consuming in key shared mode? [pulsar]

2024-02-28 Thread via GitHub
GitHub user estebanz01 added a comment to the discussion: how pulsar functions and parallel runtime works when consuming in key shared mode? Based on my testing, it's not clear how the function association works. Sometimes all functions see the same topics and sometimes some functions see

Re: [D] Window functions with extended SDK [pulsar]

2024-02-28 Thread via GitHub
GitHub user estebanz01 closed the discussion with a comment: Window functions with extended SDK I tried myself, it's not possible. GitHub link: https://github.com/apache/pulsar/discussions/22082#discussioncomment-8623062 This is an automatically sent email for

Re: [D] Window functions with extended SDK [pulsar]

2024-02-28 Thread via GitHub
GitHub user estebanz01 closed a discussion: Window functions with extended SDK Hola  ! >From the docs it's not clear if I can configure window functions to use the >extended SDK feature. I want to write a window function that saves some >information directly into a redis DB. Is it possible?

(pulsar) branch branch-3.2 updated: [improve][broker] Add an error log to troubleshoot the failure of starting broker registry. (#22065)

2024-02-28 Thread heesung
This is an automated email from the ASF dual-hosted git repository. heesung pushed a commit to branch branch-3.2 in repository https://gitbox.apache.org/repos/asf/pulsar.git The following commit(s) were added to refs/heads/branch-3.2 by this push: new 09d60d75758 [improve][broker] Add an

(pulsar) branch branch-3.0 updated: [improve][broker] Add an error log to troubleshoot the failure of starting broker registry. (#22065)

2024-02-28 Thread heesung
This is an automated email from the ASF dual-hosted git repository. heesung pushed a commit to branch branch-3.0 in repository https://gitbox.apache.org/repos/asf/pulsar.git The following commit(s) were added to refs/heads/branch-3.0 by this push: new f308ab2f4a2 [improve][broker] Add an

(pulsar) branch branch-3.1 updated: [improve][broker] Add an error log to troubleshoot the failure of starting broker registry. (#22065)

2024-02-28 Thread heesung
This is an automated email from the ASF dual-hosted git repository. heesung pushed a commit to branch branch-3.1 in repository https://gitbox.apache.org/repos/asf/pulsar.git The following commit(s) were added to refs/heads/branch-3.1 by this push: new 71022f5ba98 [improve][broker] Add an

Re: [PR] [improve][admin] Expose the offload threshold in seconds to the amdin [pulsar]

2024-02-28 Thread via GitHub
heesung-sn commented on PR #22101: URL: https://github.com/apache/pulsar/pull/22101#issuecomment-1969774168 This PR depends on TimeUnitToSecondsConverter, which has not been cherry-picked to branch-3.0. https://github.com/apache/pulsar/pull/20782 -- This is an automated message

(pulsar-site) branch case-studies-external-links deleted (was 8cc459b67459)

2024-02-28 Thread visortelle
This is an automated email from the ASF dual-hosted git repository. visortelle pushed a change to branch case-studies-external-links in repository https://gitbox.apache.org/repos/asf/pulsar-site.git was 8cc459b67459 Open Case Studies links in new tab The revisions that were on this branch

(pulsar-site) branch case-studies deleted (was faea87052a24)

2024-02-28 Thread visortelle
This is an automated email from the ASF dual-hosted git repository. visortelle pushed a change to branch case-studies in repository https://gitbox.apache.org/repos/asf/pulsar-site.git was faea87052a24 Fix build + minor fixes The revisions that were on this branch are still contained in

(pulsar) branch branch-3.1 updated: [fix][ml] Make mlOwnershipChecker asynchronous so that it doesn't block/deadlock threads (#21333)

2024-02-28 Thread heesung
This is an automated email from the ASF dual-hosted git repository. heesung pushed a commit to branch branch-3.1 in repository https://gitbox.apache.org/repos/asf/pulsar.git The following commit(s) were added to refs/heads/branch-3.1 by this push: new 750547b3e61 [fix][ml] Make

(pulsar) branch branch-3.0 updated: [fix][ml] Make mlOwnershipChecker asynchronous so that it doesn't block/deadlock threads (#21333)

2024-02-28 Thread heesung
This is an automated email from the ASF dual-hosted git repository. heesung pushed a commit to branch branch-3.0 in repository https://gitbox.apache.org/repos/asf/pulsar.git The following commit(s) were added to refs/heads/branch-3.0 by this push: new 1fd7934aca2 [fix][ml] Make

Re: [PR] [improve][broker] Fix broker not starting when both transactions and the Extensible Load Manager are enabled [pulsar]

2024-02-28 Thread via GitHub
lhotari commented on code in PR #22139: URL: https://github.com/apache/pulsar/pull/22139#discussion_r1506384701 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java: ## @@ -157,7 +158,8 @@ public

(pulsar-site) branch main updated: Open Case Studies links in new tab (#805)

2024-02-28 Thread visortelle
This is an automated email from the ASF dual-hosted git repository. visortelle pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/pulsar-site.git The following commit(s) were added to refs/heads/main by this push: new 9957c5fc56e1 Open Case Studies links in

Re: [PR] Open Case Studies links in new tab [pulsar-site]

2024-02-28 Thread via GitHub
visortelle merged PR #805: URL: https://github.com/apache/pulsar-site/pull/805 -- 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. To unsubscribe, e-mail:

[PR] Open Case Studies links in new tab [pulsar-site]

2024-02-28 Thread via GitHub
visortelle opened a new pull request, #805: URL: https://github.com/apache/pulsar-site/pull/805 I made this change according to the approved design in Figma that adds external link icons to cards on the Case Studies page: https://pulsar.apache.org/case-studies/

(pulsar-site) 01/01: Open Case Studies links in new tab

2024-02-28 Thread visortelle
This is an automated email from the ASF dual-hosted git repository. visortelle pushed a commit to branch case-studies-external-links in repository https://gitbox.apache.org/repos/asf/pulsar-site.git commit 8cc459b67459e700925b25f1bba03ab86be4f94c Author: visortelle AuthorDate: Wed Feb 28

(pulsar-site) branch case-studies-external-links created (now 8cc459b67459)

2024-02-28 Thread visortelle
This is an automated email from the ASF dual-hosted git repository. visortelle pushed a change to branch case-studies-external-links in repository https://gitbox.apache.org/repos/asf/pulsar-site.git at 8cc459b67459 Open Case Studies links in new tab This branch includes the following new

  1   2   >