[GitHub] [pulsar] eolivelli commented on a change in pull request #10536: fix lock manager npe when broker shutting down

2021-05-10 Thread GitBox
eolivelli commented on a change in pull request #10536: URL: https://github.com/apache/pulsar/pull/10536#discussion_r629895490 ## File path: pulsar-metadata/src/main/java/org/apache/pulsar/metadata/coordination/impl/LockManagerImpl.java ## @@ -115,9 +115,11 @@ private void han

[GitHub] [pulsar] gaoran10 commented on pull request #10535: Allow to overwrite the offload drive config by metadata

2021-05-10 Thread GitBox
gaoran10 commented on pull request #10535: URL: https://github.com/apache/pulsar/pull/10535#issuecomment-837948155 Currently, this method is mainly used to get the bucket name of the offload data. If we use the topic offload configuration instead of the offload context in the LedgerInfo, t

[GitHub] [pulsar] linlinnn commented on pull request #10530: [Issue 10522] support mock zookeeper with different session

2021-05-10 Thread GitBox
linlinnn commented on pull request #10530: URL: https://github.com/apache/pulsar/pull/10530#issuecomment-837938623 /pulsarbot run-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 t

[GitHub] [pulsar] linlinnn commented on pull request #10520: get durable subscription without handling startMessageRollbackDurationSec

2021-05-10 Thread GitBox
linlinnn commented on pull request #10520: URL: https://github.com/apache/pulsar/pull/10520#issuecomment-837937645 /pulsarbot run-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 t

[GitHub] [pulsar] linlinnn opened a new issue #10537: flaky test LoadBalancerTest often failed

2021-05-10 Thread GitBox
linlinnn opened a new issue #10537: URL: https://github.com/apache/pulsar/issues/10537 **Describe the bug** flaky test LoadBalancerTest often failed **Expected behavior** pass test **Additional context** ``` Error: testBrokerRanking(org.apache.pulsar.broker.loadb

[GitHub] [pulsar] eolivelli commented on a change in pull request #10535: Allow to overwrite the offload drive config by metadata

2021-05-10 Thread GitBox
eolivelli commented on a change in pull request #10535: URL: https://github.com/apache/pulsar/pull/10535#discussion_r629876241 ## File path: tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/BlobStoreManagedLedgerOffloader.java ## @@ -485,8

[GitHub] [pulsar] linlinnn commented on a change in pull request #10536: fix lock manager npe when broker shutting down

2021-05-10 Thread GitBox
linlinnn commented on a change in pull request #10536: URL: https://github.com/apache/pulsar/pull/10536#discussion_r629875513 ## File path: pulsar-metadata/src/main/java/org/apache/pulsar/metadata/coordination/impl/LockManagerImpl.java ## @@ -115,9 +115,11 @@ private void hand

[GitHub] [pulsar] freeznet commented on a change in pull request #10513: [fix #9640] remove `pulsar-client-admin-api` dependency : `pulsar-client-original`

2021-05-10 Thread GitBox
freeznet commented on a change in pull request #10513: URL: https://github.com/apache/pulsar/pull/10513#discussion_r629851502 ## File path: pulsar-io/kafka/pom.xml ## @@ -39,6 +39,12 @@ provided + + ${project.groupId} + pulsar-client-original Revie

[GitHub] [pulsar] freeznet commented on a change in pull request #10513: [fix #9640] remove `pulsar-client-admin-api` dependency : `pulsar-client-original`

2021-05-10 Thread GitBox
freeznet commented on a change in pull request #10513: URL: https://github.com/apache/pulsar/pull/10513#discussion_r629870150 ## File path: pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/TopicsImpl.java ## @@ -1397,9 +1399,14 @@ public OffloadProcess

[GitHub] [pulsar] freeznet commented on a change in pull request #10513: [fix #9640] remove `pulsar-client-admin-api` dependency : `pulsar-client-original`

2021-05-10 Thread GitBox
freeznet commented on a change in pull request #10513: URL: https://github.com/apache/pulsar/pull/10513#discussion_r629870150 ## File path: pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/TopicsImpl.java ## @@ -1397,9 +1399,14 @@ public OffloadProcess

[GitHub] [pulsar] freeznet commented on a change in pull request #10513: [fix #9640] remove `pulsar-client-admin-api` dependency : `pulsar-client-original`

2021-05-10 Thread GitBox
freeznet commented on a change in pull request #10513: URL: https://github.com/apache/pulsar/pull/10513#discussion_r629873481 ## File path: pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/TopicsImpl.java ## @@ -1397,9 +1399,14 @@ public OffloadProcess

[GitHub] [pulsar] freeznet commented on a change in pull request #10513: [fix #9640] remove `pulsar-client-admin-api` dependency : `pulsar-client-original`

2021-05-10 Thread GitBox
freeznet commented on a change in pull request #10513: URL: https://github.com/apache/pulsar/pull/10513#discussion_r629870150 ## File path: pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/TopicsImpl.java ## @@ -1397,9 +1399,14 @@ public OffloadProcess

[GitHub] [pulsar] 315157973 commented on a change in pull request #10357: [Issue 10242] add authentication data for remote cluster

2021-05-10 Thread GitBox
315157973 commented on a change in pull request #10357: URL: https://github.com/apache/pulsar/pull/10357#discussion_r629867007 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java ## @@ -1058,7 +1058,9 @@ public PulsarClient getReplicat

[GitHub] [pulsar] eolivelli commented on a change in pull request #10530: [Issue 10522] support mock zookeeper with different session

2021-05-10 Thread GitBox
eolivelli commented on a change in pull request #10530: URL: https://github.com/apache/pulsar/pull/10530#discussion_r629855168 ## File path: testmocks/src/main/java/org/apache/zookeeper/MockZooKeeperSession.java ## @@ -0,0 +1,224 @@ +/** + * Licensed to the Apache Software Fou

[GitHub] [pulsar] freeznet commented on a change in pull request #10513: [fix #9640] remove `pulsar-client-admin-api` dependency : `pulsar-client-original`

2021-05-10 Thread GitBox
freeznet commented on a change in pull request #10513: URL: https://github.com/apache/pulsar/pull/10513#discussion_r629851502 ## File path: pulsar-io/kafka/pom.xml ## @@ -39,6 +39,12 @@ provided + + ${project.groupId} + pulsar-client-original Revie

[GitHub] [pulsar] hangc0276 opened a new pull request #10536: fix lock manager npe when broker shutting down

2021-05-10 Thread GitBox
hangc0276 opened a new pull request #10536: URL: https://github.com/apache/pulsar/pull/10536 ### Motivation In broker shutting down stage, it throw the following exception. ``` 11:31:55.887 [metadata-store-5-1] ERROR org.apache.pulsar.metadata.impl.AbstractMetadataStore - Failed to

[GitHub] [pulsar] merlimat commented on a change in pull request #10513: [fix #9640] remove `pulsar-client-admin-api` dependency : `pulsar-client-original`

2021-05-10 Thread GitBox
merlimat commented on a change in pull request #10513: URL: https://github.com/apache/pulsar/pull/10513#discussion_r629838287 ## File path: pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/TopicsImpl.java ## @@ -1397,9 +1399,14 @@ public OffloadProcess

[GitHub] [pulsar] freeznet commented on pull request #10513: [fix #9640] remove `pulsar-client-admin-api` dependency : `pulsar-client-original`

2021-05-10 Thread GitBox
freeznet commented on pull request #10513: URL: https://github.com/apache/pulsar/pull/10513#issuecomment-837768495 @sijie @merlimat @jerrypeng @codelipenghui please help to review this PR if you have time, thanks. -- This is an automated message from the Apache Git Service. To respond to

[GitHub] [pulsar] chenyg0911 commented on issue #6899: Tumbling and Sliding Windows are not implemented in Python pulsar function

2021-05-10 Thread GitBox
chenyg0911 commented on issue #6899: URL: https://github.com/apache/pulsar/issues/6899#issuecomment-837762450 any roadmap for the feature can support python or go-lang? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [pulsar] abhilashmandaliya commented on pull request #10527: cleaned some code in GenericJsonRecord

2021-05-10 Thread GitBox
abhilashmandaliya commented on pull request #10527: URL: https://github.com/apache/pulsar/pull/10527#issuecomment-837759270 /pulsarbot run-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 t

[pulsar] branch master updated (4d2d66d -> a161e75)

2021-05-10 Thread jerrypeng
This is an automated email from the ASF dual-hosted git repository. jerrypeng pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git. from 4d2d66d Update "sample" tenant on standalone to stop using old property/cluster/namespace naming convention. (#1

[GitHub] [pulsar] jerrypeng merged pull request #10140: [Issue-9889] [integration tests] Refactored Function integration tests

2021-05-10 Thread GitBox
jerrypeng merged pull request #10140: URL: https://github.com/apache/pulsar/pull/10140 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, ple

[GitHub] [pulsar] jerrypeng closed issue #9889: Cleanup the org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest class

2021-05-10 Thread GitBox
jerrypeng closed issue #9889: URL: https://github.com/apache/pulsar/issues/9889 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please con

[GitHub] [pulsar] zymap opened a new pull request #10535: Allow to overwrite the offload drive config by metadata

2021-05-10 Thread GitBox
zymap opened a new pull request #10535: URL: https://github.com/apache/pulsar/pull/10535 --- *Motivation* We may change the offloaded data location by changing the metadata of the offloaded topic. So it should be allow to overwrite the driver config by metadata, and it should

[GitHub] [pulsar] 315157973 commented on pull request #10528: Make failPendingMessages called from within the ProducerImpl object mutex

2021-05-10 Thread GitBox
315157973 commented on pull request #10528: URL: https://github.com/apache/pulsar/pull/10528#issuecomment-837711641 > If all of the callers should from the ProducerImpl object mutex, why not change to `private synchronized void failPendingMessages`? Because this object mutex is also

[GitHub] [pulsar] equanz opened a new pull request #10534: [PIP 79][common,broker,client] Change PartitionedTopicStats to support partial partitioned producer

2021-05-10 Thread GitBox
equanz opened a new pull request #10534: URL: https://github.com/apache/pulsar/pull/10534 Master Issue: https://github.com/apache/pulsar/wiki/PIP-79%3A-Reduce-redundant-producers-from-partitioned-producer ### Motivation Please see the PIP document. This is a part of impleme

[GitHub] [pulsar] linlinnn commented on pull request #10533: Removed AspectJ based metrics for ZooKeeper

2021-05-10 Thread GitBox
linlinnn commented on pull request #10533: URL: https://github.com/apache/pulsar/pull/10533#issuecomment-837687426 /pulsarbot run-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 t

[GitHub] [pulsar] linlinnn commented on pull request #10520: get durable subscription without handling startMessageRollbackDurationSec

2021-05-10 Thread GitBox
linlinnn commented on pull request #10520: URL: https://github.com/apache/pulsar/pull/10520#issuecomment-837685940 /pulsarbot run-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 t

[GitHub] [pulsar] hangc0276 commented on a change in pull request #10529: Fix partitioned system topic check bug

2021-05-10 Thread GitBox
hangc0276 commented on a change in pull request #10529: URL: https://github.com/apache/pulsar/pull/10529#discussion_r629801530 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/systopic/SystemTopicClient.java ## @@ -168,7 +168,10 @@ } static boolea

[GitHub] [pulsar] hangc0276 commented on a change in pull request #10529: Fix partitioned system topic check bug

2021-05-10 Thread GitBox
hangc0276 commented on a change in pull request #10529: URL: https://github.com/apache/pulsar/pull/10529#discussion_r629801397 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/systopic/SystemTopicClient.java ## @@ -168,7 +168,10 @@ } static boolea

[GitHub] [pulsar] linlinnn commented on pull request #10520: get durable subscription without handling startMessageRollbackDurationSec

2021-05-10 Thread GitBox
linlinnn commented on pull request #10520: URL: https://github.com/apache/pulsar/pull/10520#issuecomment-837644341 /pulsarbot run-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 t

[pulsar-client-go] annotated tag v0.5.0-candidate-1 updated (aa1c9a3 -> c9696c0)

2021-05-10 Thread mmerli
This is an automated email from the ASF dual-hosted git repository. mmerli pushed a change to annotated tag v0.5.0-candidate-1 in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git. *** WARNING: tag v0.5.0-candidate-1 was modified! *** from aa1c9a3 (commit) to c9696c

svn commit: r47617 - in /dev/pulsar/pulsar-client-go: ./ apache-pulsar-client-go-0.5.0-src.tar.gz apache-pulsar-client-go-0.5.0-src.tar.gz.asc apache-pulsar-client-go-0.5.0-src.tar.gz.sha512

2021-05-10 Thread mmerli
Author: mmerli Date: Tue May 11 01:28:57 2021 New Revision: 47617 Log: Staging artifacts and signature for Pulsar Client Go release 0.5.0-candidate-1 Added: dev/pulsar/pulsar-client-go/ dev/pulsar/pulsar-client-go/apache-pulsar-client-go-0.5.0-src.tar.gz (with props) dev/pulsar/pul

svn commit: r47616 - /dev/pulsar/KEYS

2021-05-10 Thread mmerli
Author: mmerli Date: Tue May 11 01:27:28 2021 New Revision: 47616 Log: Update mmerli GPG key Modified: dev/pulsar/KEYS Modified: dev/pulsar/KEYS == --- dev/pulsar/KEYS (original) +++ dev/pulsar/KEYS Tue May 11 01:27:

[pulsar-manager] branch master updated: Upgrade Athenz version and remove yahoo.bintray.com repository (#379)

2021-05-10 Thread hrsakai
This is an automated email from the ASF dual-hosted git repository. hrsakai pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/pulsar-manager.git The following commit(s) were added to refs/heads/master by this push: new cebbcce Upgrade Athenz version and rem

[GitHub] [pulsar] codelipenghui commented on a change in pull request #10529: Fix partitioned system topic check bug

2021-05-10 Thread GitBox
codelipenghui commented on a change in pull request #10529: URL: https://github.com/apache/pulsar/pull/10529#discussion_r629782655 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/systopic/SystemTopicClient.java ## @@ -168,7 +168,10 @@ } static bo

[GitHub] [pulsar] linlinnn removed a comment on pull request #10520: get durable subscription without handling startMessageRollbackDurationSec

2021-05-10 Thread GitBox
linlinnn removed a comment on pull request #10520: URL: https://github.com/apache/pulsar/pull/10520#issuecomment-836318900 > Can you please add a test case? @eolivelli any suggestion about this, `MockManagedLedger` do nothing. -- This is an automated message from the Apache Git

[GitHub] [pulsar] dlg99 commented on a change in pull request #10498: SinkContext: ability to seek/pause/resume consumer for a topic

2021-05-10 Thread GitBox
dlg99 commented on a change in pull request #10498: URL: https://github.com/apache/pulsar/pull/10498#discussion_r629744063 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/MultiConsumerPulsarSource.java ## @@ -69,7 +72,20 @@ public void

[GitHub] [pulsar] merlimat opened a new pull request #10533: Removed AspectJ based metrics for ZooKeeper

2021-05-10 Thread GitBox
merlimat opened a new pull request #10533: URL: https://github.com/apache/pulsar/pull/10533 ### Motivation So far, we have been relying on a wacky approach to gather metrics for Zookeeper usage. That was done because ZK used not to have a decent set of exported metrics in server or

[GitHub] [pulsar] KannarFr commented on pull request #8048: [Issue 7903][proxy]Enable AutoTopicCreationType partitioned through proxy

2021-05-10 Thread GitBox
KannarFr commented on pull request #8048: URL: https://github.com/apache/pulsar/pull/8048#issuecomment-837424670 Are these flaky? errors seems not related to PR changes. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [pulsar] merlimat opened a new pull request #10532: PIP-45: Migrate NamespaceService to use MetadataStore

2021-05-10 Thread GitBox
merlimat opened a new pull request #10532: URL: https://github.com/apache/pulsar/pull/10532 ### Motivation Converted the NamespaceService to use MetadataStore instead of direct ZK access. -- This is an automated message from the Apache Git Service. To respond to the messag

[GitHub] [pulsar] KannarFr commented on pull request #8048: [Issue 7903][proxy]Enable AutoTopicCreationType partitioned through proxy

2021-05-10 Thread GitBox
KannarFr commented on pull request #8048: URL: https://github.com/apache/pulsar/pull/8048#issuecomment-837345612 /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 t

[GitHub] [pulsar] cdbartholomew opened a new pull request #10531: K8s Function Name Length Check Allows Invalid StatefulSet

2021-05-10 Thread GitBox
cdbartholomew opened a new pull request #10531: URL: https://github.com/apache/pulsar/pull/10531 ### Motivation When using the Kubernetes runtime, there is a check that the function name to ensure that it will create valid Kubernetes objects. It is currently set to check for the len

[GitHub] [pulsar] linlinnn commented on pull request #10530: [Issue 10522] support mock zookeeper with different session

2021-05-10 Thread GitBox
linlinnn commented on pull request #10530: URL: https://github.com/apache/pulsar/pull/10530#issuecomment-836961366 /pulsarbot run-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 t

[GitHub] [pulsar] 315157973 commented on a change in pull request #10529: Fix partitioned system topic check bug

2021-05-10 Thread GitBox
315157973 commented on a change in pull request #10529: URL: https://github.com/apache/pulsar/pull/10529#discussion_r629479074 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/systopic/SystemTopicClient.java ## @@ -168,7 +168,10 @@ } static boolea

[GitHub] [pulsar] linlinnn opened a new pull request #10530: [Issue 10522] support mock zookeeper with different session

2021-05-10 Thread GitBox
linlinnn opened a new pull request #10530: URL: https://github.com/apache/pulsar/pull/10530 fixes #10522 **Motivation** support mock zookeeper with different session **Modification** wrap **MockZookeeper** to support mock zookeeper with different session -- This is an

[GitHub] [pulsar] MarvinCai commented on a change in pull request #10326: support truncate topic

2021-05-10 Thread GitBox
MarvinCai commented on a change in pull request #10326: URL: https://github.com/apache/pulsar/pull/10326#discussion_r629472720 ## File path: managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerTest.java ## @@ -2917,4 +2916,59 @@ public void testManaged

[GitHub] [pulsar] eolivelli commented on pull request #10485: Update command descriptions from old 'property/cluster/namespace' format to current 'tenant/namespace' format

2021-05-10 Thread GitBox
eolivelli commented on pull request #10485: URL: https://github.com/apache/pulsar/pull/10485#issuecomment-836852553 an integration test fails consistently. I have to check it out. moving status to "draft" -- This is an automated message from the Apache Git Service. To respond to the me

[GitHub] [pulsar] hangc0276 commented on a change in pull request #10529: Fix partitioned system topic check bug

2021-05-10 Thread GitBox
hangc0276 commented on a change in pull request #10529: URL: https://github.com/apache/pulsar/pull/10529#discussion_r629455800 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/systopic/SystemTopicClient.java ## @@ -168,7 +168,10 @@ } static boolea

[GitHub] [pulsar] hangc0276 commented on a change in pull request #10529: Fix partitioned system topic check bug

2021-05-10 Thread GitBox
hangc0276 commented on a change in pull request #10529: URL: https://github.com/apache/pulsar/pull/10529#discussion_r629454124 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/systopic/SystemTopicClient.java ## @@ -168,7 +168,10 @@ } static boolea

[GitHub] [pulsar] linlinnn commented on pull request #10520: get durable subscription without handling startMessageRollbackDurationSec

2021-05-10 Thread GitBox
linlinnn commented on pull request #10520: URL: https://github.com/apache/pulsar/pull/10520#issuecomment-836778291 @eolivelli I have added unit test, please review again, thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [pulsar] 315157973 commented on a change in pull request #10529: Fix partitioned system topic check bug

2021-05-10 Thread GitBox
315157973 commented on a change in pull request #10529: URL: https://github.com/apache/pulsar/pull/10529#discussion_r629402243 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/systopic/SystemTopicClient.java ## @@ -168,7 +168,10 @@ } static boolea

[GitHub] [pulsar] 315157973 commented on a change in pull request #10529: Fix partitioned system topic check bug

2021-05-10 Thread GitBox
315157973 commented on a change in pull request #10529: URL: https://github.com/apache/pulsar/pull/10529#discussion_r629400528 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/systopic/SystemTopicClient.java ## @@ -168,7 +168,10 @@ } static boolea

[GitHub] [pulsar] MarvinCai commented on pull request #10401: [CLI] Add support for setting time based limit on backlog quota with CLI.

2021-05-10 Thread GitBox
MarvinCai commented on pull request #10401: URL: https://github.com/apache/pulsar/pull/10401#issuecomment-836739422 /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 t

[GitHub] [pulsar] t3link commented on issue #10523: Key_Shared subscription is not evenly distributed

2021-05-10 Thread GitBox
t3link commented on issue #10523: URL: https://github.com/apache/pulsar/issues/10523#issuecomment-836707922 @codelipenghui Thanks! After have a look at `PersistentStickyKeyDispatcherMultipleConsumers.java`. I think none of the three selector strategies are suitable for my situation. Cause

[GitHub] [pulsar] linlinnn commented on a change in pull request #10529: Fix partitioned system topic check bug

2021-05-10 Thread GitBox
linlinnn commented on a change in pull request #10529: URL: https://github.com/apache/pulsar/pull/10529#discussion_r629347344 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/systopic/SystemTopicClient.java ## @@ -168,7 +168,10 @@ } static boolean

[GitHub] [pulsar] jangwind commented on a change in pull request #10326: support truncate topic

2021-05-10 Thread GitBox
jangwind commented on a change in pull request #10326: URL: https://github.com/apache/pulsar/pull/10326#discussion_r629345400 ## File path: managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java ## @@ -2156,6 +2157,14 @@ private void scheduleDe

[GitHub] [pulsar] freeznet commented on pull request #10513: [fix #9640] remove `pulsar-client-admin-api` dependency : `pulsar-client-original`

2021-05-10 Thread GitBox
freeznet commented on pull request #10513: URL: https://github.com/apache/pulsar/pull/10513#issuecomment-836642794 /pulsarbot run-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 t

[GitHub] [pulsar] hangc0276 commented on pull request #10341: [BUG] Catch topic policy not hit exception in handleSubscribe

2021-05-10 Thread GitBox
hangc0276 commented on pull request #10341: URL: https://github.com/apache/pulsar/pull/10341#issuecomment-836629513 > @hangc0276 Can you address Matteo's comment? @sijie Ok, i will address it. -- This is an automated message from the Apache Git Service. To respond to the message, p

[GitHub] [pulsar] hangc0276 opened a new pull request #10529: Fix partitioned system topic check bug

2021-05-10 Thread GitBox
hangc0276 opened a new pull request #10529: URL: https://github.com/apache/pulsar/pull/10529 ### Motivation When checking a partitioned topic whether a system topic, it will always be `false`. The check logic is. ```Java static boolean isSystemTopic(TopicName topicName) {

[GitHub] [pulsar] abhilashmandaliya commented on pull request #10527: cleaned some code in GenericJsonRecord

2021-05-10 Thread GitBox
abhilashmandaliya commented on pull request #10527: URL: https://github.com/apache/pulsar/pull/10527#issuecomment-836569004 /pulsarbot run-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 t

[GitHub] [pulsar] 315157973 opened a new pull request #10528: Make failPendingMessages called from within the ProducerImpl object mutex

2021-05-10 Thread GitBox
315157973 opened a new pull request #10528: URL: https://github.com/apache/pulsar/pull/10528 ### Motivation `failPendingMessages()` will traverse the `pendingMessages` queue and this operation is not atomic. `failPendingMessages()` should be called from within the `ProducerImpl`

[GitHub] [pulsar] MarvinCai commented on pull request #10401: [CLI] Add support for setting time based limit on backlog quota with CLI.

2021-05-10 Thread GitBox
MarvinCai commented on pull request #10401: URL: https://github.com/apache/pulsar/pull/10401#issuecomment-836564272 /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 t

svn commit: r47605 - /dev/pulsar/pulsar-2.7.2-candidate-1/ /release/pulsar/pulsar-2.7.2/

2021-05-10 Thread penghui
Author: penghui Date: Mon May 10 09:44:51 2021 New Revision: 47605 Log: release 2.7.2 Added: release/pulsar/pulsar-2.7.2/ - copied from r47604, dev/pulsar/pulsar-2.7.2-candidate-1/ Removed: dev/pulsar/pulsar-2.7.2-candidate-1/

[pulsar] annotated tag v2.7.2 updated (7bf14b5 -> 289f894)

2021-05-10 Thread eolivelli
This is an automated email from the ASF dual-hosted git repository. eolivelli pushed a change to annotated tag v2.7.2 in repository https://gitbox.apache.org/repos/asf/pulsar.git. *** WARNING: tag v2.7.2 was modified! *** from 7bf14b5 (commit) to 289f894 (tag) tagging 7bf14b5ac049d

[pulsar] branch master updated (d39e5e4 -> 4d2d66d)

2021-05-10 Thread lhotari
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 d39e5e4 Fix the inconsistency of AdvertisedAddress (#10312) add 4d2d66d Update "sample" tenant on standalone

[GitHub] [pulsar] lhotari merged pull request #10486: Update "sample" tenant on standalone to stop using old property/cluster/namespace naming convention.

2021-05-10 Thread GitBox
lhotari merged pull request #10486: URL: https://github.com/apache/pulsar/pull/10486 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, pleas

[GitHub] [pulsar] abhilashmandaliya commented on pull request #10527: cleaned some code in GenericJsonRecord

2021-05-10 Thread GitBox
abhilashmandaliya commented on pull request #10527: URL: https://github.com/apache/pulsar/pull/10527#issuecomment-836462785 /pulsarbot run-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 t

[GitHub] [pulsar] congbobo184 edited a comment on pull request #10525: [Transaction] Fix transaction buffer delete marker problem.

2021-05-10 Thread GitBox
congbobo184 edited a comment on pull request #10525: URL: https://github.com/apache/pulsar/pull/10525#issuecomment-836376781 @eolivelli I have reproduced it. After fix it broker will not log this error again. Just added the test, please review again. thanks! -- This is an automated messa

[GitHub] [pulsar] congbobo184 commented on pull request #10525: [Transaction] Fix transaction buffer delete marker problem.

2021-05-10 Thread GitBox
congbobo184 commented on pull request #10525: URL: https://github.com/apache/pulsar/pull/10525#issuecomment-836376781 @eolivelli I have reproduced it and fix it broker will not log this error again. Just added the test, please review again. thanks! -- This is an automated message from th

[GitHub] [pulsar] Hanfee commented on issue #10514: pulsar-io-hdfs connect hdfs error

2021-05-10 Thread GitBox
Hanfee commented on issue #10514: URL: https://github.com/apache/pulsar/issues/10514#issuecomment-836374584 I replace core-site.xml and hdfs-site.xml resolve this problem, but I find a new problem hdfs2 connectors/pulsar-io-hdfs2-2.7.1.nar lack hadoop-lzo-0.4.21U2.jar ``` 16:

[GitHub] [pulsar] linlinnn edited a comment on issue #10522: Leader election seems elect in endless loop

2021-05-10 Thread GitBox
linlinnn edited a comment on issue #10522: URL: https://github.com/apache/pulsar/issues/10522#issuecomment-836110170 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For que

[GitHub] [pulsar] linlinnn edited a comment on issue #10522: Leader election seems elect in endless loop

2021-05-10 Thread GitBox
linlinnn edited a comment on issue #10522: URL: https://github.com/apache/pulsar/issues/10522#issuecomment-836110170 This issue caused by mockZookeeper, because all brokers share the same mockZookeeper and same `SessionId` ```java if (res.getStat().isCreatedBySelf()) { // same `Sessi

[pulsar] branch master updated (2953914 -> d39e5e4)

2021-05-10 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 2953914 Fix log about LeaderElection (#10521) add d39e5e4 Fix the inconsistency of AdvertisedAddress (#10312)

[GitHub] [pulsar] codelipenghui merged pull request #10312: Fix the inconsistency of AdvertisedAddress

2021-05-10 Thread GitBox
codelipenghui merged pull request #10312: URL: https://github.com/apache/pulsar/pull/10312 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service,

[GitHub] [pulsar] linlinnn edited a comment on pull request #10520: get durable subscription without handling startMessageRollbackDurationSec

2021-05-10 Thread GitBox
linlinnn edited a comment on pull request #10520: URL: https://github.com/apache/pulsar/pull/10520#issuecomment-836318900 > Can you please add a test case? @eolivelli any suggestion about this, `MockManagedLedger` do nothing. -- This is an automated message from the Apache Git

[GitHub] [pulsar] linlinnn commented on pull request #10520: get durable subscription without handling startMessageRollbackDurationSec

2021-05-10 Thread GitBox
linlinnn commented on pull request #10520: URL: https://github.com/apache/pulsar/pull/10520#issuecomment-836318900 > Can you please add a test case? @eolivelli any suggestion about this, `MockManagedLedger` do nothing. -- This is an automated message from the Apache Git Service. To

[GitHub] [pulsar] abhilashmandaliya commented on pull request #10527: cleaned some code in GenericJsonRecord

2021-05-10 Thread GitBox
abhilashmandaliya commented on pull request #10527: URL: https://github.com/apache/pulsar/pull/10527#issuecomment-836286590 @eolivelli @lhotari PTAL -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [pulsar] abhilashmandaliya opened a new pull request #10527: cleaned some code in GenericJsonRecord

2021-05-10 Thread GitBox
abhilashmandaliya opened a new pull request #10527: URL: https://github.com/apache/pulsar/pull/10527 The do-while loop was executed only once so removed the loop and optimized an inner for-loop to find binaryValue ### Motivation IDE warning ### Modifications Simp