jerrypeng commented on issue #1897: improving source and sink validation
URL: https://github.com/apache/incubator-pulsar/pull/1897#issuecomment-394060134
retest this please
This is an automated message from the Apache Git Ser
zhaijack commented on a change in pull request #1858: Cpp client: add
readCompacted in consumer config
URL: https://github.com/apache/incubator-pulsar/pull/1858#discussion_r192545502
##
File path: pulsar-client-cpp/tests/ConsumerConfigurationTest.cc
##
@@ -0,0 +1,105 @@
+/
jerrypeng opened a new pull request #1897: improving source and sink validation
URL: https://github.com/apache/incubator-pulsar/pull/1897
- clean up function, sink, source code
- improving source and sink validation
- refactor some code to avoid duplication
--
jerrypeng commented on issue #1897: improving source and sink validation
URL: https://github.com/apache/incubator-pulsar/pull/1897#issuecomment-394043594
@srkukarni please review
This is an automated message from the Apache G
merlimat commented on issue #1764: Pulsar Go client library
URL: https://github.com/apache/incubator-pulsar/pull/1764#issuecomment-394042237
@bruth I fixed the issues in reader (and consumer in latest push)
@sijie PTAL, this should be complete at this point
--
lucperkins commented on issue #1826: [WIP] Pulsar Functions worker configuration
URL: https://github.com/apache/incubator-pulsar/pull/1826#issuecomment-394037238
@aahmed-se Right now it's not clear what's going to happen with the
configuration (`processContainerFactory`, etc.). I think that
srkukarni commented on issue #1896: When fetching from kafka, specify to get
the earliest of messages
URL: https://github.com/apache/incubator-pulsar/pull/1896#issuecomment-394034912
@sijie @jerrypeng
This is an automated me
srkukarni opened a new pull request #1896: When fetching from kafka, specify to
get the earliest of messages
URL: https://github.com/apache/incubator-pulsar/pull/1896
### Motivation
Explain here the context, and why you're making that change.
What is the problem you're trying to s
jai1 commented on issue #1821: Closing client when Proxyconnection is
disconnected
URL: https://github.com/apache/incubator-pulsar/pull/1821#issuecomment-394029833
Ohk - now I understand the confusion
The connection pool is used for lookups and getPartitionMetaData only once
the br
jai1 commented on issue #1821: Closing client when Proxyconnection is
disconnected
URL: https://github.com/apache/incubator-pulsar/pull/1821#issuecomment-394029833
Ohk - now I understand the confusion
The connection pool is used for lookups and getPartitionMetaData only
---
merlimat commented on issue #1821: Closing client when Proxyconnection is
disconnected
URL: https://github.com/apache/incubator-pulsar/pull/1821#issuecomment-394029650
> But we still need one connection pool per proxy connection since the
broker authenticates the client and the proxy if
f
jai1 commented on issue #1821: Closing client when Proxyconnection is
disconnected
URL: https://github.com/apache/incubator-pulsar/pull/1821#issuecomment-394028480
I understand the resource aspect of it and agree that instead of having one
client we can extract the connectionPool part out
merlimat commented on issue #1821: Closing client when Proxyconnection is
disconnected
URL: https://github.com/apache/incubator-pulsar/pull/1821#issuecomment-394026518
@jai1 there are many resources that are created per-client, I don't think
it's a working approach to have 1 client instanc
jai1 commented on issue #1821: Closing client when Proxyconnection is
disconnected
URL: https://github.com/apache/incubator-pulsar/pull/1821#issuecomment-394024643
retest this please
This is an automated message from the Apac
lucperkins commented on issue #1743: ByteBuffer schema
URL: https://github.com/apache/incubator-pulsar/pull/1743#issuecomment-394019753
@merlimat Done. New build underway.
This is an automated message from the Apache Git Servi
merlimat commented on issue #1743: ByteBuffer schema
URL: https://github.com/apache/incubator-pulsar/pull/1743#issuecomment-394014455
@lucperkins The failures might be related to when this PR was applied to a
(broken) master. can you merge or rebase with current master?
---
lucperkins commented on issue #1670: Check for tenant and namespace for
pulsar-admin functions list command
URL: https://github.com/apache/incubator-pulsar/pull/1670#issuecomment-394014294
@aahmed-se This PR may be completely superfluous given recent changes to
Pulsar Functions config vali
lucperkins commented on issue #1743: ByteBuffer schema
URL: https://github.com/apache/incubator-pulsar/pull/1743#issuecomment-394014074
retest this please
This is an automated message from the Apache Git Service.
To respond to
lucperkins commented on issue #1743: ByteBuffer schema
URL: https://github.com/apache/incubator-pulsar/pull/1743#issuecomment-393910604
retest this please
This is an automated message from the Apache Git Service.
To respond to
jai1 commented on a change in pull request #1895: Pulsar proxy configuration
docs
URL: https://github.com/apache/incubator-pulsar/pull/1895#discussion_r192519692
##
File path: site/_data/config/proxy.yaml
##
@@ -0,0 +1,79 @@
+#
+# Licensed to the Apache Software Foundation
jai1 commented on a change in pull request #1895: Pulsar proxy configuration
docs
URL: https://github.com/apache/incubator-pulsar/pull/1895#discussion_r192519837
##
File path: site/_data/config/proxy.yaml
##
@@ -0,0 +1,79 @@
+#
+# Licensed to the Apache Software Foundation
jai1 commented on a change in pull request #1895: Pulsar proxy configuration
docs
URL: https://github.com/apache/incubator-pulsar/pull/1895#discussion_r192519627
##
File path: site/_data/config/proxy.yaml
##
@@ -0,0 +1,79 @@
+#
+# Licensed to the Apache Software Foundation
jai1 commented on issue #1821: Closing client when Proxyconnection is
disconnected
URL: https://github.com/apache/incubator-pulsar/pull/1821#issuecomment-394010983
retest this please
This is an automated message from the Apac
lucperkins commented on issue #1895: Pulsar proxy configuration docs
URL: https://github.com/apache/incubator-pulsar/pull/1895#issuecomment-394010925
@merlimat @aahmed-se This is ready for review
This is an automated message f
lucperkins opened a new pull request #1895: Pulsar proxy configuration docs
URL: https://github.com/apache/incubator-pulsar/pull/1895
There's now a `proxy.conf` file that can be used to configure the Pulsar
proxy. This PR adds those parameters to the docs.
-
This is an automated email from the ASF dual-hosted git repository.
jerrypeng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 7565ece allow users to specify me
lucperkins commented on issue #1791: [WIP] Pulsar Functions windowing
documentation
URL: https://github.com/apache/incubator-pulsar/pull/1791#issuecomment-393988155
@sanjeev @jerrypeng This is not ready for review
This is an
srkukarni commented on issue #1791: [WIP] Pulsar Functions windowing
documentation
URL: https://github.com/apache/incubator-pulsar/pull/1791#issuecomment-393987917
@jerrypeng can you pl review
This is an automated message fro
merlimat opened a new pull request #1894: Removed link to md5 checksums in
download page
URL: https://github.com/apache/incubator-pulsar/pull/1894
### Motivation
The md5 checksum were already deprecated and are not published anymore.
instead, linked to the sha1 and sha512 checksums.
jerrypeng commented on issue #1885: allow users to specify message timeout for
functions
URL: https://github.com/apache/incubator-pulsar/pull/1885#issuecomment-393974414
retest this please
This is an automated message from t
jerrypeng commented on issue #1885: allow users to specify message timeout for
functions
URL: https://github.com/apache/incubator-pulsar/pull/1885#issuecomment-393974312
please retest this
This is an automated message from t
jerrypeng commented on issue #1885: allow users to specify message timeout for
functions
URL: https://github.com/apache/incubator-pulsar/pull/1885#issuecomment-393974312
please retest this
This is an automated message from t
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/incubator-pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new c01c6be S3BackedInputStream seeks wit
merlimat closed pull request #1892: S3BackedInputStream seeks within current
buffer if possible
URL: https://github.com/apache/incubator-pulsar/pull/1892
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 provena
jerrypeng commented on issue #1885: allow users to specify message timeout for
functions
URL: https://github.com/apache/incubator-pulsar/pull/1885#issuecomment-393965758
@srkukarni thanks for the review. I have addressed your comments
-
jerrypeng commented on a change in pull request #1885: allow users to specify
message timeout for functions
URL: https://github.com/apache/incubator-pulsar/pull/1885#discussion_r192474989
##
File path:
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/Puls
lucperkins commented on issue #1760: [WIP] Pulsar Functions resource docs
URL: https://github.com/apache/incubator-pulsar/pull/1760#issuecomment-393964706
@aahmed-se This is ready for review
This is an automated message from t
lucperkins commented on issue #1791: [WIP] Pulsar Functions windowing
documentation
URL: https://github.com/apache/incubator-pulsar/pull/1791#issuecomment-393963107
@aahmed-se I'm not sure what the status of windowing in Pulsar Functions
currently is, so probably best to leave this to Jerr
lucperkins commented on issue #1743: ByteBuffer schema
URL: https://github.com/apache/incubator-pulsar/pull/1743#issuecomment-393963039
@aahmed-se This PR is ready to go once it passes CI (the CI issues appear to
be unrelated to this specific PR).
--
jerrypeng commented on a change in pull request #1885: allow users to specify
message timeout for functions
URL: https://github.com/apache/incubator-pulsar/pull/1885#discussion_r192471378
##
File path: pulsar-functions/proto/src/main/proto/Function.proto
##
@@ -69,6 +69,7
sijie commented on issue #1893: Include functions in pulsar-client Python
package
URL: https://github.com/apache/incubator-pulsar/pull/1893#issuecomment-393961850
@srkukarni ^^
This is an automated message from the Apache Git
jerrypeng commented on a change in pull request #1885: allow users to specify
message timeout for functions
URL: https://github.com/apache/incubator-pulsar/pull/1885#discussion_r192470839
##
File path:
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/Puls
jerrypeng closed pull request #1890: Fixed the filename of the log files in
threaded mode
URL: https://github.com/apache/incubator-pulsar/pull/1890
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:
This is an automated email from the ASF dual-hosted git repository.
jerrypeng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new ae096eb removing allowing users se
This is an automated email from the ASF dual-hosted git repository.
jerrypeng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 3412d9c Fixed the filename of the
jerrypeng closed pull request #1880: removing allowing users set subscription
type
URL: https://github.com/apache/incubator-pulsar/pull/1880
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
merlimat opened a new pull request #1893: Include functions in pulsar-client
Python package
URL: https://github.com/apache/incubator-pulsar/pull/1893
### Motivation
In 2.0 Python `pulsar-client` package, functions py files are not being
included correctly.
-
lucperkins commented on issue #1762: [WIP] Tiered storage documentation
URL: https://github.com/apache/incubator-pulsar/pull/1762#issuecomment-393960581
@aahmed-se I've taken this about as far as I can given that tiered storage
is still under active development. I'd say it'd be best to let
lucperkins commented on issue #1838: Pulsar Go client docs
URL: https://github.com/apache/incubator-pulsar/pull/1838#issuecomment-393960184
@aahmed-se This is ready for review.
This is an automated message from the Apache Git
ivankelly opened a new pull request #1892: S3BackedInputStream seeks within
current buffer if possible
URL: https://github.com/apache/incubator-pulsar/pull/1892
Previously, any time seek was called, the current buffer was
discarded, and the next time read was called, a request was made t
sijie opened a new issue #1891: Remove references to md5 checksums in download
page
URL: https://github.com/apache/incubator-pulsar/issues/1891
According to current ASF suggestions, it is better to stop signing release
with MD5, so we need to drop the links in the download page.
See
This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git
commit 8fce0b0c8b219f137f421c22eefd9850b194fcbf
Author: Matteo Merli
AuthorDate: Thu May 17 16:29:53 2018 -0700
This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git
commit 09a90fe2df047a292a17504f4a4013000a146feb
Author: Matteo Merli
AuthorDate: Wed May 16 11:15:33 2018 -0700
This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git
commit 41a2cadb2dd330834251ac93ffa7b012eb7915fb
Author: Matteo Merli
AuthorDate: Mon May 21 23:02:32 2018 -0700
This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git
commit d83894da5b21081438b3230bb906463d4605151a
Author: Matteo Merli
AuthorDate: Wed May 30 15:50:28 2018 -0700
This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a change to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git.
from 8c1e779 Fixed event time metadata on batched messages (#1882)
new 09a90fe Fix build with boost >
srkukarni commented on a change in pull request #1885: allow users to specify
message timeout for functions
URL: https://github.com/apache/incubator-pulsar/pull/1885#discussion_r192450871
##
File path: pulsar-functions/proto/src/main/proto/Function.proto
##
@@ -69,6 +69,7
srkukarni commented on a change in pull request #1885: allow users to specify
message timeout for functions
URL: https://github.com/apache/incubator-pulsar/pull/1885#discussion_r192450630
##
File path:
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/Puls
srkukarni commented on a change in pull request #1885: allow users to specify
message timeout for functions
URL: https://github.com/apache/incubator-pulsar/pull/1885#discussion_r192450480
##
File path:
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/Puls
sijie commented on issue #1880: removing allowing users set subscription type
URL: https://github.com/apache/incubator-pulsar/pull/1880#issuecomment-393934990
retest this please
This is an automated message from the Apache Git
sijie commented on issue #1864: Increase watch-znode.py connection timeout
URL: https://github.com/apache/incubator-pulsar/pull/1864#issuecomment-393934480
retest this please
This is an automated message from the Apache Git Se
sijie closed pull request #1883: All user supplied arguments have to be
properly typed
URL: https://github.com/apache/incubator-pulsar/pull/1883
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
lucperkins commented on issue #1743: ByteBuffer schema
URL: https://github.com/apache/incubator-pulsar/pull/1743#issuecomment-393910604
retest this please
This is an automated message from the Apache Git Service.
To respond to
merlimat commented on issue #1858: Cpp client: add readCompacted in consumer
config
URL: https://github.com/apache/incubator-pulsar/pull/1858#issuecomment-393908634
@zhaijack As for the others, can you expose the config option on the C
wrapper API as well?
merlimat commented on a change in pull request #1863: Cpp client: add seek
support in consumer for cpp client
URL: https://github.com/apache/incubator-pulsar/pull/1863#discussion_r192423976
##
File path: pulsar-client-cpp/include/pulsar/Consumer.h
##
@@ -211,6 +211,30 @@ c
merlimat commented on a change in pull request #1863: Cpp client: add seek
support in consumer for cpp client
URL: https://github.com/apache/incubator-pulsar/pull/1863#discussion_r192423437
##
File path: pulsar-client-cpp/lib/ConsumerImpl.cc
##
@@ -879,4 +879,45 @@ void Co
merlimat commented on a change in pull request #1863: Cpp client: add seek
support in consumer for cpp client
URL: https://github.com/apache/incubator-pulsar/pull/1863#discussion_r192423976
##
File path: pulsar-client-cpp/include/pulsar/Consumer.h
##
@@ -211,6 +211,30 @@ c
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/incubator-pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 075e872 Make supervisord wait a singl
merlimat closed pull request #1866: Make supervisord wait a single command
URL: https://github.com/apache/incubator-pulsar/pull/1866
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 for
merlimat closed pull request #1887: Upgrade RocksDb to 5.13.1
URL: https://github.com/apache/incubator-pulsar/pull/1887
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 foreign pull req
merlimat closed pull request #1873: Upgrade Ansible to install
2.0.0-rc1-incubating
URL: https://github.com/apache/incubator-pulsar/pull/1873
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 thi
merlimat closed issue #674: Assertion failure in RocksDB when opening the index
db
URL: https://github.com/apache/incubator-pulsar/issues/674
This is an automated message from the Apache Git Service.
To respond to the messag
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/incubator-pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 89dd66b Upgrade RocksDb to 5.13.1 (#1
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/incubator-pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 588ea6a Upgrade Ansible to install 2.
srkukarni commented on issue #1890: Fixed the filename of the log files in
threaded mode
URL: https://github.com/apache/incubator-pulsar/pull/1890#issuecomment-393901095
@sijie @jerrypeng
This is an automated message from th
srkukarni opened a new pull request #1890: Fixed the filename of the log files
in threaded mode
URL: https://github.com/apache/incubator-pulsar/pull/1890
### Motivation
Explain here the context, and why you're making that change.
What is the problem you're trying to solve.
bardock commented on issue #1886: Underreplicated ledgers did not refresh when
bookie was recovered
URL:
https://github.com/apache/incubator-pulsar/issues/1886#issuecomment-393893112
Hello @sijie
In one of our clusters we currently have 21k ledgers marked as
underreplicated. The booki
ivankelly opened a new pull request #1889: Encrypted or compressed payloads can
be compacted out if empty
URL: https://github.com/apache/incubator-pulsar/pull/1889
Compressed payloads don't have zero size, even if the uncompressed
payload is empty, so if a payload was empty, it wouldn't
ivankelly opened a new pull request #1888: Move UUID in S3 object name to start
URL: https://github.com/apache/incubator-pulsar/pull/1888
This acheives better load balancing on S3, as I guess internally
objects in buckets are distributed over machines based on their
names. Randomizing
ivankelly commented on issue #1866: Make supervisord wait a single command
URL: https://github.com/apache/incubator-pulsar/pull/1866#issuecomment-393861424
retest this please
This is an automated message from the Apache Gi
This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git
The following commit(s) were added to refs/heads/asf-site by this push:
new c7d7112 Updated site at revision
81 matches
Mail list logo