laurent-chriqui opened a new issue #3926: Add option to delete counter in
python functions state
URL: https://github.com/apache/pulsar/issues/3926
**Is your feature request related to a problem? Please describe.**
It is possible to create a counter in a python pulsar functions using
chairmank commented on issue #3715: Pulsar functions worker fails to initialize
URL: https://github.com/apache/pulsar/issues/3715#issuecomment-477584106
I see this problem only when triggering offload to tiered storage:
```
14:13:53.419 [bookkeeper-ml-workers-OrderedExecutor-2-0]
jiazhai opened a new pull request #3924: [Pulsar IO]: Add a source connector
for debezium postgres
URL: https://github.com/apache/pulsar/pull/3924
This PR try to add a source connector for debezium postgres.
changes:
- add debezium postges project;
- add DebeziumSource, and
chairmank edited a comment on issue #3715: Pulsar functions worker fails to
initialize
URL: https://github.com/apache/pulsar/issues/3715#issuecomment-477584106
I see this problem only when triggering offload to tiered storage:
```
14:13:53.419
laurent-chriqui opened a new pull request #3930: [Issue 3926][functions] Add
delete counter in python functions state_context
URL: https://github.com/apache/pulsar/pull/3930
Fixes #3926
### Motivation
Add possibility to delete a counter from a python function
###
codelipenghui opened a new pull request #3923: Fix comments of schema
compatibility strategy.
URL: https://github.com/apache/pulsar/pull/3923
### Motivation
Fix comments of schema compatibility strategy.
### Modifications
Change comment of
congbobo184 commented on a change in pull request #3876: Add the multi version
schema support
URL: https://github.com/apache/pulsar/pull/3876#discussion_r269873516
##
File path:
pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java
##
@@ -83,6
srkukarni merged pull request #3909: Using Auto Consume consumer on a topic
that doesn't have a schema doesn't work
URL: https://github.com/apache/pulsar/pull/3909
This is an automated message from the Apache Git Service.
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 70cc682 Using Auto Consume consumer on a
rdhabalia commented on issue #3881: [pulsar-broker] add valid-readPosition
check before setting readPosition at cursor
URL: https://github.com/apache/pulsar/pull/3881#issuecomment-477724757
rerun java8 tests
rerun integration tests
rdhabalia removed a comment on issue #3881: [pulsar-broker] add
valid-readPosition check before setting readPosition at cursor
URL: https://github.com/apache/pulsar/pull/3881#issuecomment-475772960
rerun java8 tests
rerun integration tests
rdhabalia removed a comment on issue #3921: clean-up unnecessary public from
interface
URL: https://github.com/apache/pulsar/pull/3921#issuecomment-477724342
rerun cpp tests
This is an automated message from the Apache Git
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 4a739e5 fix jcloud shaded in IDEA (#3912)
merlimat merged pull request #3929: [3928][tiered-storage] Include
java-xmlbuilder in tiered-storage-jcloud NAR
URL: https://github.com/apache/pulsar/pull/3929
This is an automated message from the Apache Git Service.
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 625649f Include java-xmlbuilder in
merlimat closed issue #3928: Ledger offload to tiered storage fails with
NoClassDefFoundError: com/jamesmurty/utils/XMLBuilder
URL: https://github.com/apache/pulsar/issues/3928
This is an automated message from the Apache
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 0487804 Support Kafka's
rdhabalia commented on issue #3921: clean-up unnecessary public from interface
URL: https://github.com/apache/pulsar/pull/3921#issuecomment-477724342
rerun cpp tests
This is an automated message from the Apache Git Service.
devinbost opened a new issue #3931: How to determine what a namespace contains
URL: https://github.com/apache/pulsar/issues/3931
How do we determine what objects still exist in our namespace? We are
deleting everything we can find, but we're missing something; and, it's not
clear what
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 012b818 [pulsar-broker] Fix: Deserialization
merlimat merged pull request #3912: [tiered-storage] fix jcloud-shaded version
to build in IDEA
URL: https://github.com/apache/pulsar/pull/3912
This is an automated message from the Apache Git Service.
To respond to the
merlimat merged pull request #3918: [pulsar-broker] Fix: Deserialization
failing for ZkIsolatedBookieEnsemblePlacementPolicy
URL: https://github.com/apache/pulsar/pull/3918
This is an automated message from the Apache Git
merlimat commented on a change in pull request #3912: [tiered-storage] fix
jcloud-shaded version to build in IDEA
URL: https://github.com/apache/pulsar/pull/3912#discussion_r270184644
##
File path: tiered-storage/pom.xml
##
@@ -32,6 +32,11 @@
tiered-storage-parent
rdhabalia commented on issue #3919: [pulsar-broker] zk-isolation placement
policy should make sure isolation group bookies must not be excluded
URL: https://github.com/apache/pulsar/pull/3919#issuecomment-477758896
rerun cpp tests
merlimat closed issue #3908: Pulsar source/sink creation fails when using JSON
config values
URL: https://github.com/apache/pulsar/issues/3908
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.
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 ee395ca Fix source/sink creation to use JSON
merlimat closed issue #1090: Allow to configure all options when using Kafka
wrapper
URL: https://github.com/apache/pulsar/issues/1090
This is an automated message from the Apache Git Service.
To respond to the message,
merlimat merged pull request #3922: [Issue 3908] [pulsar-client-tool] Fix
source/sink creation to use JSON config values
URL: https://github.com/apache/pulsar/pull/3922
This is an automated message from the Apache Git
merlimat merged pull request #3911: Support Kafka's
ConsumerConfig.INTERCEPTOR_CLASSES_CONFIG in PulsarKafkaConsumer.
URL: https://github.com/apache/pulsar/pull/3911
This is an automated message from the Apache Git Service.
chairmank edited a comment on issue #3715: Pulsar functions worker fails to
initialize
URL: https://github.com/apache/pulsar/issues/3715#issuecomment-477584106
I see this problem only when triggering offload to tiered storage:
```
14:13:53.419
sijie commented on issue #3909: Using Auto Consume consumer on a topic that
doesn't have a schema doesn't work
URL: https://github.com/apache/pulsar/pull/3909#issuecomment-477670665
I think if there is no topic, it should fail immediately since auto consume
requires topic exists first.
jerrypeng merged pull request #3874: [ISSUE 3763] - Implementing Function
authorization
URL: https://github.com/apache/pulsar/pull/3874
This is an automated message from the Apache Git Service.
To respond to the message,
ivankelly commented on a change in pull request #3923: Fix comments of schema
compatibility strategy.
URL: https://github.com/apache/pulsar/pull/3923#discussion_r270049400
##
File path:
jerrypeng commented on issue #3909: Using Auto Consume consumer on a topic that
doesn't have a schema doesn't work
URL: https://github.com/apache/pulsar/pull/3909#issuecomment-477669334
@sijie @srkukarni should we have a discussion on what the correct behavior
of auto consume consumer
srkukarni commented on issue #3865: Classloader choice for validating
Source/Sink
URL: https://github.com/apache/pulsar/pull/3865#issuecomment-477824333
run java8 tests
This is an automated message from the Apache Git
srkukarni merged pull request #3865: Classloader choice for validating
Source/Sink
URL: https://github.com/apache/pulsar/pull/3865
This is an automated message from the Apache Git Service.
To respond to the message, please
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 f3095d8 Classloader choice for validating
jiazhai opened a new issue #3925: Meet schema error while using debezium source.
URL: https://github.com/apache/pulsar/issues/3925
**Describe the bug**
If a debezium source connector stop and start again. the internal
PulsarSink's schema type is changed.
In PulsarSink.open(), the
chairmank opened a new issue #3928: Ledger offload to tiered storage fails with
NoClassDefFoundError: com/jamesmurty/utils/XMLBuilder
URL: https://github.com/apache/pulsar/issues/3928
We see this stacktrace on brokers when we trigger offload to tiered storage:
```
13:35:26.044
chairmank opened a new pull request #3929: [3928][tiered-storage] Include
java-xmlbuilder in tiered-storage-jcloud NAR
URL: https://github.com/apache/pulsar/pull/3929
In the POM file for tiered-storage-jcloud, the dependency on
com.jamesmurty.utils/java-xmlbuilder was marked with test
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-client-node.git
The following commit(s) were added to refs/heads/master by this push:
new 0dccd84 Support authentication
srkukarni commented on issue #3865: Classloader choice for validating
Source/Sink
URL: https://github.com/apache/pulsar/pull/3865#issuecomment-477841423
run java8 tests
This is an automated message from the Apache Git
ConcurrencyPractitioner commented on a change in pull request #3848:
[Issue-2122] [pulsar-client] Adding configuration for backoff strategy
URL: https://github.com/apache/pulsar/pull/3848#discussion_r270262854
##
File path:
ConcurrencyPractitioner commented on a change in pull request #3848:
[Issue-2122] [pulsar-client] Adding configuration for backoff strategy
URL: https://github.com/apache/pulsar/pull/3848#discussion_r270262854
##
File path:
sijie opened a new issue #3935: unload an non-existent topic returns 500
URL: https://github.com/apache/pulsar/issues/3935
**Describe the bug**
unload an non-existent topic returns 500
```
$ bin/pulsar-admin topics unload persistent://public/default/non-existent
jerrypeng commented on a change in pull request #3932: Cleanup logic in
JavaInstanceRunnable close method
URL: https://github.com/apache/pulsar/pull/3932#discussion_r270201841
##
File path:
rdhabalia commented on issue #3919: [pulsar-broker] zk-isolation placement
policy should make sure isolation group bookies must not be excluded
URL: https://github.com/apache/pulsar/pull/3919#issuecomment-477798283
rerun cpp tests
rdhabalia commented on issue #3933: [pulsar-broker] Introduce tenant based
bookie isolation
URL: https://github.com/apache/pulsar/pull/3933#issuecomment-477798209
rerun java8 tests
This is an automated message from the
sijie commented on issue #3715: Pulsar functions worker fails to initialize
URL: https://github.com/apache/pulsar/issues/3715#issuecomment-477804457
@chairmank I think your problem is related to #3913 when offloader attempts
to offload an empty ledger.
srkukarni commented on a change in pull request #3932: Cleanup logic in
JavaInstanceRunnable close method
URL: https://github.com/apache/pulsar/pull/3932#discussion_r270212004
##
File path:
jerrypeng opened a new pull request #3934: fix submit function via url
URL: https://github.com/apache/pulsar/pull/3934
### Motivation
Submitting a function in which the function package is a url is broker right
now. If a user is submitting a function with a url package, he or she
merlimat commented on issue #3868: [Issue 3867] Provide the description of
sink/source command for better usage
URL: https://github.com/apache/pulsar/pull/3868#issuecomment-477815320
run java8 tests
This is an automated
rdhabalia opened a new pull request #3933: [pulsar-broker] Introduce tenant
based bookie isolation
URL: https://github.com/apache/pulsar/pull/3933
### Motivation
Right now, broker has capability to set bookie isolation at broker level.
Using which we can make broker to write into
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 c11c48f clean-up unnecessary public from
merlimat merged pull request #3921: clean-up unnecessary public from interface
URL: https://github.com/apache/pulsar/pull/3921
This is an automated message from the Apache Git Service.
To respond to the message, please log
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 5740699 Cleanup logic in
srkukarni commented on issue #3865: Classloader choice for validating
Source/Sink
URL: https://github.com/apache/pulsar/pull/3865#issuecomment-477808278
run java8 tests
This is an automated message from the Apache Git
sijie merged pull request #3868: [Issue 3867] Provide the description of
sink/source command for better usage
URL: https://github.com/apache/pulsar/pull/3868
This is an automated message from the Apache Git Service.
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.git
The following commit(s) were added to refs/heads/master by this push:
new 07030e3 [Issue 3867] Provide the description of
jiazhai commented on issue #3927: Added information about generate key location
for jwt.
URL: https://github.com/apache/pulsar/pull/3927#issuecomment-477872772
@skyrocknroll Thanks for the fix. would you please also update [version
sijie closed issue #3867: Provide the description of sink/source command for
better usage
URL: https://github.com/apache/pulsar/issues/3867
This is an automated message from the Apache Git Service.
To respond to the
sijie commented on issue #3793: Update connector download URL
URL: https://github.com/apache/pulsar/pull/3793#issuecomment-477870827
I have verified the replacement happens correctly.
we can go ahead on merging this first.
sijie commented on a change in pull request #3793: Update connector download URL
URL: https://github.com/apache/pulsar/pull/3793#discussion_r270280618
##
File path: site2/website/scripts/replace.js
##
@@ -32,6 +32,8 @@ function binaryReleaseUrl(version) {
function
sijie commented on issue #3915: (WIP) [PIP28][PROXY] Pulsar Proxy Gateway
Improvement
URL: https://github.com/apache/pulsar/pull/3915#issuecomment-477871227
@foreversunyao I prepended `(WIP)` in the caption. feel free to remove it
when it is ready for reviews.
jiazhai commented on issue #3930: [Issue 3926][functions] Add delete counter in
python functions state_context
URL: https://github.com/apache/pulsar/pull/3930#issuecomment-477871153
run java8 tests
This is an automated
sijie commented on a change in pull request #3934: fix submit function via url
URL: https://github.com/apache/pulsar/pull/3934#discussion_r270278672
##
File path:
pulsar-broker/src/test/java/org/apache/pulsar/io/PulsarFunctionE2ETest.java
##
@@ -385,8 +385,7 @@ public
sijie commented on issue #3848: [Issue-2122] [pulsar-client] Adding
configuration for backoff strategy
URL: https://github.com/apache/pulsar/pull/3848#issuecomment-477866972
@merlimat can you reply to @ConcurrencyPractitioner 's comment?
sijie commented on issue #3931: How to determine what a namespace contains
URL: https://github.com/apache/pulsar/issues/3931#issuecomment-477871586
@devinbost
you can use `bin/pulsar-admin topics list /` to list all
the topics within a namespace. if there are topics, you are
sijie commented on a change in pull request #3848: [Issue-2122] [pulsar-client]
Adding configuration for backoff strategy
URL: https://github.com/apache/pulsar/pull/3848#discussion_r269868281
##
File path:
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java
congbobo184 commented on issue #3876: Add the multi version schema support
URL: https://github.com/apache/pulsar/pull/3876#issuecomment-477468694
> @congbobo184 overall looks much clearer now. However I think we still need
to push the reader and writer schema logic to `StructSchema`.
sijie commented on issue #3876: Add the multi version schema support
URL: https://github.com/apache/pulsar/pull/3876#issuecomment-477469650
> I think we need to push the reader and writer, not reader schema and
writer schema.
@congbobo184 yes
congbobo184 commented on a change in pull request #3876: Add the multi version
schema support
URL: https://github.com/apache/pulsar/pull/3876#discussion_r269873516
##
File path:
pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java
##
@@ -83,6
sijie commented on issue #3909: Using Auto Consume consumer on a topic that
doesn't have a schema doesn't work
URL: https://github.com/apache/pulsar/pull/3909#issuecomment-477471543
@srkukarni @jerrypeng I think current change is the easiest way to fix the
integration tests. alternatively
congbobo184 commented on a change in pull request #3876: Add the multi version
schema support
URL: https://github.com/apache/pulsar/pull/3876#discussion_r269873516
##
File path:
pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java
##
@@ -83,6
sijie commented on issue #3921: clean-up unnecessary public from interface
URL: https://github.com/apache/pulsar/pull/3921#issuecomment-477471832
run cpp tests
This is an automated message from the Apache Git Service.
To
sijie commented on issue #3922: [Issue 3908] [pulsar-client-tool] Fix
source/sink creation to use JSON config values
URL: https://github.com/apache/pulsar/pull/3922#issuecomment-477471778
run java8 tests
This is an automated
congbobo184 commented on a change in pull request #3876: Add the multi version
schema support
URL: https://github.com/apache/pulsar/pull/3876#discussion_r269873516
##
File path:
pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java
##
@@ -83,6
sijie merged pull request #3920: Fix: unloading namespace logging
URL: https://github.com/apache/pulsar/pull/3920
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
congbobo184 commented on a change in pull request #3876: Add the multi version
schema support
URL: https://github.com/apache/pulsar/pull/3876#discussion_r269873516
##
File path:
pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java
##
@@ -83,6
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.git
The following commit(s) were added to refs/heads/master by this push:
new a4a53c7 Fix: unloading namespace logging
sijie closed issue #3831: [schema] support timestamp/date schema
URL: https://github.com/apache/pulsar/issues/3831
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
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.git
The following commit(s) were added to refs/heads/master by this push:
new bda6a9c [pulsar-client] add Date/Time/Timestamp
sijie merged pull request #3856: [pulsar-client] add Date/Time/Timestamp schema
URL: https://github.com/apache/pulsar/pull/3856
This is an automated message from the Apache Git Service.
To respond to the message, please log
sijie merged pull request #3907: Misc Function fixes
URL: https://github.com/apache/pulsar/pull/3907
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
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.git
The following commit(s) were added to refs/heads/master by this push:
new 19dd255 Misc Function fixes:- (#3907)
19dd255
congbobo184 commented on a change in pull request #3876: Add the multi version
schema support
URL: https://github.com/apache/pulsar/pull/3876#discussion_r269874938
##
File path:
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/AvroSchema.java
##
@@ -30,26
86 matches
Mail list logo
