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/incubator-pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 2f38b89 Minor bug-fixes to
srkukarni closed pull request #2145: Minor bug-fixes to examples
URL: https://github.com/apache/incubator-pulsar/pull/2145
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
rdhabalia opened a new pull request #2146: add list-connector rest api at
workers
URL: https://github.com/apache/incubator-pulsar/pull/2146
### Motivation
Add rest api to get list of connectors from workers.
### Modifications
CmdSink/CmdSource fails without this api.
srkukarni opened a new pull request #2145: Minor bug-fixes to examples
URL: https://github.com/apache/incubator-pulsar/pull/2145
### Motivation
Explain here the context, and why you're making that change.
What is the problem you're trying to solve.
### Modifications
merlimat commented on a change in pull request #2108: add flatbuffer option to
serialize kinesis-message in KinesisSink
URL: https://github.com/apache/incubator-pulsar/pull/2108#discussion_r202140495
##
File path: pom.xml
##
@@ -952,6 +952,11 @@ flexible messaging model
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 ede2108 Release resources for ZLib
merlimat closed pull request #2111: Release resources for ZLib
inflater/deflater when not used
URL: https://github.com/apache/incubator-pulsar/pull/2111
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
aahmed-se commented on a change in pull request #2101: Migrate compaction and
s3 offload test to testcontainers
URL: https://github.com/apache/incubator-pulsar/pull/2101#discussion_r202194635
##
File path:
aahmed-se commented on issue #2101: Migrate compaction and s3 offload test to
testcontainers
URL: https://github.com/apache/incubator-pulsar/pull/2101#issuecomment-404666757
It should be ready I am able get the test pass locally
merlimat commented on a change in pull request #2108: add flatbuffer option to
serialize kinesis-message in KinesisSink
URL: https://github.com/apache/incubator-pulsar/pull/2108#discussion_r202171471
##
File path: distribution/server/licenses/LICENSE-flatbuffer.txt
##
@@
This is an automated email from the ASF dual-hosted git repository.
rdhabalia 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 14fc5d9 Schedule task to update
This is an automated email from the ASF dual-hosted git repository.
rdhabalia 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 d43bf87 add list-connector rest
rdhabalia commented on a change in pull request #2108: add flatbuffer option to
serialize kinesis-message in KinesisSink
URL: https://github.com/apache/incubator-pulsar/pull/2108#discussion_r202203957
##
File path: pom.xml
##
@@ -952,6 +952,11 @@ flexible messaging model
rdhabalia closed pull request #2146: add list-connector rest api at workers
URL: https://github.com/apache/incubator-pulsar/pull/2146
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 #2148: Fix schema initialization
URL: https://github.com/apache/incubator-pulsar/pull/2148
### Motivation
There are a couple of race condition when multiple producers consumer are
trying to use a new topic with schema defined.
If the scheme
merlimat commented on a change in pull request #2148: Fix schema initialization
URL: https://github.com/apache/incubator-pulsar/pull/2148#discussion_r202214245
##
File path:
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/schema/PartitionedTopicsSchema.java
##
rdhabalia commented on a change in pull request #2148: Fix schema initialization
URL: https://github.com/apache/incubator-pulsar/pull/2148#discussion_r202214227
##
File path:
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/schema/PartitionedTopicsSchema.java
rdhabalia commented on a change in pull request #2148: Fix schema initialization
URL: https://github.com/apache/incubator-pulsar/pull/2148#discussion_r202214180
##
File path:
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/schema/PartitionedTopicsSchema.java
merlimat commented on a change in pull request #2148: Fix schema initialization
URL: https://github.com/apache/incubator-pulsar/pull/2148#discussion_r202214274
##
File path:
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/schema/PartitionedTopicsSchema.java
##
sijie closed pull request #2056: Add authentication to admin proxy
URL: https://github.com/apache/incubator-pulsar/pull/2056
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
sijie commented on issue #2105: Attach function metadata properties to pulsar
source/sink
URL: https://github.com/apache/incubator-pulsar/pull/2105#issuecomment-404681332
retest this please
This is an automated message from
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/incubator-pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 8736582 Add authentication to admin
sijie commented on issue #2116: Added optional key in pulsar IO
URL: https://github.com/apache/incubator-pulsar/pull/2116#issuecomment-404681249
This PR might just need a rebase
This is an automated message from the Apache
merlimat commented on issue #2086: Add std=c99 to CMAKE_C_FLAGS to avoid
compile error with gcc-4.8
URL: https://github.com/apache/incubator-pulsar/pull/2086#issuecomment-404689930
@hrsakai Please rebase on latest master, so it should fix the build
sijie commented on a change in pull request #2147: Fix: function load correct
type-class of connector
URL: https://github.com/apache/incubator-pulsar/pull/2147#discussion_r202207526
##
File path:
codelipenghui closed issue #2144: Improve performance in one topic.
URL: https://github.com/apache/incubator-pulsar/issues/2144
This is an automated message from the Apache Git Service.
To respond to the message, please log
rdhabalia removed a comment on issue #2147: Fix: function load correct
type-class of connector
URL: https://github.com/apache/incubator-pulsar/pull/2147#issuecomment-404688315
retest this please
This is an automated message
rdhabalia commented on issue #2147: Fix: function load correct type-class of
connector
URL: https://github.com/apache/incubator-pulsar/pull/2147#issuecomment-404688315
retest this please
This is an automated message from the
rdhabalia commented on a change in pull request #2147: Fix: function load
correct type-class of connector
URL: https://github.com/apache/incubator-pulsar/pull/2147#discussion_r202208967
##
File path:
merlimat opened a new pull request #2149: Avoid closing cursor when consumers
are disconnected
URL: https://github.com/apache/incubator-pulsar/pull/2149
### Motivation
While investigating the failures of `SequenceIdWithErrorTest` which are also
related to #2148, I've identified
rdhabalia commented on a change in pull request #2149: Avoid closing cursor
when consumers are disconnected
URL: https://github.com/apache/incubator-pulsar/pull/2149#discussion_r202212484
##
File path:
rdhabalia closed pull request #2108: add flatbuffer option to serialize
kinesis-message in KinesisSink
URL: https://github.com/apache/incubator-pulsar/pull/2108
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
This is an automated email from the ASF dual-hosted git repository.
rdhabalia 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 2a6d195 add flatbuffer option to
rdhabalia removed a comment on issue #2147: Fix: function load correct
type-class of connector
URL: https://github.com/apache/incubator-pulsar/pull/2147#issuecomment-404698159
retest this please
This is an automated message
rdhabalia commented on issue #2147: Fix: function load correct type-class of
connector
URL: https://github.com/apache/incubator-pulsar/pull/2147#issuecomment-404698159
retest this please
This is an automated message from the
sijie commented on issue #2135: Allow user to get topic from consumer message
(#2007)
URL: https://github.com/apache/incubator-pulsar/pull/2135#issuecomment-404681444
@ivankelly can you confirm @jiazhai 's question?
This is
rdhabalia opened a new pull request #2150: Fix: file-url sink/source submission
with cli
URL: https://github.com/apache/incubator-pulsar/pull/2150
### Motivation
Sometime, user wants to submit sink/source for archive with file-url. So,
pass classname with file-url of archive.
rdhabalia commented on issue #2149: Avoid closing cursor when consumers are
disconnected
URL: https://github.com/apache/incubator-pulsar/pull/2149#issuecomment-404698279
retest this please
This is an automated message from
sijie closed pull request #2126: Slow consumer prevents offloaded ledger cleanup
URL: https://github.com/apache/incubator-pulsar/pull/2126
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
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 e071ec1 Use container name in logs
merlimat closed pull request #2139: Use container name in logs
URL: https://github.com/apache/incubator-pulsar/pull/2139
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
rdhabalia commented on a change in pull request #2149: Avoid closing cursor
when consumers are disconnected
URL: https://github.com/apache/incubator-pulsar/pull/2149#discussion_r202213996
##
File path:
rdhabalia removed a comment on issue #2149: Avoid closing cursor when consumers
are disconnected
URL: https://github.com/apache/incubator-pulsar/pull/2149#issuecomment-404687733
retest this please
This is an automated
rdhabalia commented on issue #2149: Avoid closing cursor when consumers are
disconnected
URL: https://github.com/apache/incubator-pulsar/pull/2149#issuecomment-404687733
retest this please
This is an automated message from
hrsakai commented on issue #2086: Add std=c99 to CMAKE_C_FLAGS to avoid compile
error with gcc-4.8
URL: https://github.com/apache/incubator-pulsar/pull/2086#issuecomment-404693900
@merlimat
Got it, thanks.
This is an
This is an automated email from the ASF dual-hosted git repository.
hrsakai pushed a change to branch c-examples
in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git.
was 9c39d1d Add std=c99 to CMAKE_C_FLAGS to avoid compile error with
gcc-4.8
This change permanently
rdhabalia closed pull request #2112: Function: REST and CLI to get list of
workers in cluster
URL: https://github.com/apache/incubator-pulsar/pull/2112
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
This is an automated email from the ASF dual-hosted git repository.
rdhabalia 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 e9d67bc Function: REST and CLI to
sijie commented on a change in pull request #2101: Migrate compaction and s3
offload test to testcontainers
URL: https://github.com/apache/incubator-pulsar/pull/2101#discussion_r202237447
##
File path:
sijie commented on a change in pull request #2101: Migrate compaction and s3
offload test to testcontainers
URL: https://github.com/apache/incubator-pulsar/pull/2101#discussion_r202238010
##
File path:
sijie commented on a change in pull request #2101: Migrate compaction and s3
offload test to testcontainers
URL: https://github.com/apache/incubator-pulsar/pull/2101#discussion_r202238372
##
File path:
zhaijack opened a new pull request #2151: GCS offload support(3): add configs
to support GCS driver
URL: https://github.com/apache/incubator-pulsar/pull/2151
This is the third part to support Google Cloud Storage offload.
It aims to support GCS related config in
sijie commented on a change in pull request #2101: Migrate compaction and s3
offload test to testcontainers
URL: https://github.com/apache/incubator-pulsar/pull/2101#discussion_r202237897
##
File path:
sijie commented on a change in pull request #2101: Migrate compaction and s3
offload test to testcontainers
URL: https://github.com/apache/incubator-pulsar/pull/2101#discussion_r202237714
##
File path:
sijie commented on a change in pull request #2101: Migrate compaction and s3
offload test to testcontainers
URL: https://github.com/apache/incubator-pulsar/pull/2101#discussion_r202237886
##
File path:
sijie commented on a change in pull request #2101: Migrate compaction and s3
offload test to testcontainers
URL: https://github.com/apache/incubator-pulsar/pull/2101#discussion_r202237423
##
File path:
merlimat closed pull request #2086: Add std=c99 to CMAKE_C_FLAGS to avoid
compile error with gcc-4.8
URL: https://github.com/apache/incubator-pulsar/pull/2086
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
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 1e2b5d7 Add std=c99 to CMAKE_C_FLAGS
massakam commented on issue #2131: Fix Link in Binary Protocol
URL: https://github.com/apache/incubator-pulsar/pull/2131#issuecomment-404405524
retest this please
This is an automated message from the Apache Git Service.
To
jerrypeng commented on issue #2128: Schedule task to update function stats
separately
URL: https://github.com/apache/incubator-pulsar/pull/2128#issuecomment-404407954
I am not sure if its better to make the metrics gathering more complicated
here. I do like to paradigm of an external
codelipenghui opened a new issue #2142: Can't find code source in package
org.apache.bookkeeper.mledger.proto
URL: https://github.com/apache/incubator-pulsar/issues/2142
import org.apache.bookkeeper.mledger.proto.MLDataFormats.ManagedCursorInfo;
import
rdhabalia commented on issue #2128: Schedule task to update function stats
separately
URL: https://github.com/apache/incubator-pulsar/pull/2128#issuecomment-404415298
> Like I mentioned before, if a user can get only the last 60 secs of
metrics, the user would either have to get lucky and
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 81e2dcf Updated site at revision
yumochiz opened a new pull request #2143: Fix a command in Pulsar Function
overview Document
URL: https://github.com/apache/incubator-pulsar/pull/2143
### Motivation
In https://pulsar.incubator.apache.org/docs/latest/functions/overview/
```
$ bin/pulsar-functions localrun
aahmed-se commented on a change in pull request #2101: [WIP] Migrate compaction
test to testcontainers
URL: https://github.com/apache/incubator-pulsar/pull/2101#discussion_r201918724
##
File path:
aahmed-se commented on a change in pull request #2101: [WIP] Migrate compaction
test to testcontainers
URL: https://github.com/apache/incubator-pulsar/pull/2101#discussion_r201918716
##
File path:
This is an automated email from the ASF dual-hosted git repository.
massakam 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 15e4d3d fix link in binary
aahmed-se commented on a change in pull request #2139: Use container name in
logs
URL: https://github.com/apache/incubator-pulsar/pull/2139#discussion_r201918420
##
File path:
tests/integration-tests-utils/src/main/java/org/apache/pulsar/tests/DockerUtils.java
##
@@
aahmed-se commented on a change in pull request #2139: Use container name in
logs
URL: https://github.com/apache/incubator-pulsar/pull/2139#discussion_r201932128
##
File path:
tests/integration-tests-utils/src/main/java/org/apache/pulsar/tests/DockerUtils.java
##
@@
jerrypeng commented on issue #2128: Schedule task to update function stats
separately
URL: https://github.com/apache/incubator-pulsar/pull/2128#issuecomment-404410087
@rdhabalia but the metrics is for only the last 60 secs right?
kuangye098 commented on issue #2142: Can't find code source in package
org.apache.bookkeeper.mledger.proto
URL:
https://github.com/apache/incubator-pulsar/issues/2142#issuecomment-404429216
Please read ReadMe.md in the protobuf directory, which will teach you how to
build.
This is an automated email from the ASF dual-hosted git repository.
rdhabalia 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 8631067 Temporarely disable
rdhabalia commented on issue #2128: Schedule task to update function stats
separately
URL: https://github.com/apache/incubator-pulsar/pull/2128#issuecomment-404409702
> I do like to paradigm of an external system keeping track of intervals
and metrics
had a quick chat with
aahmed-se commented on issue #2101: Migrate compaction test to testcontainers
URL: https://github.com/apache/incubator-pulsar/pull/2101#issuecomment-404415048
TestCompaction should be ready and passing
TestS3Offload is code ready is not passing yet , we probably to redesign the
start
massakam closed pull request #2131: Fix Link in Binary Protocol
URL: https://github.com/apache/incubator-pulsar/pull/2131
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
codelipenghui commented on issue #2142: Can't find code source in package
org.apache.bookkeeper.mledger.proto
URL:
https://github.com/apache/incubator-pulsar/issues/2142#issuecomment-404454099
Thanks
This is an automated
codelipenghui opened a new issue #2144: Improve performance in one topic.
URL: https://github.com/apache/incubator-pulsar/issues/2144
a topic maybe has any partition?
how to scale horizontally throughput of topic.
This is
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 bf906d1 Fix a command in Pulsar
merlimat closed pull request #2143: Fix a command in Pulsar Function overview
Document
URL: https://github.com/apache/incubator-pulsar/pull/2143
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
merlimat closed pull request #2103: Issue 1433: Expose batch flushAsync() and
flush() methods in Producer
URL: https://github.com/apache/incubator-pulsar/pull/2103
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake
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 cc8ec3d Issue 1433: Expose batch
sijie commented on issue #2101: Migrate compaction and s3 offload test to
testcontainers
URL: https://github.com/apache/incubator-pulsar/pull/2101#issuecomment-404576850
> TestCompaction should be ready and passing
if TestCompaction is passing, please split this PR into two parts.
sijie commented on a change in pull request #2101: Migrate compaction and s3
offload test to testcontainers
URL: https://github.com/apache/incubator-pulsar/pull/2101#discussion_r202105798
##
File path:
sijie commented on a change in pull request #2101: Migrate compaction and s3
offload test to testcontainers
URL: https://github.com/apache/incubator-pulsar/pull/2101#discussion_r202107437
##
File path: tests/integration/s3-offload/pom.xml
##
@@ -53,5 +48,17 @@
sijie commented on a change in pull request #2101: Migrate compaction and s3
offload test to testcontainers
URL: https://github.com/apache/incubator-pulsar/pull/2101#discussion_r202105060
##
File path:
sijie commented on a change in pull request #2101: Migrate compaction and s3
offload test to testcontainers
URL: https://github.com/apache/incubator-pulsar/pull/2101#discussion_r202105679
##
File path:
sijie commented on a change in pull request #2101: Migrate compaction and s3
offload test to testcontainers
URL: https://github.com/apache/incubator-pulsar/pull/2101#discussion_r202110364
##
File path:
rdhabalia commented on issue #2108: add flatbuffer option to serialize
kinesis-message in KinesisSink
URL: https://github.com/apache/incubator-pulsar/pull/2108#issuecomment-404588142
retest this please
This is an automated
merlimat closed pull request #2138: Fixed mem leak when receiving unrecoverable
fencing errors in managed ledger
URL: https://github.com/apache/incubator-pulsar/pull/2138
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
merlimat closed pull request #2129: Fixed RPM/Deb package to include "apache"
and "incubating" in name
URL: https://github.com/apache/incubator-pulsar/pull/2129
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
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 4843154 Fixed mem leak when
merlimat commented on issue #2111: Release resources for ZLib inflater/deflater
when not used
URL: https://github.com/apache/incubator-pulsar/pull/2111#issuecomment-404590962
retest this please
This is an automated message
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 960dc3a Fixed RPM/Deb package to
merlimat removed a comment on issue #2111: Release resources for ZLib
inflater/deflater when not used
URL: https://github.com/apache/incubator-pulsar/pull/2111#issuecomment-404590962
retest this please
This is an automated
sijie closed pull request #2137: Added more Java and Python examples and made
the examples match across languages
URL: https://github.com/apache/incubator-pulsar/pull/2137
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
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/incubator-pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 387f884 Added more Java and Python
sijie commented on a change in pull request #2139: Use container name in logs
URL: https://github.com/apache/incubator-pulsar/pull/2139#discussion_r202119144
##
File path:
tests/integration-tests-utils/src/main/java/org/apache/pulsar/tests/DockerUtils.java
##
@@ -61,11
97 matches
Mail list logo
