sijie edited a comment on issue #3225: python example with aws loadbalancer
connection stuck
URL: https://github.com/apache/pulsar/issues/3225#issuecomment-449280178
@lxkaka can you telnet the lb dns?
btw, how do you configure the lb?
sijie commented on issue #3225: python example with aws loadbalancer connection
stuck
URL: https://github.com/apache/pulsar/issues/3225#issuecomment-449280178
@lxkaka can you telnet the lb dns?
This is an automated message
legendtkl commented on issue #3233: Document new rest api - getLastMessageId
URL: https://github.com/apache/pulsar/issues/3233#issuecomment-449274788
I will do that later.
This is an automated message from the Apache Git
legendtkl commented on issue #3196: add Rest API for Persistent Topic
GetLastMessageId
URL: https://github.com/apache/pulsar/pull/3196#issuecomment-449274251
@sijie No problem.
This is an automated message from the Apache
xiangzilv123 commented on issue #3226: Unclosed consumer after calling
closeAsync
URL: https://github.com/apache/pulsar/issues/3226#issuecomment-449266078
@legendtkl you must start two consumers;shared mode
This is an
sijie commented on issue #3231: [pulsar-flink] add streaming connectors as a
Pulsar stream that serializes data in Avro format
URL: https://github.com/apache/pulsar/pull/3231#issuecomment-449265722
run java8 tests
This is an
sijie commented on issue #2983: add replication_delay to namespace metrics
URL: https://github.com/apache/pulsar/pull/2983#issuecomment-449265509
run integration tests
This is an automated message from the Apache Git Service.
ambition119 commented on issue #3231: [pulsar-flink] add streaming connectors
as a Pulsar stream that serializes data in Avro format
URL: https://github.com/apache/pulsar/pull/3231#issuecomment-449265574
ok, I can supplement PulsarJsonTableSink and PulsarAvroTableSink simple
example.
xiangzilv123 commented on issue #3226: Unclosed consumer after calling
closeAsync
URL: https://github.com/apache/pulsar/issues/3226#issuecomment-449265114
```java
package test;
import org.apache.pulsar.client.api.Consumer;
import
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 8ef0ca7 Updated PIP 27: Add checklist in
ambition119 commented on issue #3232: Discuss whether remove JsonRow
SerializationSchema and DeserializationSchema
URL: https://github.com/apache/pulsar/issues/3232#issuecomment-449262576
> @ambition119 :
>
> > directly use flink-json model classes, maintain consistency and
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 c7ac328 Updated Home (markdown)
c7ac328 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 edcb766 Updated PIP 27: Improve github
ambition119 opened a new pull request #3234: [issues 3232] integrate flink-json
to pulsar
URL: https://github.com/apache/pulsar/pull/3234
### Motivation
Explain here the context, and why you're making that change.
What is the problem you're trying to solve.
###
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 51bc0e9 Created PIP 27: Improve github
This is an automated email from the ASF dual-hosted git repository.
sijie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.wiki.git
The following commit(s) were added to refs/heads/master by this push:
new d8e017a Updated Home (markdown)
d8e017a is
sijie commented on issue #3233: Document new rest api - getLastMessageId
URL: https://github.com/apache/pulsar/issues/3233#issuecomment-449256895
we need to add the documentation to
http://pulsar.apache.org/docs/en/admin-api-persistent-topics/
sijie commented on issue #3196: add Rest API for Persistent Topic
GetLastMessageId
URL: https://github.com/apache/pulsar/pull/3196#issuecomment-449256720
@legendtkl I created #3233 , can you also help updating the website to
document this new rest endpoint?
sijie closed issue #3162: There should be a way to get the last message ID of a
topic
URL: https://github.com/apache/pulsar/issues/3162
This is an automated message from the Apache Git Service.
To respond to the message,
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 f493676 support GetLastMessageId api (#3196)
sijie closed pull request #3196: add Rest API for Persistent Topic
GetLastMessageId
URL: https://github.com/apache/pulsar/pull/3196
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
sijie opened a new issue #3233: Document new rest api - getLastMessageId
URL: https://github.com/apache/pulsar/issues/3233
We introduced a new rest endpoint `getLastMessageId` at #3196. We should
also update the website about this new api
sijie commented on issue #3232: Discuss whether remove JsonRow
SerializationSchema and DeserializationSchema
URL: https://github.com/apache/pulsar/issues/3232#issuecomment-449254686
@ambition119 :
> directly use flink-json model classes, maintain consistency and
synchronization
ambition119 opened a new issue #3232: Discuss whether remove JsonRow
SerializationSchema and DeserializationSchema
URL: https://github.com/apache/pulsar/issues/3232
Expected behavior
while I commit PulsarAvroTableSink class found , we can use the native
SerializationSchema and
ambition119 opened a new pull request #3231: [pulsar-flink] add streaming
connectors as a Pulsar stream that serializes data in Avro format
URL: https://github.com/apache/pulsar/pull/3231
### Motivation
add Avro data format flink streaming connectors
### Modifications
legendtkl commented on issue #3226: Unclosed consumer after calling closeAsync
URL: https://github.com/apache/pulsar/issues/3226#issuecomment-449225878
hi, @xiangzilv123 , would you mind giving the code snippet ?
This is an
lxkaka edited a comment on issue #3225: python example with aws loadbalancer
connection stuck
URL: https://github.com/apache/pulsar/issues/3225#issuecomment-449221967
@sijie, thanks for reply. telnet no problem
```
import pulsar
# this is one of borkers private dns
add =
legendtkl commented on issue #3196: add Rest API for Persistent Topic
GetLastMessageId
URL: https://github.com/apache/pulsar/pull/3196#issuecomment-449223499
rerun java8 tests
This is an automated message from the Apache Git
lxkaka edited a comment on issue #3225: python example with aws loadbalancer
connection stuck
URL: https://github.com/apache/pulsar/issues/3225#issuecomment-449221967
@sijie, thanks for reply. telnet no problem
```
import pulsar
# this is one of borkers ip
add =
lxkaka edited a comment on issue #3225: python example with aws loadbalancer
connection stuck
URL: https://github.com/apache/pulsar/issues/3225#issuecomment-449221967
@sijie, thanks for reply. telnet no problem
```
import pulsar
# this is one of borker ip
add =
lxkaka commented on issue #3225: python example with aws loadbalancer
connection stuck
URL: https://github.com/apache/pulsar/issues/3225#issuecomment-449221967
@sijie, thanks for reply. telnet no problem
```
import pulsar
# this is one of borker ip
add = 'pulsar://
xiangzilv123 edited a comment on issue #3226: Unclosed consumer after calling
closeAsync
URL: https://github.com/apache/pulsar/issues/3226#issuecomment-449215546
@sijie we've waited more than 30mins
![101545357940_
xiangzilv123 edited a comment on issue #3226: Unclosed consumer after calling
closeAsync
URL: https://github.com/apache/pulsar/issues/3226#issuecomment-449215546
we've waited more than 30mins
![101545357940_
aahmed-se commented on issue #3168: Refactor api commands
URL: https://github.com/apache/pulsar/pull/3168#issuecomment-449216483
There is low chance on BC breaking , I am directly returning the object to
be serialized by jersey rather than doing it explicitly.
xiangzilv123 commented on issue #3226: Unclosed consumer after calling
closeAsync
URL: https://github.com/apache/pulsar/issues/3226#issuecomment-449215546
we wait more than 30min
![101545357940_
jiazhai opened a new issue #3230: expect not restart application after more
partitions created
URL: https://github.com/apache/pulsar/issues/3230
http://pulsar.apache.org/docs/en/admin-api-partitioned-topics.html#update
Already created partitioned producers and consumers can’t see
sijie commented on issue #3168: Refactor api commands
URL: https://github.com/apache/pulsar/pull/3168#issuecomment-449195097
> getFunctionInfo, getStatus, getStats endpoints
can you gusy come up a list of endpoints that are added in 2.3.0 and those
were changed in 2.3.0, before we
aahmed-se commented on issue #3168: Refactor api commands
URL: https://github.com/apache/pulsar/pull/3168#issuecomment-449194879
I will make the changes for the assert statements not sure if we want to
invest in BC tests at this time.
jerrypeng edited a comment on issue #3168: Refactor api commands
URL: https://github.com/apache/pulsar/pull/3168#issuecomment-449192676
@sijie I think we have already broken backwards compatibility with
getFunctionInfo, getStatus, getStats endpoints in previous PRs. To maintain
backwards
jerrypeng commented on issue #3168: Refactor api commands
URL: https://github.com/apache/pulsar/pull/3168#issuecomment-449192676
@sijie I think we have already broken backwards compatibility with
getFunctionInfo, getStatus, getStats endpoints in previous PRs. If we must
maintain
sijie commented on a change in pull request #3168: Refactor api commands
URL: https://github.com/apache/pulsar/pull/3168#discussion_r243461521
##
File path:
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v2/SinkApiV2Resource.java
##
@@
sijie commented on a change in pull request #3168: Refactor api commands
URL: https://github.com/apache/pulsar/pull/3168#discussion_r243461634
##
File path:
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/SourceBase.java
##
@@ -127,11 +132,10 @@ public
sijie commented on issue #3168: Refactor api commands
URL: https://github.com/apache/pulsar/pull/3168#issuecomment-449188795
@srkukarni I would prefer some forms of tests to ensure it doesn't really
break BC, because breaking BC is a really bad behavior to users.
srkukarni commented on issue #3168: Refactor api commands
URL: https://github.com/apache/pulsar/pull/3168#issuecomment-449187971
@sijie I'm not sure if this pr breaks backwards compatibility. Its not
changing any return types.
jerrypeng commented on a change in pull request #3168: Refactor api commands
URL: https://github.com/apache/pulsar/pull/3168#discussion_r243459531
##
File path:
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/SinkBase.java
##
@@ -85,15 +85,15 @@ public
jerrypeng closed pull request #3229: optimize py function stats usage
URL: https://github.com/apache/pulsar/pull/3229
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
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 6c42737 optimize py function stats usage
jerrypeng opened a new pull request #3229: optimize py function stats usage
URL: https://github.com/apache/pulsar/pull/3229
### Motivation
Reduce memory allocation in py function stats collection
This is an
merlimat opened a new pull request #3228: Provide separate module with Pulsar
v1 client API wrapper
URL: https://github.com/apache/pulsar/pull/3228
### Motivation
Provide a Pulsar V1 API compatibility wrappers.
Applications can use artifact name `pulsar-client-1x` instead of
merlimat closed pull request #3207: Configure limited number of threads in
Jetty executor
URL: https://github.com/apache/pulsar/pull/3207
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/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 06d3755 Configure limited number of threads in
merlimat closed pull request #3222: [doc] Improve documentation of running
administration dashboard for a Pulsar standalone installation
URL: https://github.com/apache/pulsar/pull/3222
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it 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/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 3490e64 [doc] Improve documentation of running
sijie opened a new issue #3227: Improve deployment guide on enabling tiered
storage
URL: https://github.com/apache/pulsar/issues/3227
It seems that there is no documentation in deployment sections about
enabling tiered storage for various deployment mechanisms.
sijie closed pull request #3117: [conf] Add annotations for documenting
function worker configuration settings
URL: https://github.com/apache/pulsar/pull/3117
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
sijie commented on issue #3213: document co-run zookeeper and bookie on same
machine
URL: https://github.com/apache/pulsar/issues/3213#issuecomment-449051697
@foreversunyao yeah, so good to me. +1
This is an automated
sijie commented on issue #3226: Unclosed consumer after calling closeAsync
URL: https://github.com/apache/pulsar/issues/3226#issuecomment-449051449
@ntysdd @xiangzilv123 : the metrics are refreshed in a given interval. I
don't remember it is 30 seconds or 5 mins. Can you wait for some time
getui-fe-ci commented on issue #3226: Unclosed consumer after calling closeAsync
URL: https://github.com/apache/pulsar/issues/3226#issuecomment-448992411
ntysdd opened a new issue #3226: Unclosed consumer after calling closeAsync
URL: https://github.com/apache/pulsar/issues/3226
Expected behavior
Consumer should be closed, and disappear in Pulsar Dashboard after we call
closeAsync().
Actual behavior
Consumer
lxkaka commented on issue #3220: Pulsar Java admin client should work with URL
that points to a load balancer
URL: https://github.com/apache/pulsar/issues/3220#issuecomment-448973331
@michael-card I have similar problem.
```
2018-12-20 19:48:04.103 INFO ConnectionPool:63 | Created
sijie closed pull request #3113: [conf] Add annotations for documenting broker
configuration settings
URL: https://github.com/apache/pulsar/pull/3113
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.
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 9c3f2a7 [conf] Add annotations for documenting
lxkaka opened a new issue #3225: python example with aws loadbalancer
connection stuck
URL: https://github.com/apache/pulsar/issues/3225
Expected behavior
hope connect to broker through LB like directly connect
```
2018-12-20 17:36:10.667 INFO ConnectionPool:63 | Created
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/pulsar.git
The following commit(s) were added to refs/heads/asf-site by this push:
new 9dddfaa Updated site at revision 71d5a25
ngjaying opened a new issue #3224: Function option --subscription-type does not
work
URL: https://github.com/apache/pulsar/issues/3224
The option is documented at
https://pulsar.apache.org/docs/en/pulsar-admin/#create-1, but it is actually an
invalid option. I find it was once supported
65 matches
Mail list logo
