merlimat closed pull request #2572: Shorten the timeout value of C++ ZTS client
URL: https://github.com/apache/incubator-pulsar/pull/2572
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is
david-streamlio opened a new pull request #2615: Azure offloader
URL: https://github.com/apache/incubator-pulsar/pull/2615
### Motivation
Added Azure offloader for Pulsar Tiered Storage
### Modifications
Refactored the tiered storage configuration tree to make it easier
jiazhai opened a new pull request #2614: Debezium: add PulsarDatabaseHistory
for debezium
URL: https://github.com/apache/incubator-pulsar/pull/2614
### Motivation
add PulsarDatabaseHistory for debezium
### Modifications
add PulsarDatabaseHistory for debezium and test
merlimat closed pull request #2608: Enforce boost-python was found by CMake
URL: https://github.com/apache/incubator-pulsar/pull/2608
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a
rdhabalia opened a new pull request #2613: Avoid scheduling heartbeat function
if owner-worker not available
URL: https://github.com/apache/incubator-pulsar/pull/2613
### Motivation
Handle heartbeat function if owner-worker is not available.
### Modifications
Function
jiazhai commented on issue #2590: Issue #2584: unacked message is not
redelivered on time
URL: https://github.com/apache/incubator-pulsar/pull/2590#issuecomment-422994297
seems some ut need change, will look into it later.
jiazhai removed a comment on issue #2606: Add support for dead letter topics
for java functions
URL: https://github.com/apache/incubator-pulsar/pull/2606#issuecomment-422994155
Seems some ut need change, will look into it later.
jiazhai commented on issue #2606: Add support for dead letter topics for java
functions
URL: https://github.com/apache/incubator-pulsar/pull/2606#issuecomment-422994155
Seems some ut need change, will look into it later.
jerrypeng commented on issue #2605: implement topic routing on a per record
basis
URL: https://github.com/apache/incubator-pulsar/pull/2605#issuecomment-422990454
rerun integration tests
This is an automated message from the
jerrypeng commented on a change in pull request #2593: Add support for running
python functions with wheel file
URL: https://github.com/apache/incubator-pulsar/pull/2593#discussion_r218982622
##
File path:
sijie closed issue #2007: Implement an easier way to get the topic information
from consumed message
URL: https://github.com/apache/incubator-pulsar/issues/2007
This is an automated message from the Apache Git Service.
To
sijie commented on issue #2007: Implement an easier way to get the topic
information from consumed message
URL:
https://github.com/apache/incubator-pulsar/issues/2007#issuecomment-422970257
This has been implemented and merged.
sijie commented on issue #2009: Unable to get messages from non-persistent
topics
URL:
https://github.com/apache/incubator-pulsar/issues/2009#issuecomment-422970028
This is being fixed by #2025, will be included in the upcoming release.
dsambandam commented on issue #2576: Pulsar client consume command fails with
java.lang.IllegalArgumentException: port out of range:-1
URL:
https://github.com/apache/incubator-pulsar/issues/2576#issuecomment-422969989
@sijie I don't have any special character in my service urls. In that
sijie commented on issue #2013: Unable to consume messages from a partition
URL:
https://github.com/apache/incubator-pulsar/issues/2013#issuecomment-422969773
I think this is a duplicate of #2431 , closing this one.
This is
sijie closed issue #2013: Unable to consume messages from a partition
URL: https://github.com/apache/incubator-pulsar/issues/2013
This is an automated message from the Apache Git Service.
To respond to the message, please
sijie commented on issue #2033: Python pulsar-client lacks multi-topic support
URL:
https://github.com/apache/incubator-pulsar/issues/2033#issuecomment-422969364
multi-topic and regex subscription support is added to python. it is
actually released in 2.1.1 and will also be in 2.2.0
sijie closed issue #2033: Python pulsar-client lacks multi-topic support
URL: https://github.com/apache/incubator-pulsar/issues/2033
This is an automated message from the Apache Git Service.
To respond to the message, please
sijie commented on issue #2574: Timeout message not get redeliver in
TopicsConsumer when use message listener
URL:
https://github.com/apache/incubator-pulsar/issues/2574#issuecomment-422968685
This is fixed by #2583
This
sijie commented on issue #2576: Pulsar client consume command fails with
java.lang.IllegalArgumentException: port out of range:-1
URL:
https://github.com/apache/incubator-pulsar/issues/2576#issuecomment-422968544
@dsambandam I think the exception is quite similar ast the issue reported
sijie closed issue #2574: Timeout message not get redeliver in TopicsConsumer
when use message listener
URL: https://github.com/apache/incubator-pulsar/issues/2574
This is an automated message from the Apache Git Service.
sijie commented on issue #1016: Support bytes message key
URL:
https://github.com/apache/incubator-pulsar/issues/1016#issuecomment-422966131
this is being implemented in #2612
This is an automated message from the Apache
srkukarni commented on issue #2593: Add support for running python functions
with wheel file
URL: https://github.com/apache/incubator-pulsar/pull/2593#issuecomment-422965788
run java8 tests
This is an automated message from
aahmed-se commented on issue #2504: Add Presto Sql Test
URL: https://github.com/apache/incubator-pulsar/pull/2504#issuecomment-422963308
retest this please
This is an automated message from the Apache Git Service.
To respond
aahmed-se commented on issue #2578: Add support for schema extraction from a jar
URL: https://github.com/apache/incubator-pulsar/pull/2578#issuecomment-422963330
retest this please
This is an automated message from the Apache
aahmed-se commented on issue #2611: Make dockerUtils use container name for
test exec
URL: https://github.com/apache/incubator-pulsar/pull/2611#issuecomment-422962898
the log configure does not, the DockerUtils changes fixes that issue.
sijie commented on issue #2611: Make dockerUtils use container name for test
exec
URL: https://github.com/apache/incubator-pulsar/pull/2611#issuecomment-422954395
> we are reducing the number of log line elements since we are not looking
at multithreaded server components but single
sijie commented on a change in pull request #2612: Allow byte[] keys for
messages (#1016)
URL: https://github.com/apache/incubator-pulsar/pull/2612#discussion_r218956364
##
File path:
pulsar-client/src/main/java/org/apache/pulsar/client/api/TypedMessageBuilder.java
##
@@
srkukarni commented on issue #2593: Add support for running python functions
with wheel file
URL: https://github.com/apache/incubator-pulsar/pull/2593#issuecomment-422942590
run java8 tests
This is an automated message from
kramasamy commented on a change in pull request #2609: Initial commit for a go
based pulsar cli.
URL: https://github.com/apache/incubator-pulsar/pull/2609#discussion_r218946596
##
File path: cli/admin/clusters.go
##
@@ -0,0 +1,62 @@
+//
Review comment:
since the
srkukarni commented on issue #2593: Add support for running python functions
with wheel file
URL: https://github.com/apache/incubator-pulsar/pull/2593#issuecomment-422936960
run java8 tests
This is an automated message from
ivankelly opened a new pull request #2612: Allow byte[] keys for messages
(#1016)
URL: https://github.com/apache/incubator-pulsar/pull/2612
Sometimes it can be useful to send something more complex than a
string as the key of the message. However, early on Pulsar chose to
make String
sijie opened a new issue #1016: Support bytes message key
URL: https://github.com/apache/incubator-pulsar/issues/1016
Currently the message key is string. It would be good to make the key also
be bytes backed. so people can configure a SerDe on the message key, which
message router can
aahmed-se commented on issue #2611: Make dockerUtils use container name for
test exec
URL: https://github.com/apache/incubator-pulsar/pull/2611#issuecomment-422930867
We are overriding that , we are reducing the number of log line elements
since we are not looking at multithreaded server
sijie commented on a change in pull request #2611: Make dockerUtils use
container name for test exec
URL: https://github.com/apache/incubator-pulsar/pull/2611#discussion_r218935033
##
File path: tests/integration/src/test/resources/log4j2.xml
##
@@ -0,0 +1,33 @@
+
aahmed-se opened a new pull request #2611: Make dockerUtils use container name
for test exec
URL: https://github.com/apache/incubator-pulsar/pull/2611
Provides easier to follow logs also we reduce the log output via custom log
config for the itegration tests.
srkukarni commented on issue #2593: Add support for running python functions
with wheel file
URL: https://github.com/apache/incubator-pulsar/pull/2593#issuecomment-422919735
run java8 tests
This is an automated message from
jerrypeng commented on issue #2605: implement topic routing on a per record
basis
URL: https://github.com/apache/incubator-pulsar/pull/2605#issuecomment-422915657
@rdhabalia I will write some tests
This is an automated
aahmed-se commented on issue #2607: Add default value for test image org tag
URL: https://github.com/apache/incubator-pulsar/pull/2607#issuecomment-422913594
you are right will close this
This is an automated message from the
aahmed-se closed pull request #2607: Add default value for test image org tag
URL: https://github.com/apache/incubator-pulsar/pull/2607
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a
merlimat opened a new pull request #2610: Prepare website for future releases
without '-incubating' suffix
URL: https://github.com/apache/incubator-pulsar/pull/2610
### Motivation
The `-incubating` suffix is a property of a particular release. We shouldn't
add it to all releases in
sijie commented on issue #2609: Initial commit for a go based pulsar cli.
URL: https://github.com/apache/incubator-pulsar/pull/2609#issuecomment-422902467
@cckellogg ideally yes. but `mvn license:format` should already attaching
the license headers.
cckellogg commented on issue #2609: Initial commit for a go based pulsar cli.
URL: https://github.com/apache/incubator-pulsar/pull/2609#issuecomment-422901452
@sijie does a license need to be added to the source files only? Do the mod
files and readme need a license too?
jerrypeng removed a comment on issue #2605: implement topic routing on a per
record basis
URL: https://github.com/apache/incubator-pulsar/pull/2605#issuecomment-422897646
rerun tests please
This is an automated message from
jerrypeng commented on issue #2605: implement topic routing on a per record
basis
URL: https://github.com/apache/incubator-pulsar/pull/2605#issuecomment-422898762
rerun integration tests
This is an automated message from
srkukarni commented on issue #2593: Add support for running python functions
with wheel file
URL: https://github.com/apache/incubator-pulsar/pull/2593#issuecomment-422898627
run cpp tests
This is an automated message from
jerrypeng commented on issue #2605: implement topic routing on a per record
basis
URL: https://github.com/apache/incubator-pulsar/pull/2605#issuecomment-422897997
rerun java8 tests
This is an automated message from the
jerrypeng commented on issue #2605: implement topic routing on a per record
basis
URL: https://github.com/apache/incubator-pulsar/pull/2605#issuecomment-422897646
rerun tests please
This is an automated message from the
jerrypeng commented on issue #2605: implement topic routing on a per record
basis
URL: https://github.com/apache/incubator-pulsar/pull/2605#issuecomment-422897747
rerun cpp tests
This is an automated message from the Apache
jerrypeng removed a comment on issue #2605: implement topic routing on a per
record basis
URL: https://github.com/apache/incubator-pulsar/pull/2605#issuecomment-422897519
rerun tests
This is an automated message from the
jerrypeng commented on issue #2605: implement topic routing on a per record
basis
URL: https://github.com/apache/incubator-pulsar/pull/2605#issuecomment-422897519
rerun tests
This is an automated message from the Apache Git
jerrypeng commented on a change in pull request #2605: implement topic routing
on a per record basis
URL: https://github.com/apache/incubator-pulsar/pull/2605#discussion_r218900232
##
File path:
srkukarni commented on issue #2593: Add support for running python functions
with wheel file
URL: https://github.com/apache/incubator-pulsar/pull/2593#issuecomment-422895917
run cpp tests
This is an automated message from
jerrypeng commented on a change in pull request #2605: implement topic routing
on a per record basis
URL: https://github.com/apache/incubator-pulsar/pull/2605#discussion_r218900232
##
File path:
jerrypeng edited a comment on issue #2605: implement topic routing on a per
record basis
URL: https://github.com/apache/incubator-pulsar/pull/2605#issuecomment-422892352
@rdhabalia a usecase we have is will a source for ingesting data from
databases. Users will often want to just specify
jerrypeng commented on issue #2605: implement topic routing on a per record
basis
URL: https://github.com/apache/incubator-pulsar/pull/2605#issuecomment-422892352
@rdhabalia a use we have is will a source for ingesting data from databases.
Users will often want to just specify schema or
merlimat closed pull request #2580: [Python] Consolidated duplicated
subscribe_*() methods into a single one
URL: https://github.com/apache/incubator-pulsar/pull/2580
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the
sijie commented on issue #2585: [tests] Make BrokerClientIntegrationTest
testing behavior deterministic
URL: https://github.com/apache/incubator-pulsar/pull/2585#issuecomment-422882486
run java8 tests
This is an automated
sijie commented on issue #2590: Issue #2584: unacked message is not redelivered
on time
URL: https://github.com/apache/incubator-pulsar/pull/2590#issuecomment-422882307
run java8 tests
This is an automated message from the
sijie closed pull request #2594: Correcting SQL getting started title
URL: https://github.com/apache/incubator-pulsar/pull/2594
This is an automated message from the Apache Git Service.
To respond to the message, please log
srkukarni closed pull request #2606: Add support for dead letter topics for
java functions
URL: https://github.com/apache/incubator-pulsar/pull/2606
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
sijie commented on issue #2606: Add support for dead letter topics for java
functions
URL: https://github.com/apache/incubator-pulsar/pull/2606#issuecomment-422843947
run java8 tests
This is an automated message from the
sijie commented on issue #2594: Correcting SQL getting started title
URL: https://github.com/apache/incubator-pulsar/pull/2594#issuecomment-422843819
run cpp tests
This is an automated message from the Apache Git Service.
To
massakam removed a comment on issue #2572: Shorten the timeout value of C++ ZTS
client
URL: https://github.com/apache/incubator-pulsar/pull/2572#issuecomment-422764843
rerun integration tests
This is an automated message
massakam commented on issue #2572: Shorten the timeout value of C++ ZTS client
URL: https://github.com/apache/incubator-pulsar/pull/2572#issuecomment-422816585
rerun integration tests
This is an automated message from the
srkukarni commented on issue #2593: Add support for running python functions
with wheel file
URL: https://github.com/apache/incubator-pulsar/pull/2593#issuecomment-422807920
run cpp tests
This is an automated message from
srkukarni commented on issue #2606: Add support for dead letter topics for java
functions
URL: https://github.com/apache/incubator-pulsar/pull/2606#issuecomment-422807563
run java8 tests
This is an automated message from the
massakam commented on issue #2572: Shorten the timeout value of C++ ZTS client
URL: https://github.com/apache/incubator-pulsar/pull/2572#issuecomment-422764843
rerun integration tests
This is an automated message from the
sijie commented on issue #2543: Add ServiceUrlProvider and add method
forceCloseConnection in PulsarC…
URL: https://github.com/apache/incubator-pulsar/pull/2543#issuecomment-422704688
@codelipenghui yeah, thank you so much for your contribution! look forward
to your contribution about
sijie commented on issue #2585: [tests] Make BrokerClientIntegrationTest
testing behavior deterministic
URL: https://github.com/apache/incubator-pulsar/pull/2585#issuecomment-422678548
run java8 tests
This is an automated
massakam commented on issue #2572: Shorten the timeout value of C++ ZTS client
URL: https://github.com/apache/incubator-pulsar/pull/2572#issuecomment-422675074
rerun java8 tests
This is an automated message from the Apache
sijie closed pull request #2586: fixing/improving logging for function instance
URL: https://github.com/apache/incubator-pulsar/pull/2586
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is
jerrypeng commented on issue #2586: fixing/improving logging for function
instance
URL: https://github.com/apache/incubator-pulsar/pull/2586#issuecomment-422669848
rerun integration tests
This is an automated message from
srkukarni commented on issue #2606: Add support for dead letter topics for java
functions
URL: https://github.com/apache/incubator-pulsar/pull/2606#issuecomment-422666303
run java8 tests
This is an automated message from the
cckellogg opened a new pull request #2609: Initial commit for a go based pulsar
cli.
URL: https://github.com/apache/incubator-pulsar/pull/2609
### Motivation
Initial patch to create a pulsar go based admin cli. This will help improve
the cli performance, make the user experience
merlimat opened a new pull request #2608: Enforce boost-python was found by
CMake
URL: https://github.com/apache/incubator-pulsar/pull/2608
### Motivation
Ensure the CMake preparation fails when the correct Boost-Python library is
not found. With the current behavior, the build
sijie closed pull request #2604: [tests] remove
PersistentQueueE2ETest#testConsumersWithDifferentPermits
URL: https://github.com/apache/incubator-pulsar/pull/2604
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake
rdhabalia closed pull request #2503: add auto ack and timeout configurable
URL: https://github.com/apache/incubator-pulsar/pull/2503
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a
srkukarni commented on issue #2586: fixing/improving logging for function
instance
URL: https://github.com/apache/incubator-pulsar/pull/2586#issuecomment-422638074
run java8 tests
This is an automated message from the Apache
rdhabalia commented on a change in pull request #2605: implement topic routing
on a per record basis
URL: https://github.com/apache/incubator-pulsar/pull/2605#discussion_r218635418
##
File path:
jerrypeng commented on issue #2605: implement topic routing on a per record
basis
URL: https://github.com/apache/incubator-pulsar/pull/2605#issuecomment-422597240
@rdhabalia thanks for the review. I have addressed your comments
rdhabalia commented on issue #2503: add auto ack and timeout configurable
URL: https://github.com/apache/incubator-pulsar/pull/2503#issuecomment-422590573
rerun java8 tests
This is an automated message from the Apache Git
rdhabalia removed a comment on issue #2503: add auto ack and timeout
configurable
URL: https://github.com/apache/incubator-pulsar/pull/2503#issuecomment-422590512
retest java8 tests
This is an automated message from the
rdhabalia commented on issue #2503: add auto ack and timeout configurable
URL: https://github.com/apache/incubator-pulsar/pull/2503#issuecomment-422590512
retest java8 tests
This is an automated message from the Apache Git
aahmed-se commented on issue #2578: Add support for schema extraction from a jar
URL: https://github.com/apache/incubator-pulsar/pull/2578#issuecomment-422589407
Added Test cases
This is an automated message from the Apache
srkukarni commented on issue #2577: fix behavior of JSONSchema for derived
classes
URL: https://github.com/apache/incubator-pulsar/pull/2577#issuecomment-422578421
run java8 tests
This is an automated message from the Apache
rdhabalia closed pull request #2549: [Function] avoid creating assignment
snapshot and publish individual assignment msg
URL: https://github.com/apache/incubator-pulsar/pull/2549
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed
aahmed-se opened a new pull request #2607: Add default value for test image org
tag
URL: https://github.com/apache/incubator-pulsar/pull/2607
This adds a default value for the image tag in cases it's not speicifed
This is an
srkukarni opened a new pull request #2606: Add support for dead letter topics
for java functions
URL: https://github.com/apache/incubator-pulsar/pull/2606
### Motivation
This pr adds two options for running java functions
1. Ability to control the number of times a message is
sijie closed pull request #2587: [tests] improve connector related integration
tests
URL: https://github.com/apache/incubator-pulsar/pull/2587
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As
sijie closed pull request #2597: [build] Fix docker organization parameter
URL: https://github.com/apache/incubator-pulsar/pull/2597
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a
rdhabalia commented on a change in pull request #2605: implement topic routing
on a per record basis
URL: https://github.com/apache/incubator-pulsar/pull/2605#discussion_r218606849
##
File path:
jerrypeng commented on a change in pull request #2605: implement topic routing
on a per record basis
URL: https://github.com/apache/incubator-pulsar/pull/2605#discussion_r218606215
##
File path:
jerrypeng commented on a change in pull request #2605: implement topic routing
on a per record basis
URL: https://github.com/apache/incubator-pulsar/pull/2605#discussion_r218606215
##
File path:
rdhabalia commented on a change in pull request #2605: implement topic routing
on a per record basis
URL: https://github.com/apache/incubator-pulsar/pull/2605#discussion_r218603818
##
File path:
rdhabalia commented on a change in pull request #2605: implement topic routing
on a per record basis
URL: https://github.com/apache/incubator-pulsar/pull/2605#discussion_r218603562
##
File path:
rdhabalia commented on a change in pull request #2605: implement topic routing
on a per record basis
URL: https://github.com/apache/incubator-pulsar/pull/2605#discussion_r218605442
##
File path:
rdhabalia commented on a change in pull request #2605: implement topic routing
on a per record basis
URL: https://github.com/apache/incubator-pulsar/pull/2605#discussion_r218604865
##
File path:
jerrypeng opened a new pull request #2605: implement topic routing on a per
record basis
URL: https://github.com/apache/incubator-pulsar/pull/2605
### Motivation
There are use cases that the destination topic for a message cannot be
determined at source submission time. This
srkukarni commented on issue #2597: [build] Fix docker organization parameter
URL: https://github.com/apache/incubator-pulsar/pull/2597#issuecomment-422562254
run integration tests
This is an automated message from the Apache
1 - 100 of 10673 matches
Mail list logo