eolivelli commented on a change in pull request #10723:
URL: https://github.com/apache/pulsar/pull/10723#discussion_r641899014
##
File path:
pulsar-broker/src/test/java/org/apache/pulsar/client/api/NonDurableSubscriptionTest.java
##
@@ -126,4 +129,63 @@ public void testDeleteI
congbobo184 opened a new pull request #10741:
URL: https://github.com/apache/pulsar/pull/10741
## Motivation
Now when broke enable transaction, every ack will check the next position is
transaction marker position whether or not. When don't have transaction ack, we
don' need to check th
This is an automated email from the ASF dual-hosted git repository.
mmerli 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 9eb173a On multi-topic consumer, we shouldn't k
merlimat merged pull request #10708:
URL: https://github.com/apache/pulsar/pull/10708
--
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, plea
BewareMyPower commented on issue #10721:
URL: https://github.com/apache/pulsar/issues/10721#issuecomment-850765134
First I noticed there's a line in your log:
```
2021-05-28 19:57:42.121 WARN [140473932080896[] PartitionedProducerImpl:369
| Failed to getPartitionMetadata: TimeOut
This is an automated email from the ASF dual-hosted git repository.
penghui 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 10ed501 Support using AutoProduceBytesSchema a
codelipenghui merged pull request #10716:
URL: https://github.com/apache/pulsar/pull/10716
--
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,
adrianog edited a comment on issue #5554:
URL: https://github.com/apache/pulsar/issues/5554#issuecomment-847428306
Workaround I'm using - uses pulsarctl and it's faster:
`pulsar-admin persistent list public/NAMESPACE | sed 's/^"\(.*\)"$/pulsarctl
topics delete --non-partitioned --force \
adrianog edited a comment on issue #5554:
URL: https://github.com/apache/pulsar/issues/5554#issuecomment-847428306
Workaround I'm using:
`pulsar-admin persistent list public/NAMESPACE | sed 's/^"\(.*\)"$/pulsarctl
topics delete --non-partitioned --force \1/' | bash`
--
This is an auto
zzzming opened a new pull request #528:
URL: https://github.com/apache/pulsar-client-go/pull/528
Fixes #513
fix batch size limit validation
### Motivation
The current batch size validation is incorrect.
### Modifications
The batch max size should be used t
zbentley edited a comment on issue #10721:
URL: https://github.com/apache/pulsar/issues/10721#issuecomment-850644626
I ran the below code:
```
#!/usr/bin/env python
import sys
import pulsar
def get_producer():
return pulsar.Client(
'pulsar://p
zbentley commented on issue #10721:
URL: https://github.com/apache/pulsar/issues/10721#issuecomment-850644626
I ran the below code:
```
#!/usr/bin/env python
import sys
import tempfile
import pulsar
log_config = tempfile.NamedTemporaryFile(delete=False)
l
This is an automated email from the ASF dual-hosted git repository.
eolivelli 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 0237580 [ML] Fix solution for preventing rac
eolivelli merged pull request #10740:
URL: https://github.com/apache/pulsar/pull/10740
--
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
eolivelli commented on pull request #10735:
URL: https://github.com/apache/pulsar/pull/10735#issuecomment-850622381
Yes, dependency management differs from Maven version to Maven version.
We should also probably upgrade to latest maven 3.8.1.
--
This is an automated message fr
lhotari commented on pull request #10735:
URL: https://github.com/apache/pulsar/pull/10735#issuecomment-850613949
Building with JDK 11 vs. JDK 8 makes a difference.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
sijie commented on pull request #10685:
URL: https://github.com/apache/pulsar/pull/10685#issuecomment-850596875
@RobertIndie Can you take a look at @cckellogg 's latest comments?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHu
lhotari edited a comment on issue #10738:
URL: https://github.com/apache/pulsar/issues/10738#issuecomment-850576082
@merlimat There are 3 LEAK logs with
`-Dio.netty.leakDetection.targetRecords=30` setting in this file:
https://gist.github.com/lhotari/956f5732d4f4fd96750bd4e679e312ee
lhotari commented on issue #10738:
URL: https://github.com/apache/pulsar/issues/10738#issuecomment-850576082
@merlimat There's a 3 LEAK logs with
`-Dio.netty.leakDetection.targetRecords=30` setting in this file:
https://gist.github.com/lhotari/956f5732d4f4fd96750bd4e679e312ee
The
This is an automated email from the ASF dual-hosted git repository.
mmerli 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 6a17b3e [ML] Cancel scheduled tasks as the firs
merlimat merged pull request #10739:
URL: https://github.com/apache/pulsar/pull/10739
--
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, plea
lhotari commented on issue #10738:
URL: https://github.com/apache/pulsar/issues/10738#issuecomment-850568301
Here are some leak logs from master branch:
https://gist.github.com/lhotari/eac5370c2a436a6da9f5ac33ba1a82ba
The logs got a bit truncated since I was capturing the logs with
lhotari commented on issue #10738:
URL: https://github.com/apache/pulsar/issues/10738#issuecomment-850556047
> Also, is it happening on master as well?
Yes the behavior can be seen on master branch.
--
This is an automated message from the Apache Git Service.
To respond to the mes
lhotari commented on issue #10738:
URL: https://github.com/apache/pulsar/issues/10738#issuecomment-850553856
> @lhotari Can you add `-Dio.netty.leakDetection.targetRecords=30` to JVM to
get all the places that touched these buffers?
thanks for the tip. I added this to the repro case
merlimat edited a comment on issue #10738:
URL: https://github.com/apache/pulsar/issues/10738#issuecomment-850543108
Also, is it happening on master as well?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
merlimat commented on issue #10738:
URL: https://github.com/apache/pulsar/issues/10738#issuecomment-850543108
Also, is it also happening on master?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go
merlimat commented on issue #10738:
URL: https://github.com/apache/pulsar/issues/10738#issuecomment-850542931
@lhotari Can you add `-Dio.netty.leakDetection.targetRecords=30` to JVM to
get all the places that touched these buffers?
--
This is an automated message from the Apache Git Serv
merlimat commented on pull request #10735:
URL: https://github.com/apache/pulsar/pull/10735#issuecomment-850517189
I think it's probably related to differences in the maven version that
resolve a slightly different set of dependencies.
--
This is an automated message from the Apache Git
maraiskruger1980 commented on pull request #518:
URL: https://github.com/apache/pulsar-client-go/pull/518#issuecomment-850507204
> @maraiskruger1980 Great Job., thanks for your contribution. Can you add
some test cases for this?
>
> It seems that we can also add similar functions to
sijie commented on pull request #10635:
URL: https://github.com/apache/pulsar/pull/10635#issuecomment-850506936
@wolfstudy Can you review this?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to th
sijie commented on pull request #10735:
URL: https://github.com/apache/pulsar/pull/10735#issuecomment-850505100
@codelipenghui any ideas?
```
jetty-alpn-java-client-9.4.27.v20200227.jar unaccounted for in
lib/presto/LICENSE
It looks like there are issues with the LICENSE/NO
lhotari opened a new pull request #10740:
URL: https://github.com/apache/pulsar/pull/10740
### Motivation
It seem that the solution for preventing race conditions between timeout and
completion doesn't work.
The repro case in #10738 can reproduce this problem.
### Modificat
yangl removed a comment on pull request #10715:
URL: https://github.com/apache/pulsar/pull/10715#issuecomment-850291245
/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
yangl commented on pull request #10715:
URL: https://github.com/apache/pulsar/pull/10715#issuecomment-850478349
/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 the
lhotari opened a new pull request #10739:
URL: https://github.com/apache/pulsar/pull/10739
### Motivation
- when `currentLedger` was null, the scheduled tasks `timeoutTask` and
`checkLedgerRollTask` wouldn't get cancelled in `asyncClose` method.
### Modifications
- move
lhotari commented on issue #10738:
URL: https://github.com/apache/pulsar/issues/10738#issuecomment-850459367
> So basically when we do ledger rollover we are not releasing something,
correct?
@eolivelli perhaps. the repro case does a lot of ledger rollovers since
`managedLedgerMaxEn
eolivelli commented on issue #10738:
URL: https://github.com/apache/pulsar/issues/10738#issuecomment-850440010
So basically when we do ledger rollover we are not releasing something,
correct?
--
This is an automated message from the Apache Git Service.
To respond to the message, please l
marksilcox commented on issue #10733:
URL: https://github.com/apache/pulsar/issues/10733#issuecomment-850436909
Solved it - there was a second `brokerClientAuthenticationPlugin` in the
`broker.conf` under the bookie auth section, renamed to
`bookkeeperClientAuthenticationPlugin` and everyt
marksilcox closed issue #10733:
URL: https://github.com/apache/pulsar/issues/10733
--
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
lhotari commented on issue #6054:
URL: https://github.com/apache/pulsar/issues/6054#issuecomment-850420985
I have reported a separate issue about a direct memory leak, it's #10738 .
It includes a full repro case with a helm deployment that can be used to
reproduce the issue in minikube (re
lhotari commented on issue #10738:
URL: https://github.com/apache/pulsar/issues/10738#issuecomment-850417614
example of some Netty leak logs
https://gist.github.com/lhotari/21bb7dcdd06dfa8369576ac8c837319e
created with command `kubectl -n pulsar-testenv logs -f
pod/pulsar-testenv-deploy
marksilcox commented on issue #10733:
URL: https://github.com/apache/pulsar/issues/10733#issuecomment-850400409
Removing the "token:" prefix or using file did not work.
I enabled debug logging and it appears that not all the requests that are
called as part of `bin/pulsar-admin topic
lhotari opened a new issue #10738:
URL: https://github.com/apache/pulsar/issues/10738
**Describe the bug**
Broker (tested with 2.6.3, 2.7.2 and master branch) runs out of direct
memory under certain conditions.
The Netty leak detector shows leaks (leak detector enabled with
`-Dp
linlinnn commented on pull request #10731:
URL: https://github.com/apache/pulsar/pull/10731#issuecomment-850299348
> In this way, `userConfigMap ` will be null if user does not set user
config. We need to confirm if this will cause Conext.getUserConfigMap() return
null. In that condition,
yangl removed a comment on pull request #10715:
URL: https://github.com/apache/pulsar/pull/10715#issuecomment-850145489
/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
yangl commented on pull request #10715:
URL: https://github.com/apache/pulsar/pull/10715#issuecomment-850291245
/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 the
wangjialing218 commented on pull request #10731:
URL: https://github.com/apache/pulsar/pull/10731#issuecomment-850290272
In this way, `userConfigMap ` will be null if user does not set user config.
We need to confirm if this will cause Conext.getUserConfigMap() return null. In
that conditi
xuesongxs opened a new issue #10737:
URL: https://github.com/apache/pulsar/issues/10737
Expected behavior
1.How to configure haproxy?
2.Does pulsar broker need to enable the haproxyprotocolenabled flag?
3.Will haproxy exceed maxmessage size = 5242880?
--
This is an automated
Author: lhotari
Date: Fri May 28 09:08:34 2021
New Revision: 47947
Log:
Staging artifacts and signature for Pulsar release 2.6.4
Added:
dev/pulsar/pulsar-2.6.4-candidate-1/
dev/pulsar/pulsar-2.6.4-candidate-1/DEB/
dev/pulsar/pulsar-2.6.4-candidate-1/DEB/Packages.gz (with props)
Added:
dev/pulsar/pulsar-2.6.4-candidate-1/connectors/pulsar-io-elastic-search-2.6.4.nar.asc
==
---
dev/pulsar/pulsar-2.6.4-candidate-1/connectors/pulsar-io-elastic-search-2.6.4.nar.asc
(added)
+++
dev/pulsar/pulsar-2.6
Hanfee opened a new issue #10736:
URL: https://github.com/apache/pulsar/issues/10736
16:58:50.803 [pulsar-client-io-1-2] WARN
org.apache.pulsar.client.impl.ClientCnx - [id: 0x4a31a8e7, L:/127.0.0.1:26060 -
R:localhost/127.0.0.1:6650] Received error from server: Topic does not have
schema
linlinnn commented on a change in pull request #10732:
URL: https://github.com/apache/pulsar/pull/10732#discussion_r641386080
##
File path:
pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/FunctionConfigUtils.java
##
@@ -902,7 +902,7 @@ public static Func
linlinnn commented on a change in pull request #10732:
URL: https://github.com/apache/pulsar/pull/10732#discussion_r641384970
##
File path:
pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/FunctionConfigUtils.java
##
@@ -902,7 +902,7 @@ public static Func
dockerzhang commented on pull request #10728:
URL: https://github.com/apache/pulsar/pull/10728#issuecomment-850262724
/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 t
linlinnn closed pull request #10731:
URL: https://github.com/apache/pulsar/pull/10731
--
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, plea
lhotari edited a comment on issue #10733:
URL: https://github.com/apache/pulsar/issues/10733#issuecomment-850254300
Pulsar JWT token auth in 2.6.3 contains a security vulnerability,
[CVE-2021-22160](https://lists.apache.org/thread.html/r347650d15a3e9c5f58b83e918b6ad6dedc2a63d3eb63da8e6a7be8
lhotari commented on issue #10733:
URL: https://github.com/apache/pulsar/issues/10733#issuecomment-850254300
Pulsar JWT token auth in 2.6.3 contains a security vulnerability,
[CVE-2021-22160](https://lists.apache.org/thread.html/r347650d15a3e9c5f58b83e918b6ad6dedc2a63d3eb63da8e6a7be87e%40%3
codelipenghui opened a new pull request #10735:
URL: https://github.com/apache/pulsar/pull/10735
--
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 se
marcoguest opened a new issue #10734:
URL: https://github.com/apache/pulsar/issues/10734
**Describe the bug**
If a Pulsar C++ consumer subscribes into key-shared mode to a non-persistent
topic and it is too slow to dequeue the incoming messagges, the length limit
for the receiving queue
This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a change to annotated tag v2.6.4-candidate-1
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
*** WARNING: tag v2.6.4-candidate-1 was modified! ***
from 28f141d (commit)
to a3f0b88 (tag)
This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a change to branch branch-2.6
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 67e7e0c Disallow parsing of token with none signature in
authenticateToken (#9172)
add 28f141d Release 2
BewareMyPower commented on a change in pull request #10712:
URL: https://github.com/apache/pulsar/pull/10712#discussion_r641336087
##
File path: pulsar-client-cpp/include/pulsar/SingleFileLoggerFactory.h
##
@@ -0,0 +1,68 @@
+/**
+ * Licensed to the Apache Software Foundation (A
marksilcox opened a new issue #10733:
URL: https://github.com/apache/pulsar/issues/10733
Having further trouble with enabling JWT on v2.6.3. I've configured the
broker and proxy as per the docs. I can connect and send messages from a Java
client. However connecting through pulsar-manager f
wangjialing218 opened a new pull request #10732:
URL: https://github.com/apache/pulsar/pull/10732
### Motivation
Fixes #10720
### Modifications
Update UserConfig only when it's not empty.
### Verifying this change
FunctionConfigUtilsTest.testMergeDifferentU
64 matches
Mail list logo