GitHub user hpvd added a comment to the discussion: Apache Beam support for
Pulsar
if you are interested in Beam support for Pulsar plz upvote this discussion
topic to gain visibility
and take a look on open issues in beam repository summarized in
https://github.com/apache/beam/issues/31078
semistone opened a new issue, #22601:
URL: https://github.com/apache/pulsar/issues/22601
### Search before asking
- [X] I searched in the [issues](https://github.com/apache/pulsar/issues)
and found nothing similar.
### Read release policy
- [X] I understand that
thetumbled commented on PR #22595:
URL: https://github.com/apache/pulsar/pull/22595#issuecomment-2079048232
/pulsarbot rerun-failure-checks
--
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
codecov-commenter commented on PR #22600:
URL: https://github.com/apache/pulsar/pull/22600#issuecomment-2079013686
##
[Codecov](https://app.codecov.io/gh/apache/pulsar/pull/22600?dropdown=coverage=pr=h1_medium=referral_source=github_content=comment_campaign=pr+comments_term=apache)
Report
Technoboy- commented on code in PR #22600:
URL: https://github.com/apache/pulsar/pull/22600#discussion_r1580764559
##
managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerTest.java:
##
@@ -2473,19 +2473,17 @@ public void testTimestampOnWorkingLedger()
heesung-sn commented on PR #22597:
URL: https://github.com/apache/pulsar/pull/22597#issuecomment-2078763715
To answer your questions, Im not sure. I assume all system topics should
live in local cluster only,but I could be wrong.
--
This is an automated message from the Apache Git
BewareMyPower commented on code in PR #22573:
URL: https://github.com/apache/pulsar/pull/22573#discussion_r1580574803
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java:
##
@@ -926,9 +927,13 @@ public void unloadNamespaceBundlesGracefully() {
poorbarcode commented on code in PR #22599:
URL: https://github.com/apache/pulsar/pull/22599#discussion_r1580626116
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java:
##
@@ -1429,7 +1430,14 @@ private CompletableFuture
freeznet commented on PR #22501:
URL: https://github.com/apache/pulsar/pull/22501#issuecomment-2078827890
@lhotari could you please help to review this PR when you have time, thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
lhotari commented on code in PR #22599:
URL: https://github.com/apache/pulsar/pull/22599#discussion_r1580671136
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java:
##
@@ -1429,7 +1430,14 @@ private CompletableFuture delete(boolean
lhotari merged PR #22595:
URL: https://github.com/apache/pulsar/pull/22595
--
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:
This is an automated email from the ASF dual-hosted git repository.
lhotari 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 d19860c706e [cleanup] [test] remove useless
lhotari commented on PR #17524:
URL: https://github.com/apache/pulsar/pull/17524#issuecomment-2079199183
@poorbarcode looks like OneWayReplicatorTest.testUnFenceTopicToReuse fails
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
lhotari commented on code in PR #22573:
URL: https://github.com/apache/pulsar/pull/22573#discussion_r1580566781
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java:
##
@@ -926,9 +927,13 @@ public void unloadNamespaceBundlesGracefully() {
}
lhotari opened a new pull request, #22596:
URL: https://github.com/apache/pulsar/pull/22596
### Motivation
When topic is closing and throws an exception, the exception isn't logged
and it's swallowed.
It's better to propagate the cause in TopicBusyException in these causes.
shibd opened a new pull request, #22600:
URL: https://github.com/apache/pulsar/pull/22600
### Motivation
#22430
After #22034, When the ledger is closed due to full entry, will trigger
create a new ledger, However, since the creation of the ledger is asynchronous,
sometimes the
lhotari commented on PR #17524:
URL: https://github.com/apache/pulsar/pull/17524#issuecomment-2078692302
> However, I think this Topic state management needs a serious refactoring.
>
> I suggest defining TopicState and revisit topic state transitions in a
state machine manner.
Technoboy- merged PR #22547:
URL: https://github.com/apache/pulsar/pull/22547
--
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:
poorbarcode commented on PR #17524:
URL: https://github.com/apache/pulsar/pull/17524#issuecomment-2078692154
> However, I think this Topic state management needs a serious refactoring.
Agree with you
--
This is an automated message from the Apache Git Service.
To respond to the
This is an automated email from the ASF dual-hosted git repository.
technoboy 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 69a600e86bb [improve][admin] Check if the
lhotari opened a new pull request, #22597:
URL: https://github.com/apache/pulsar/pull/22597
WIP, not ready for review. PR opened in draft mode for initial discussion
and feedback.
### Motivation
When investigating another issue and reproducing the problem using these
heesung-sn commented on PR #22597:
URL: https://github.com/apache/pulsar/pull/22597#issuecomment-2078761854
I realized that Pulsar has some loopholes that unnecessarily try to
replicate, migrate or do other operations on system topics.
We need to check all system topics and define
lhotari opened a new pull request, #22599:
URL: https://github.com/apache/pulsar/pull/22599
### Motivation
```
2024-04-26T09:36:28,397 - ERROR -
[ForkJoinPool.commonPool-worker-10:PersistentTopic] -
[persistent://pulsar/global/removeClusterTest/__change_events] Error closing
poorbarcode commented on code in PR #21948:
URL: https://github.com/apache/pulsar/pull/21948#discussion_r1580517607
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java:
##
@@ -3881,9 +3895,27 @@ private void
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 adac20a72ef [improve][admin] Check
thetumbled commented on code in PR #22595:
URL: https://github.com/apache/pulsar/pull/22595#discussion_r1580519788
##
pulsar-broker/src/test/java/org/apache/pulsar/client/api/AuthorizationProducerConsumerTest.java:
##
@@ -349,7 +349,8 @@ public void testSubscriberPermission()
thetumbled commented on code in PR #22595:
URL: https://github.com/apache/pulsar/pull/22595#discussion_r1580519788
##
pulsar-broker/src/test/java/org/apache/pulsar/client/api/AuthorizationProducerConsumerTest.java:
##
@@ -349,7 +349,8 @@ public void testSubscriberPermission()
lhotari commented on PR #22597:
URL: https://github.com/apache/pulsar/pull/22597#issuecomment-2078730928
@poorbarcode @heesung-sn Do you think that relaxing the
checkLocalOrGetPeerReplicationCluster checks for system topics would be useful?
--
This is an automated message from the
thetumbled commented on code in PR #22595:
URL: https://github.com/apache/pulsar/pull/22595#discussion_r1580519788
##
pulsar-broker/src/test/java/org/apache/pulsar/client/api/AuthorizationProducerConsumerTest.java:
##
@@ -349,7 +349,8 @@ public void testSubscriberPermission()
GitHub user visortelle edited a comment on the discussion: What is the intended
result of creating a cluster via PUT /admin/v2/clusters/{cluster-name}?
@dameiss-tibco hi
You'll need to use these cluster names in further operations. For example, the
"create tenant" operation requires at
nodece commented on PR #22391:
URL: https://github.com/apache/pulsar/pull/22391#issuecomment-2079804762
Could you provide the log4j/log4j2 and slf4j versions?
I can help you solve the issues you are facing.
--
This is an automated message from the Apache Git Service.
To respond to the
poorbarcode commented on PR #17524:
URL: https://github.com/apache/pulsar/pull/17524#issuecomment-2079693146
> @poorbarcode looks like OneWayReplicatorTest.testUnFenceTopicToReuse fails
Sorry, I found a behavior change(before: broker tries to unfence topic to
reuse when clos clients
GitHub user visortelle edited a comment on the discussion: What is the intended
result of creating a cluster via PUT /admin/v2/clusters/{cluster-name}?
@dameiss-tibco hi
You'll need to use these cluster names in further operations. For example, the
"create tenant" operation requires at
GitHub user visortelle added a comment to the discussion: What is the intended
result of creating a cluster via PUT /admin/v2/clusters/{cluster-name}?
@dameiss-tibco hi
You'll need to use these cluster names in further operations. For example, the
"create tenant" operation requires at
GitHub user visortelle edited a comment on the discussion: What is the intended
result of creating a cluster via PUT /admin/v2/clusters/{cluster-name}?
@dameiss-tibco hi
You'll need to use these cluster names in further operations. For example, the
"create tenant" operation requires at
GitHub user visortelle edited a comment on the discussion: What is the intended
result of creating a cluster via PUT /admin/v2/clusters/{cluster-name}?
@dameiss-tibco hi
You'll need to use these cluster names in further operations. For example, the
"create tenant" operation requires at
BewareMyPower commented on PR #22391:
URL: https://github.com/apache/pulsar/pull/22391#issuecomment-2079238842
It's a breaking change that affects the down
In our KSN project (the private version of
[KoP](https://github.com/streamnative/kop)), after upgrading to include this
commit,
This is an automated email from the ASF dual-hosted git repository.
lhotari 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 ec646f90c48 [improve][meta] Log a
This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a commit to branch branch-2.11
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-2.11 by this push:
new 66a1edb64b9 [improve][meta] Log a
This is an automated email from the ASF dual-hosted git repository.
lhotari 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 b764afa2bb3 [improve][meta] Log a
This is an automated email from the ASF dual-hosted git repository.
lhotari 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 701d4cfe21b [improve][meta] Log a
BewareMyPower commented on PR #22391:
URL: https://github.com/apache/pulsar/pull/22391#issuecomment-2079249332
I tried adding the `reload4j` dependency and it didn't work.
```
[INFO] \- org.slf4j:slf4j-reload4j:jar:2.0.13:test
[INFO]\-
This is an automated email from the ASF dual-hosted git repository.
lhotari 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 6e0d0d98b29 [improve][broker]
sandeep-mst opened a new pull request, #891:
URL: https://github.com/apache/pulsar-site/pull/891
Cluster failover Java client is available for 2.10.0 and later versions.
This PR fixes example code shown in
This is an automated email from the ASF dual-hosted git repository.
lhotari 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 69839c72f13 [improve][meta] Log a warning when
lhotari merged PR #22566:
URL: https://github.com/apache/pulsar/pull/22566
--
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:
lhotari commented on code in PR #22589:
URL: https://github.com/apache/pulsar/pull/22589#discussion_r1581034618
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/SystemTopicBasedTopicPoliciesService.java:
##
@@ -110,11 +111,13 @@ public
lhotari merged PR #22596:
URL: https://github.com/apache/pulsar/pull/22596
--
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:
This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from 69839c72f13 [improve][meta] Log a warning when ZK batch fails with
connectionloss (#22566)
add 3b9602c04db
This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 8ecfd64a8993e93a2ff4a45b3ca32b74f7a04997
Author: Lari Hotari
AuthorDate: Tue Oct 17 21:50:16 2023 +0300
This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 72833feba28740b7f02e1978edae7baf36a462bf
Author: Lari Hotari
AuthorDate: Thu Apr 25 21:54:55 2024 +0300
This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a change to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from 5ffec8a3cd8 [fix][admin] Fix namespace admin api exception response
(#22587)
new 8ecfd64a899 [fix][test]
merlimat commented on code in PR #22585:
URL: https://github.com/apache/pulsar/pull/22585#discussion_r1581199791
##
pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/batching/AbstractBatchedMetadataStore.java:
##
@@ -99,7 +103,13 @@ public void close() throws
This is an automated email from the ASF dual-hosted git repository.
lhotari 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 1be23d00295 [fix][test] Clear fields
lhotari merged PR #22573:
URL: https://github.com/apache/pulsar/pull/22573
--
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:
lhotari closed issue #22569: [Bug] Broker could take 30+ seconds to close with
extensible load manager
URL: https://github.com/apache/pulsar/issues/22569
--
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
This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from 3b9602c04db [improve][broker] Propagate cause exception in
TopicBusyException when applicable (#22596)
add
This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a commit to branch branch-2.11
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-2.11 by this push:
new 82308b95f59 [improve][broker]
This is an automated email from the ASF dual-hosted git repository.
lhotari 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 d00d715f487 [improve][broker]
This is an automated email from the ASF dual-hosted git repository.
lhotari 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 7cc99dfff63 [improve][broker]
bph-sag commented on issue #424:
URL:
https://github.com/apache/pulsar-client-cpp/issues/424#issuecomment-2079446323
So, looking at the internal stats for the topic, it does appear that the
mark-delete position indicates that the full batch is indeed acknowledged for
our aarch32 runs.
lhotari merged PR #22599:
URL: https://github.com/apache/pulsar/pull/22599
--
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:
This is an automated email from the ASF dual-hosted git repository.
lhotari 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 f8f256cfbdc [fix][broker] Continue closing
This is an automated email from the ASF dual-hosted git repository.
ayegorov 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 bf5d6aac1b6 [improve][broker] perf: Reduce
dlg99 merged PR #22536:
URL: https://github.com/apache/pulsar/pull/22536
--
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:
This is an automated email from the ASF dual-hosted git repository.
lhotari 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 7a44c801f86 [improve][broker] Close
lhotari merged PR #22589:
URL: https://github.com/apache/pulsar/pull/22589
--
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:
This is an automated email from the ASF dual-hosted git repository.
lhotari 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 8323a3c4991 [improve][broker] Don't use
lhotari merged PR #22598:
URL: https://github.com/apache/pulsar/pull/22598
--
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:
codecov-commenter commented on PR #22604:
URL: https://github.com/apache/pulsar/pull/22604#issuecomment-2080372023
##
[Codecov](https://app.codecov.io/gh/apache/pulsar/pull/22604?dropdown=coverage=pr=h1_medium=referral_source=github_content=comment_campaign=pr+comments_term=apache)
Report
dao-jun opened a new issue, #22603:
URL: https://github.com/apache/pulsar/issues/22603
### Search before asking
- [X] I searched in the [issues](https://github.com/apache/pulsar/issues)
and found nothing similar.
### Read release policy
- [X] I understand that
dao-jun opened a new pull request, #22604:
URL: https://github.com/apache/pulsar/pull/22604
Fixes https://github.com/apache/pulsar/issues/22603
### Motivation
Fix concurrent containers concurrency issue
### Modifications
### Verifying this change
72 matches
Mail list logo
