skyrocknroll commented on issue #6605:
URL: https://github.com/apache/pulsar/issues/6605#issuecomment-636280454
@ckdarby it is using prestodb
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.
sanjeevrk 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 e451be3 Moved ClassLoading and Reflections
srkukarni merged pull request #7103:
URL: https://github.com/apache/pulsar/pull/7103
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
oneum72 commented on issue #7047:
URL: https://github.com/apache/pulsar/issues/7047#issuecomment-636277944
> What does `pulsar-admin` interface mean here? Do you mean `pulsar-admin`
CLI tool or pulsar-manager?
Edited the previous repy!
oneum72 edited a comment on issue #7047:
URL: https://github.com/apache/pulsar/issues/7047#issuecomment-635442506
@sijie I have tested as you suggested and there is only one error:
```
15:34:08.471 [main-EventThread] WARN
org.apache.pulsar.proxy.server.util.ZookeeperCacheLoader -
ckdarby commented on issue #7058:
URL: https://github.com/apache/pulsar/issues/7058#issuecomment-636275897
> Should be big enough to hold a significant portion of the index database
@sijie This is what is stored in
/pulsar/data/bookkeeper/ledgers/current/locations correct?
ckdarby edited a comment on issue #7058:
URL: https://github.com/apache/pulsar/issues/7058#issuecomment-636275897
> Should be big enough to hold a significant portion of the index database
@sijie This is what is stored in
/pulsar/data/bookkeeper/ledgers/current/locations correct?
wuzhanpeng opened a new pull request #7111:
URL: https://github.com/apache/pulsar/pull/7111
### Motivation
This pull request implements a monitor thread to check if the current topic
ledger meets the constraint of `managedLedgerMaxLedgerRolloverTimeMinutes` and
trigger a rollover to
This is an automated email from the ASF dual-hosted git repository.
sijie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-helm-chart.git
The following commit(s) were added to refs/heads/master by this push:
new 5914996 Removing reference to
sijie commented on issue #7047:
URL: https://github.com/apache/pulsar/issues/7047#issuecomment-636246936
What does `pulsar-admin` interface mean here? Do you mean `pulsar-admin` CLI
tool or pulsar-manager?
This is an
merlimat commented on pull request #7101:
URL: https://github.com/apache/pulsar/pull/7101#issuecomment-636246260
> need to change current build scripts to build python38 for manylinx
Sure, but that's out of the context of this PR.
merlimat opened a new pull request #7110:
URL: https://github.com/apache/pulsar/pull/7110
### Motivation
PersistentTopic registers a listener for updates to the policies of
the topic.
PersistentTopic#initializeDispatchRateLimiterIfNeeded runs under a
lock on the
merlimat opened a new pull request #7109:
URL: https://github.com/apache/pulsar/pull/7109
### Motivation
The `MockZooKeeper#failNow` instructs the `MockZooKeeper` instance to fail
the next call to zookeeper. In a multithreaded system with many things
accessing zookeeper, using
merlimat opened a new pull request #7108:
URL: https://github.com/apache/pulsar/pull/7108
Note: this is based on top of #6791, #7104, #7105, #7106 and #7107. Once
these are merged, I'll rebase here. For the sake of this review, check commit
3afe89bea
### Motivation
When
sijie commented on issue #7055:
URL: https://github.com/apache/pulsar/issues/7055#issuecomment-636242082
@Saswatibhoi I don't think this is a clear way to *decommission* bookies.
At which step the error was encountered?
yusufaytas commented on issue #3153:
URL: https://github.com/apache/pulsar/issues/3153#issuecomment-636241309
I've figured this out. I had to set `stateStorageServiceUrl` to make
functions work. Nevertheless, it might be a good idea to supply local
BookKeeper URI to functions by default.
merlimat commented on a change in pull request #7093:
URL: https://github.com/apache/pulsar/pull/7093#discussion_r432787179
##
File path:
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractTopic.java
##
@@ -423,5 +428,13 @@ public long getBytesOutCounter() {
sijie commented on issue #7058:
URL: https://github.com/apache/pulsar/issues/7058#issuecomment-636240424
@ckdarby
for reading from backlog:
1) tune rocksdb block cache size for holding the entry index in memory.
```
# Size of RocksDB block-cache. For best
sijie commented on issue #7089:
URL: https://github.com/apache/pulsar/issues/7089#issuecomment-636239030
So you need to adjust the settings based on your machine type.
This is an automated message from the Apache Git
sijie commented on issue #7089:
URL: https://github.com/apache/pulsar/issues/7089#issuecomment-636238611
@ckdarby This seems to be a known issue related to jetty. You need to
adjust the number threads to be more than cpu cores.
merlimat opened a new pull request #7107:
URL: https://github.com/apache/pulsar/pull/7107
Note: this is based on top of #6791, #7104, #7105 and #7106. Once these are
merged, I'll rebase here. For the sake of this review, check commit 0ce0177dc
### Motivation
When messages are
sijie commented on issue #3153:
URL: https://github.com/apache/pulsar/issues/3153#issuecomment-636237051
@yusufaytas for standalone, the state is enabled by default. How did you run
the standalone?
This is an automated
aahmed-se commented on pull request #7101:
URL: https://github.com/apache/pulsar/pull/7101#issuecomment-636235443
need to change current build scripts to build python38 for manylinx
This is an automated message from the
merlimat opened a new pull request #7106:
URL: https://github.com/apache/pulsar/pull/7106
Note: this is based on top of #6791, #7104 and #7105. Once these are merged,
I'll rebase here. For the sake of this review, check commit ad2e39be36
### Motivation
Fixes: #6554
merlimat opened a new pull request #7105:
URL: https://github.com/apache/pulsar/pull/7105
Note: this is based on top of #6791 & #7104. Once these are merged, I'll
rebase here. For the sake of this review, check commit 23d6dcb7
### Motivation
If one consumer is slowly
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 09fc647 In HTTP authentication, throw
merlimat merged pull request #7100:
URL: https://github.com/apache/pulsar/pull/7100
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
merlimat opened a new pull request #7104:
URL: https://github.com/apache/pulsar/pull/7104
Note: this is based on top of #6791. Once that is merged, I'll rebase here.
For the sake of this review, check commit a3a9c91f
### Motivation
Instead of grouping the messages by same
nicolo-paganin commented on pull request #6895:
URL: https://github.com/apache/pulsar/pull/6895#issuecomment-636221587
@codelipenghui any ideas on how to fix the CI?
This is an automated message from the Apache Git Service.
sijie commented on pull request #7101:
URL: https://github.com/apache/pulsar/pull/7101#issuecomment-636215896
/pulsarbot run-failure-checks
This is an automated message from the Apache Git Service.
To respond to the message,
srkukarni opened a new pull request #7103:
URL: https://github.com/apache/pulsar/pull/7103
*(If this PR fixes a github issue, please add `Fixes #`.)*
Fixes #
*(or if this PR is one task of a github issue, please add `Master Issue:
#` to link to the master issue.)*
merlimat merged pull request #7087:
URL: https://github.com/apache/pulsar/pull/7087
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
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 c281d95 update asynchttpclient verison (#7087)
merlimat closed issue #7084:
URL: https://github.com/apache/pulsar/issues/7084
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
This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 44d14a5 Cap the dispatcher batch size in bytes to fixed max (#7097)
add 8d7139e add postgresql to supervisord
merlimat merged pull request #7086:
URL: https://github.com/apache/pulsar/pull/7086
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
nicolo-paganin removed a comment on pull request #6895:
URL: https://github.com/apache/pulsar/pull/6895#issuecomment-636197068
/pulsarbot run-failure-checks
This is an automated message from the Apache Git Service.
To
nicolo-paganin commented on pull request #6895:
URL: https://github.com/apache/pulsar/pull/6895#issuecomment-636197068
/pulsarbot run-failure-checks
This is an automated message from the Apache Git Service.
To respond to the
nicolo-paganin removed a comment on pull request #6895:
URL: https://github.com/apache/pulsar/pull/6895#issuecomment-636196630
/pulsarbot run-failure-checks
This is an automated message from the Apache Git Service.
To
nicolo-paganin commented on pull request #6895:
URL: https://github.com/apache/pulsar/pull/6895#issuecomment-636196630
/pulsarbot run-failure-checks
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.
sijie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 0eaea25 [Python] Enforce type of values set on record field (#7098)
add 44d14a5 Cap the dispatcher batch size
This is an automated email from the ASF dual-hosted git repository.
sijie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 9f9478e Allow BasicEndToEndTest to run multiple times locally (#7069)
add 0eaea25 [Python] Enforce type of
This is an automated email from the ASF dual-hosted git repository.
sijie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 3989c98 Regex consumer shared queue should be set to configured value
(#7062)
add 9f9478e Allow
This is an automated email from the ASF dual-hosted git repository.
sijie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 3989c98 Regex consumer shared queue should be set to configured value
(#7062)
add 9f9478e Allow
This is an automated email from the ASF dual-hosted git repository.
sijie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 9f9478e Allow BasicEndToEndTest to run multiple times locally (#7069)
add 0eaea25 [Python] Enforce type of
merlimat opened a new pull request #7102:
URL: https://github.com/apache/pulsar/pull/7102
### Motivation
There seems to be a race when mocking the compactor in
MockedPulsarServiceBaseTest which yields errors like:
```
Caused by: java.lang.ClassCastException:
merlimat commented on pull request #6791:
URL: https://github.com/apache/pulsar/pull/6791#issuecomment-636163229
@sijie PTAL again
This is an automated message from the Apache Git Service.
To respond to the message, please
sijie commented on pull request #6992:
URL: https://github.com/apache/pulsar/pull/6992#issuecomment-636162540
/puslarbot run-failure-checks
This is an automated message from the Apache Git Service.
To respond to the message,
sijie commented on pull request #7014:
URL: https://github.com/apache/pulsar/pull/7014#issuecomment-636161510
/pulsarbot run-failure-checks
This is an automated message from the Apache Git Service.
To respond to the message,
merlimat opened a new pull request #7101:
URL: https://github.com/apache/pulsar/pull/7101
### Motivation
Added Docker files and scripts to build packages for Alpine Linux, both APK
and wheel files that don't depend on glibc.
sijie commented on pull request #7086:
URL: https://github.com/apache/pulsar/pull/7086#issuecomment-636159360
/pulsarbot run-failure-checks
This is an automated message from the Apache Git Service.
To respond to the message,
merlimat opened a new pull request #7100:
URL: https://github.com/apache/pulsar/pull/7100
### Motivation
During HTTP authentication, we try to authenticate against all the
configured AuthN providers. If there's an exception in the auth operation, we
should bubble back the original
sijie commented on pull request #7093:
URL: https://github.com/apache/pulsar/pull/7093#issuecomment-636155641
/pulsarbot run-failure-checks
This is an automated message from the Apache Git Service.
To respond to the message,
merlimat opened a new pull request #7099:
URL: https://github.com/apache/pulsar/pull/7099
### Motivation
Negative acknowledgement runs in the background on a consumer and
triggers redelivery of messages. The tests verify a that messages do
indeed get redelivered, and which
sijie merged pull request #7097:
URL: https://github.com/apache/pulsar/pull/7097
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
sijie merged pull request #7098:
URL: https://github.com/apache/pulsar/pull/7098
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
sijie merged pull request #7069:
URL: https://github.com/apache/pulsar/pull/7069
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
gotopanic commented on issue #6962:
URL: https://github.com/apache/pulsar/issues/6962#issuecomment-636134433
Sorry, I missed your reply. Yes I will gladly contribute, but I will need
some guidance as this would be my first contribution... Would you be the
committer who will review as per
ckdarby commented on issue #6605:
URL: https://github.com/apache/pulsar/issues/6605#issuecomment-636122242
I was under the impression that Pulsar is using PrestoSQL and not PrestoDB.
Is it using PrestoSQL or PrestoDB? Can we clarify the docs to be more
explicit?
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 3989c98 Regex consumer shared queue should be
merlimat merged pull request #7062:
URL: https://github.com/apache/pulsar/pull/7062
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
merlimat opened a new pull request #7098:
URL: https://github.com/apache/pulsar/pull/7098
### Motivation
In Python client, we're not validating the type of the values set on the
records when using schema.
This means that, through a simple mistake, an application can end up
merlimat opened a new pull request #7097:
URL: https://github.com/apache/pulsar/pull/7097
### Motivation
Applying the new functionality introduced in #7060 to hint to the underlying
cursor the max size that we are comfortable to read at this time.
codelipenghui commented on pull request #6052:
URL: https://github.com/apache/pulsar/pull/6052#issuecomment-636029103
/pulsarbot run-failure-checks
This is an automated message from the Apache Git Service.
To respond to the
aloyszhang commented on a change in pull request #7078:
URL: https://github.com/apache/pulsar/pull/7078#discussion_r432435725
##
File path:
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PublishRateLimiter.java
##
@@ -66,6 +69,83 @@
* @param clusterName
massakam opened a new pull request #7096:
URL: https://github.com/apache/pulsar/pull/7096
Master Issue: #7041
### Motivation
When a leader broker is restarted, some producers for topics owned by that
broker may not be reopened on the new broker. When this happens, message
yusufaytas edited a comment on issue #3153:
URL: https://github.com/apache/pulsar/issues/3153#issuecomment-635925591
I've just downloaded pulsar 2.5.2 and running it in standalone mode. I get
`java.lang.IllegalStateException: State is not enabled.` when running functions.
yusufaytas commented on issue #3153:
URL: https://github.com/apache/pulsar/issues/3153#issuecomment-635925591
I've just downloaded pulsar and running it in standalone mode. I get
`java.lang.IllegalStateException: State is not enabled.` when running functions.
trexinc commented on issue #7095:
URL: https://github.com/apache/pulsar/issues/7095#issuecomment-635883555
Seems that this feature is not overly complicated to implement, just add a
config to function to enable key based batching, and then create producers
according to this config.
315157973 commented on issue #7046:
URL: https://github.com/apache/pulsar/issues/7046#issuecomment-635882310
Please assign it to me @sijie
This is an automated message from the Apache Git Service.
To respond to the message,
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 8b7b60e Allow managed cursor to specify max read batch in bytes
(#7060)
add 4883e1b fix consumer fetch
codelipenghui merged pull request #6719:
URL: https://github.com/apache/pulsar/pull/6719
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
codelipenghui commented on pull request #6719:
URL: https://github.com/apache/pulsar/pull/6719#issuecomment-635876524
### Motivation
when consumer send fetch request to broker server, it contains fetch message
number telling the server how many messges should be pushed to consumer
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 21a142a Remove the bundle load data info before performing the split
(#7065)
add 8b7b60e Allow managed
codelipenghui merged pull request #7060:
URL: https://github.com/apache/pulsar/pull/7060
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.
penghui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 5cb32e9 Remove double @Test annotations (#7063)
add 21a142a Remove the bundle load data info before
codelipenghui merged pull request #7065:
URL: https://github.com/apache/pulsar/pull/7065
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.
penghui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 5c06756 Brokers must advertize on localhost to avoid problems
creating client (#7067)
add 5cb32e9 Remove
codelipenghui merged pull request #7063:
URL: https://github.com/apache/pulsar/pull/7063
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
trexinc opened a new issue #7095:
URL: https://github.com/apache/pulsar/issues/7095
There is a publisher that publishes with keys (and key based batching
enabled) to a certain partitioned topic.
A routing function (see below) reads from this topic and forwards the
messages to a
codelipenghui commented on pull request #6052:
URL: https://github.com/apache/pulsar/pull/6052#issuecomment-635845264
/pulsarbot run-failure-checks
This is an automated message from the Apache Git Service.
To respond to the
Huanli-Meng closed pull request #7053:
URL: https://github.com/apache/pulsar/pull/7053
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
315157973 opened a new pull request #7094:
URL: https://github.com/apache/pulsar/pull/7094
Fixes #7032
### Motivation
Source data flow:
Custom Source-> Function-> Pulsar producer-> Broker
Sink data flow:
Broker-> Pulsar consumer-> Function-> Custom
zhanghaou commented on pull request #7091:
URL: https://github.com/apache/pulsar/pull/7091#issuecomment-635813272
/pulsarbot run-failure-checks
This is an automated message from the Apache Git Service.
To respond to the
zhanghaou commented on pull request #7093:
URL: https://github.com/apache/pulsar/pull/7093#issuecomment-635801398
/pulsarbot run-failure-checks
This is an automated message from the Apache Git Service.
To respond to the
keithnull edited a comment on issue #177:
URL:
https://github.com/apache/pulsar-client-go/issues/177#issuecomment-632457978
@wolfstudy
Hi, I'm interested in this issue. But I can't fully understand why multi
pulsar cluster addresses are needed for a client.
In Pulsar's
keithnull commented on issue #264:
URL:
https://github.com/apache/pulsar-client-go/issues/264#issuecomment-635790148
@wolfstudy
I've checked all error-related logs, which can be classified as:
1. `.WithError(someErr).Error("some string")`
1. `.WithError(someErr).Error()`
zhanghaou opened a new pull request #7093:
URL: https://github.com/apache/pulsar/pull/7093
**Motivation**
The brokerDeleteInactiveTopicsEnabled parameter is effect to all Topics, but
in some cases like topic created by protocol handler, we need keep some topics
not be deleted even if
88 matches
Mail list logo
