merlimat merged pull request #4007: [pulsar-io] Specify the RabbitMQSink type
as Bytes by default
URL: https://github.com/apache/pulsar/pull/4007
This is an automated message from the Apache Git Service.
To respond to the me
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 357284a Specify the RabbitMQSink type as Bytes
Jennifer88huang opened a new pull request #4016: [Issue 3989][Doc] Update Geo
Replication docs
URL: https://github.com/apache/pulsar/pull/4016
Fixes #3989
### Motivation
The content on creating global namespaces is out of date, i've updated the
content.
### Modifications
murong00 opened a new pull request #4017: [pulsar-io] Add a Pulsar IO connector
for InfluxDB sink
URL: https://github.com/apache/pulsar/pull/4017
### Motivation
Provides a builtin InfluxDB sink Connector, in order to persist pulsar
messages to a InfluxDB database.
### Modific
foreversunyao commented on issue #3915: [PIP28][PROXY] Pulsar Proxy Gateway
Improvement
URL: https://github.com/apache/pulsar/pull/3915#issuecomment-481650025
run java8 tests
This is an automated message from the Apache Git
This is an automated email from the ASF dual-hosted git repository.
nkurihar pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.wiki.git
The following commit(s) were added to refs/heads/master by this push:
new 013bbce Updated Release Candidate Valida
zymap opened a new pull request #4018: Support multi-host for pulsar-admin
URL: https://github.com/apache/pulsar/pull/4018
---
*Motivation*
Sometimes we have many pulsar-admins. So we need support multi-host for that.
*Modifications*
Use `PulsarServiceNameResolver
tuteng opened a new pull request #4019: [Issue 3987][pulsar-broker]Handle
config is null when create tenant
URL: https://github.com/apache/pulsar/pull/4019
Fixes #3987
### Motivation
Config will not appear null when create tenant use pulsar-admin create foo3,
but use the fol
merlimat commented on a change in pull request #4018: Support multi-host for
pulsar-admin
URL: https://github.com/apache/pulsar/pull/4018#discussion_r274039066
##
File path:
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/PulsarAdmin.java
##
@@ -162,7 +16
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 fb4eaf9 [Doc] Update "load distribution" as "loa
sijie merged pull request #3958: [Doc] Update "load distribution" as "load
balance"
URL: https://github.com/apache/pulsar/pull/3958
This is an automated message from the Apache Git Service.
To respond to the message, please
merlimat commented on issue #4015: Allow to configure TypedMessageBuilder
through a Map conf object
URL: https://github.com/apache/pulsar/pull/4015#issuecomment-481755446
run java8 tests
This is an automated message f
iEverX opened a new pull request #4020: Make generate_protobuf_docker.sh usable
on windows
URL: https://github.com/apache/pulsar/pull/4020
### Motivation
On windows, `generate_protobuf_docker.sh` cannot work well, because a ':' is
contained in windows path. Just make it work.
merlimat commented on a change in pull request #4016: [Issue 3989][Doc] Update
Geo Replication docs
URL: https://github.com/apache/pulsar/pull/4016#discussion_r274058159
##
File path: site2/docs/administration-geo.md
##
@@ -38,19 +38,19 @@ Applications can create producers
merlimat commented on a change in pull request #4016: [Issue 3989][Doc] Update
Geo Replication docs
URL: https://github.com/apache/pulsar/pull/4016#discussion_r274061316
##
File path: site2/docs/administration-geo.md
##
@@ -12,24 +12,24 @@ The diagram below illustrates the
merlimat commented on a change in pull request #4016: [Issue 3989][Doc] Update
Geo Replication docs
URL: https://github.com/apache/pulsar/pull/4016#discussion_r274059213
##
File path: site2/docs/administration-geo.md
##
@@ -77,17 +75,17 @@ $ bin/pulsar-admin namespaces set
merlimat commented on a change in pull request #4016: [Issue 3989][Doc] Update
Geo Replication docs
URL: https://github.com/apache/pulsar/pull/4016#discussion_r274058690
##
File path: site2/docs/administration-geo.md
##
@@ -60,11 +60,9 @@ $ bin/pulsar-admin properties crea
devinbost opened a new issue #4021: Parallel pulsar-admin commands do not
support parallelization
URL: https://github.com/apache/pulsar/issues/4021
## Describe the bug
Executing pulsar-admin commands in parallel via bash results in only the
last command succeeding. The other commands ar
devinbost commented on issue #4012: Adding upsert functionality
URL: https://github.com/apache/pulsar/pull/4012#issuecomment-481791959
This relates to issue #4021 (Pulsar admin commands do not support
parallelization.)
This i
merlimat commented on issue #4021: Pulsar-admin commands do not support
parallelization
URL: https://github.com/apache/pulsar/issues/4021#issuecomment-481793532
I think the problem might be related with the memory settings. Each admin
tool is starting a JVM which requires a considerable am
jerrypeng commented on issue #4015: Allow to configure TypedMessageBuilder
through a Map conf object
URL: https://github.com/apache/pulsar/pull/4015#issuecomment-481794393
rerun java8 tests
This is an automated message from t
merlimat commented on a change in pull request #4017: [pulsar-io] Add a Pulsar
IO connector for InfluxDB sink
URL: https://github.com/apache/pulsar/pull/4017#discussion_r274096707
##
File path:
pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/InfluxDBSinkConfig.java
merlimat commented on a change in pull request #4017: [pulsar-io] Add a Pulsar
IO connector for InfluxDB sink
URL: https://github.com/apache/pulsar/pull/4017#discussion_r274096749
##
File path:
pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/InfluxDBSinkConfig.java
jerrypeng commented on issue #4012: Adding upsert functionality
URL: https://github.com/apache/pulsar/pull/4012#issuecomment-481809137
@devinbost thanks sharing your use case and the hurdles you are trying to
overcome!
In regards to:
> Because our pulsar-admin commands are doc
jerrypeng commented on issue #4014: Fix querystate key not found and add tests
for function state
URL: https://github.com/apache/pulsar/pull/4014#issuecomment-481811252
rerun cpp tests
This is an automated message from the Ap
jerrypeng edited a comment on issue #4012: Adding upsert functionality
URL: https://github.com/apache/pulsar/pull/4012#issuecomment-481809137
@devinbost thanks sharing your use case and the hurdles you are trying to
overcome!
In regards to:
> Because our pulsar-admin commands
jerrypeng commented on issue #4014: Fix querystate key not found and add tests
for function state
URL: https://github.com/apache/pulsar/pull/4014#issuecomment-481824684
rerun cpp tests
This is an automated message from the Ap
devinbost commented on issue #4012: Adding upsert functionality
URL: https://github.com/apache/pulsar/pull/4012#issuecomment-481832662
@jerrypeng Thank you for your very detailed response. I appreciate your time
and attention to this matter.
Regarding:
> Is there a reason why
devinbost edited a comment on issue #4012: Adding upsert functionality
URL: https://github.com/apache/pulsar/pull/4012#issuecomment-481832662
@jerrypeng Thank you for your very detailed response. I appreciate your time
and attention to this matter.
Regarding:
> Is there a rea
merlimat commented on issue #4012: Adding upsert functionality
URL: https://github.com/apache/pulsar/pull/4012#issuecomment-481852631
> I didn't mean that the Pulsar cluster is not running. What I meant is that
our end-to-end production message pipelines will be in a broken state. (i.e.
Ou
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/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 3742483 Fix querystate key not found and add
jerrypeng merged pull request #4014: Fix querystate key not found and add tests
for function state
URL: https://github.com/apache/pulsar/pull/4014
This is an automated message from the Apache Git Service.
To respond to the m
jerrypeng commented on issue #4015: Allow to configure TypedMessageBuilder
through a Map conf object
URL: https://github.com/apache/pulsar/pull/4015#issuecomment-481859711
rerun java8 tests
This is an automated message from t
srkukarni opened a new pull request #4022: Making use of builtin schemas for
primitive types
URL: https://github.com/apache/pulsar/pull/4022
### Motivation
This pr solves couple of issues
1. Functions using primitive types as output, now make use of the built-in
primitive schemas.
devinbost commented on issue #4012: Adding upsert functionality
URL: https://github.com/apache/pulsar/pull/4012#issuecomment-481868321
I wrote a Java method to performance test the process of creating components
with the Pulsar Java Admin API, and it's orders of magnitude faster. (I was
ru
devinbost edited a comment on issue #4012: Adding upsert functionality
URL: https://github.com/apache/pulsar/pull/4012#issuecomment-481868321
@jerrypeng I wrote a Java method to performance test the process of creating
components with the Pulsar Java Admin API, and it's orders of magnitude
merlimat commented on issue #4015: Allow to configure TypedMessageBuilder
through a Map conf object
URL: https://github.com/apache/pulsar/pull/4015#issuecomment-481892044
rerun java8 tests
This is an automated message
yciabaud opened a new pull request #4023: [python client] Handle subrecords in
JsonSchema encoding
URL: https://github.com/apache/pulsar/pull/4023
### Motivation
When using a complex type with subrecord in a JsonSchema, the JSON encoding
fails with `Object of type SubType is not JSO
Jennifer88huang commented on a change in pull request #4016: [Issue 3989][Doc]
Update Geo Replication docs
URL: https://github.com/apache/pulsar/pull/4016#discussion_r274225390
##
File path: site2/docs/administration-geo.md
##
@@ -38,19 +38,19 @@ Applications can create pr
Jennifer88huang commented on a change in pull request #4016: [Issue 3989][Doc]
Update Geo Replication docs
URL: https://github.com/apache/pulsar/pull/4016#discussion_r274225457
##
File path: site2/docs/administration-geo.md
##
@@ -60,11 +60,9 @@ $ bin/pulsar-admin properti
jerrypeng commented on issue #4015: Allow to configure TypedMessageBuilder
through a Map conf object
URL: https://github.com/apache/pulsar/pull/4015#issuecomment-481924774
rerun java8 tests
This is an automated message from t
Jennifer88huang commented on a change in pull request #4016: [Issue 3989][Doc]
Update Geo Replication docs
URL: https://github.com/apache/pulsar/pull/4016#discussion_r274225747
##
File path: site2/docs/administration-geo.md
##
@@ -77,17 +75,17 @@ $ bin/pulsar-admin namespa
Jennifer88huang commented on a change in pull request #4016: [Issue 3989][Doc]
Update Geo Replication docs
URL: https://github.com/apache/pulsar/pull/4016#discussion_r274230219
##
File path: site2/docs/administration-geo.md
##
@@ -12,24 +12,24 @@ The diagram below illustra
srkukarni opened a new pull request #4024: Fix the swagger files generated by
removing troublesome class
URL: https://github.com/apache/pulsar/pull/4024
### Motivation
Function/Source/Sink get returns Function/Source/SinkConfig. Corrected the
classname. This dramatically reduces the swa
sijie commented on a change in pull request #4024: Fix the swagger files
generated by removing troublesome class
URL: https://github.com/apache/pulsar/pull/4024#discussion_r274231211
##
File path: site2/tools/python-doc-gen.sh
##
@@ -26,6 +26,8 @@ ROOT_DIR=$(git rev-parse
sijie commented on issue #4023: [python client] Handle subrecords in JsonSchema
encoding
URL: https://github.com/apache/pulsar/pull/4023#issuecomment-481933653
run java8 tests
This is an automated message from the Apache Git
murong00 commented on a change in pull request #4017: [pulsar-io] Add a Pulsar
IO connector for InfluxDB sink
URL: https://github.com/apache/pulsar/pull/4017#discussion_r274233612
##
File path:
pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/InfluxDBSinkConfig.java
murong00 commented on a change in pull request #4017: [pulsar-io] Add a Pulsar
IO connector for InfluxDB sink
URL: https://github.com/apache/pulsar/pull/4017#discussion_r274233624
##
File path:
pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/InfluxDBSinkConfig.java
srkukarni commented on a change in pull request #4024: Fix the swagger files
generated by removing troublesome class
URL: https://github.com/apache/pulsar/pull/4024#discussion_r274236465
##
File path: site2/tools/python-doc-gen.sh
##
@@ -26,6 +26,8 @@ ROOT_DIR=$(git rev-pa
srkukarni commented on issue #4024: Fix the swagger files generated by removing
troublesome class
URL: https://github.com/apache/pulsar/pull/4024#issuecomment-481938489
rerun cpp tests
This is an automated message from the Ap
ambition119 commented on a change in pull request #4022: Making use of builtin
schemas for primitive types
URL: https://github.com/apache/pulsar/pull/4022#discussion_r274240738
##
File path:
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/ByteSchema.java
#
ambition119 commented on a change in pull request #4022: Making use of builtin
schemas for primitive types
URL: https://github.com/apache/pulsar/pull/4022#discussion_r274240854
##
File path:
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/ShortSchema.java
zymap commented on a change in pull request #4018: Support multi-host for
pulsar-admin
URL: https://github.com/apache/pulsar/pull/4018#discussion_r274242502
##
File path:
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/PulsarAdmin.java
##
@@ -162,7 +165,1
sijie commented on issue #4022: Making use of builtin schemas for primitive
types
URL: https://github.com/apache/pulsar/pull/4022#issuecomment-481947836
/cc @codelipenghui and @congbobo184 as reviewers as well, since they have
been working on schemas for a while.
ambition119 commented on a change in pull request #4017: [pulsar-io] Add a
Pulsar IO connector for InfluxDB sink
URL: https://github.com/apache/pulsar/pull/4017#discussion_r274243994
##
File path:
pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/InfluxDBAbstractSink.j
srkukarni commented on issue #4022: Making use of builtin schemas for primitive
types
URL: https://github.com/apache/pulsar/pull/4022#issuecomment-481948869
@sijie
1) How is it not BC? The existing clients will still be able to read the old
data(they just wont contain anything).
2)
srkukarni commented on a change in pull request #4022: Making use of builtin
schemas for primitive types
URL: https://github.com/apache/pulsar/pull/4022#discussion_r274247242
##
File path:
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/ByteSchema.java
##
srkukarni commented on a change in pull request #4022: Making use of builtin
schemas for primitive types
URL: https://github.com/apache/pulsar/pull/4022#discussion_r274247250
##
File path:
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/ShortSchema.java
##
srkukarni edited a comment on issue #4022: Making use of builtin schemas for
primitive types
URL: https://github.com/apache/pulsar/pull/4022#issuecomment-481948869
@sijie
1) How is it not BC? The existing clients will still be able to read the new
data. Currently instead of getting nul
jiazhai opened a new issue #4025: Improve read performance for tiered-storage
segment readout
URL: https://github.com/apache/pulsar/issues/4025
As discussed in slack channel with @chairmank , Steve suggested that we
could do a read-ahead to improve the read performance:
```
I looked
sijie commented on a change in pull request #4022: Making use of builtin
schemas for primitive types
URL: https://github.com/apache/pulsar/pull/4022#discussion_r274250231
##
File path:
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordCursor.java
sijie commented on a change in pull request #4022: Making use of builtin
schemas for primitive types
URL: https://github.com/apache/pulsar/pull/4022#discussion_r274246558
##
File path:
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/TopicSchema.java
sijie commented on a change in pull request #4022: Making use of builtin
schemas for primitive types
URL: https://github.com/apache/pulsar/pull/4022#discussion_r274244695
##
File path:
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/BooleanSchema.java
##
sijie commented on a change in pull request #4022: Making use of builtin
schemas for primitive types
URL: https://github.com/apache/pulsar/pull/4022#discussion_r274247131
##
File path:
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarMetadata.java
sijie commented on a change in pull request #4022: Making use of builtin
schemas for primitive types
URL: https://github.com/apache/pulsar/pull/4022#discussion_r274246796
##
File path:
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/TopicSchema.java
sijie commented on a change in pull request #4022: Making use of builtin
schemas for primitive types
URL: https://github.com/apache/pulsar/pull/4022#discussion_r274246664
##
File path:
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/TopicSchema.java
sijie commented on a change in pull request #4022: Making use of builtin
schemas for primitive types
URL: https://github.com/apache/pulsar/pull/4022#discussion_r274253399
##
File path:
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/LongSchema.java
##
@@
sijie commented on a change in pull request #4022: Making use of builtin
schemas for primitive types
URL: https://github.com/apache/pulsar/pull/4022#discussion_r274244937
##
File path:
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/DoubleSchema.java
##
@
sijie commented on a change in pull request #4022: Making use of builtin
schemas for primitive types
URL: https://github.com/apache/pulsar/pull/4022#discussion_r274246800
##
File path:
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/TopicSchema.java
sijie commented on a change in pull request #4022: Making use of builtin
schemas for primitive types
URL: https://github.com/apache/pulsar/pull/4022#discussion_r274248555
##
File path:
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PrimitiveSchemaHandler.java
sijie commented on a change in pull request #4022: Making use of builtin
schemas for primitive types
URL: https://github.com/apache/pulsar/pull/4022#discussion_r274251984
##
File path:
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordCursor.java
ambition119 commented on a change in pull request #4022: Making use of builtin
schemas for primitive types
URL: https://github.com/apache/pulsar/pull/4022#discussion_r274255369
##
File path:
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/ByteSchema.java
#
jerrypeng merged pull request #4015: Allow to configure TypedMessageBuilder
through a Map conf object
URL: https://github.com/apache/pulsar/pull/4015
This is an automated message from the Apache Git Service.
To respond to th
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/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 9c0937b Allow to configure TypedMessageBuild
murong00 commented on a change in pull request #4017: [pulsar-io] Add a Pulsar
IO connector for InfluxDB sink
URL: https://github.com/apache/pulsar/pull/4017#discussion_r274264490
##
File path:
pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/InfluxDBAbstractSink.java
Jennifer88huang commented on a change in pull request #4016: [Issue 3989][Doc]
Update Geo Replication docs
URL: https://github.com/apache/pulsar/pull/4016#discussion_r274230219
##
File path: site2/docs/administration-geo.md
##
@@ -12,24 +12,24 @@ The diagram below illustra
Jennifer88huang commented on a change in pull request #4016: [Issue 3989][Doc]
Update Geo Replication docs
URL: https://github.com/apache/pulsar/pull/4016#discussion_r274230219
##
File path: site2/docs/administration-geo.md
##
@@ -12,24 +12,24 @@ The diagram below illustra
sijie commented on a change in pull request #4022: Making use of builtin
schemas for primitive types
URL: https://github.com/apache/pulsar/pull/4022#discussion_r274248555
##
File path:
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PrimitiveSchemaHandler.java
sijie closed issue #3987: admin REST API serves 404 response to GET
/admin/v2/tenants/{tenant} even though tenant exists
URL: https://github.com/apache/pulsar/issues/3987
This is an automated message from the Apache Git Serv
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 61e9e1b [Issue 3987][pulsar-broker]Handle config
sijie merged pull request #4019: [Issue 3987][pulsar-broker]Handle config is
null when create tenant
URL: https://github.com/apache/pulsar/pull/4019
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 commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.wiki.git
The following commit(s) were added to refs/heads/master by this push:
new 551f3c6 Updated Home (markdown)
551f3c6 is
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.wiki.git
The following commit(s) were added to refs/heads/master by this push:
new dd7aedf Created PIP 35: Improve topic looku
murong00 commented on issue #3745: [Issue #3726] Modify the usage of Connector
CLI for better guidance
URL: https://github.com/apache/pulsar/pull/3745#issuecomment-481983604
run cpp tests
This is an automated message from the
84 matches
Mail list logo
