erenavsarogullari commented on issue #3200: [Pulsar-Client] Extends
ConsumerBuilder Validations
URL: https://github.com/apache/pulsar/pull/3200#issuecomment-448127722
rerun java8 tests
This is an automated message from the Ap
merlimat opened a new pull request #3207: Configure limited number of threads
in Jetty executor
URL: https://github.com/apache/pulsar/pull/3207
### Motivation
When upgrading Jetty version in b73a967a846e7a748b8d560e36851afcb7a414aa in
2.2.0, we switched from a Jetty thread pool size
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 1414edd Path prometheus python client due to th
merlimat closed pull request #3206: Patch prometheus python client due to
thread leak
URL: https://github.com/apache/pulsar/pull/3206
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 f
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 5d24067 enable java enums to be queried in sql (
jiazhai closed issue #3185: Re-delivery un-acked message repeated in different
consumers
URL: https://github.com/apache/pulsar/issues/3185
This is an automated message from the Apache Git Service.
To respond to the message,
sijie closed pull request #3202: enable java enums to be queried in sql
URL: https://github.com/apache/pulsar/pull/3202
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
sijie commented on issue #2865: Refactored JCloud Tiered Storage
URL: https://github.com/apache/pulsar/pull/2865#issuecomment-448066541
run java8 tests
run integration tests
This is an automated message from the Apache Git
sijie edited a comment on issue #3196: add Rest API for Persistent Topic
GetLastMessageId
URL: https://github.com/apache/pulsar/pull/3196#issuecomment-448064280
run java8 tests
for
org.apache.pulsar.functions.worker.PulsarWorkerAssignmentTest.testFunctionAssignmentsWithRestart
jiazhai commented on issue #3196: add Rest API for Persistent Topic
GetLastMessageId
URL: https://github.com/apache/pulsar/pull/3196#issuecomment-448066407
rerun java8 tests
This is an automated message from the Apache Git Se
sijie commented on issue #3196: add Rest API for Persistent Topic
GetLastMessageId
URL: https://github.com/apache/pulsar/pull/3196#issuecomment-448064280
run java8 tests
This is an automated message from the Apache Git Servic
sijie commented on issue #3200: [Pulsar-Client] Extends ConsumerBuilder
Validations
URL: https://github.com/apache/pulsar/pull/3200#issuecomment-448063491
run java8 tests
This is an automated message from the Apache Git Servi
ambition119 commented on a change in pull request #3205: [pulsar-flink]
Implements a batch program on Pulsar topic by writing Flink DataSet as Avro
URL: https://github.com/apache/pulsar/pull/3205#discussion_r242376567
##
File path:
examples/flink-consumer-source/src/main/scala/org/
ambition119 commented on a change in pull request #3205: [pulsar-flink]
Implements a batch program on Pulsar topic by writing Flink DataSet as Avro
URL: https://github.com/apache/pulsar/pull/3205#discussion_r242376533
##
File path:
examples/flink-consumer-source/src/main/scala/org/
jerrypeng commented on issue #3206: Patch prometheus python client due to
thread leak
URL: https://github.com/apache/pulsar/pull/3206#issuecomment-448053804
rerun java8 tests
This is an automated message from the Apache Git S
jerrypeng commented on issue #3202: enable java enums to be queried in sql
URL: https://github.com/apache/pulsar/pull/3202#issuecomment-448049229
rerun integration tests
This is an automated message from the Apache Git Service
jerrypeng commented on a change in pull request #3168: Refactor api commands
URL: https://github.com/apache/pulsar/pull/3168#discussion_r242366045
##
File path:
pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/rest/api/v2/FunctionApiV2ResourceTest.java
#
aahmed-se commented on a change in pull request #3168: Refactor api commands
URL: https://github.com/apache/pulsar/pull/3168#discussion_r242365709
##
File path:
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v2/FunctionApiV2Resource.java
#
jerrypeng commented on a change in pull request #3168: Refactor api commands
URL: https://github.com/apache/pulsar/pull/3168#discussion_r242365206
##
File path:
pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/rest/api/v2/SinkApiV2ResourceTest.java
#
jerrypeng commented on a change in pull request #3168: Refactor api commands
URL: https://github.com/apache/pulsar/pull/3168#discussion_r242365084
##
File path:
pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/rest/api/v2/SourceApiV2ResourceTest.java
###
jerrypeng commented on a change in pull request #3168: Refactor api commands
URL: https://github.com/apache/pulsar/pull/3168#discussion_r242364670
##
File path:
pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/rest/api/v2/SourceApiV2ResourceTest.java
###
jerrypeng commented on a change in pull request #3168: Refactor api commands
URL: https://github.com/apache/pulsar/pull/3168#discussion_r242364651
##
File path:
pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/rest/api/v2/SourceApiV2ResourceTest.java
###
jerrypeng commented on a change in pull request #3168: Refactor api commands
URL: https://github.com/apache/pulsar/pull/3168#discussion_r242364610
##
File path:
pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/rest/api/v2/SourceApiV2ResourceTest.java
###
jerrypeng commented on a change in pull request #3168: Refactor api commands
URL: https://github.com/apache/pulsar/pull/3168#discussion_r242364549
##
File path:
pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/rest/api/v2/SourceApiV2ResourceTest.java
###
jerrypeng commented on a change in pull request #3168: Refactor api commands
URL: https://github.com/apache/pulsar/pull/3168#discussion_r242364584
##
File path:
pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/rest/api/v2/SourceApiV2ResourceTest.java
###
jerrypeng commented on a change in pull request #3168: Refactor api commands
URL: https://github.com/apache/pulsar/pull/3168#discussion_r242364629
##
File path:
pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/rest/api/v2/SourceApiV2ResourceTest.java
###
jerrypeng commented on a change in pull request #3168: Refactor api commands
URL: https://github.com/apache/pulsar/pull/3168#discussion_r242364421
##
File path:
pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/rest/api/v2/SourceApiV2ResourceTest.java
###
jerrypeng commented on a change in pull request #3168: Refactor api commands
URL: https://github.com/apache/pulsar/pull/3168#discussion_r242364354
##
File path:
pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/rest/api/v2/SourceApiV2ResourceTest.java
###
jerrypeng commented on a change in pull request #3168: Refactor api commands
URL: https://github.com/apache/pulsar/pull/3168#discussion_r242364514
##
File path:
pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/rest/api/v2/SourceApiV2ResourceTest.java
###
jerrypeng commented on a change in pull request #3168: Refactor api commands
URL: https://github.com/apache/pulsar/pull/3168#discussion_r242364261
##
File path:
pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/rest/api/v2/SourceApiV2ResourceTest.java
###
jerrypeng commented on a change in pull request #3168: Refactor api commands
URL: https://github.com/apache/pulsar/pull/3168#discussion_r242363724
##
File path:
pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/rest/api/v2/SinkApiV2ResourceTest.java
#
jerrypeng commented on a change in pull request #3168: Refactor api commands
URL: https://github.com/apache/pulsar/pull/3168#discussion_r242361509
##
File path:
pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/rest/api/v2/FunctionApiV2ResourceTest.java
#
aahmed-se commented on a change in pull request #3168: Refactor api commands
URL: https://github.com/apache/pulsar/pull/3168#discussion_r242361303
##
File path:
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/ComponentImpl.java
##
@@ -337,
aahmed-se commented on a change in pull request #3168: Refactor api commands
URL: https://github.com/apache/pulsar/pull/3168#discussion_r242361134
##
File path:
pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/rest/api/v2/FunctionApiV2ResourceTest.java
#
aahmed-se commented on a change in pull request #3168: Refactor api commands
URL: https://github.com/apache/pulsar/pull/3168#discussion_r242360259
##
File path:
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/ComponentImpl.java
##
@@ -1145
srkukarni commented on a change in pull request #3168: Refactor api commands
URL: https://github.com/apache/pulsar/pull/3168#discussion_r242359823
##
File path:
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/ComponentImpl.java
##
@@ -337,
jerrypeng commented on a change in pull request #3168: Refactor api commands
URL: https://github.com/apache/pulsar/pull/3168#discussion_r242359693
##
File path:
pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/rest/api/v2/FunctionApiV2ResourceTest.java
#
jerrypeng commented on a change in pull request #3168: Refactor api commands
URL: https://github.com/apache/pulsar/pull/3168#discussion_r242357780
##
File path:
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v2/FunctionApiV2Resource.java
#
aahmed-se commented on a change in pull request #3168: Refactor api commands
URL: https://github.com/apache/pulsar/pull/3168#discussion_r242357534
##
File path:
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/ComponentImpl.java
##
@@ -1145
jerrypeng commented on a change in pull request #3168: Refactor api commands
URL: https://github.com/apache/pulsar/pull/3168#discussion_r242357200
##
File path:
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/ComponentImpl.java
##
@@ -1145
jerrypeng commented on issue #3202: enable java enums to be queried in sql
URL: https://github.com/apache/pulsar/pull/3202#issuecomment-448038249
@sijie I have added testing coverage for enums
This is an automated message fro
merlimat commented on issue #3206: Path prometheus python client due to thread
leak
URL: https://github.com/apache/pulsar/pull/3206#issuecomment-448021542
run java8 tests
This is an automated message from the Apache Git Servi
jerrypeng opened a new pull request #3206: Path prometheus python client due to
thread leak
URL: https://github.com/apache/pulsar/pull/3206
### Motivation
The current release of the prometheus python client contains a bug that
leaks threads.
This PR fixes the issue:
ht
erenavsarogullari commented on issue #3200: [Pulsar-Client] Extends
ConsumerBuilder Validations
URL: https://github.com/apache/pulsar/pull/3200#issuecomment-447986947
Hi @sijie, Thanks again for reviews.
Comment has been addressed. PR is ready for re-review / merge.
ivankelly commented on issue #2865: Refactored JCloud Tiered Storage
URL: https://github.com/apache/pulsar/pull/2865#issuecomment-447984785
rerun java8 tests
This is an automated message from the Apache Git Service.
To respond
erenavsarogullari commented on a change in pull request #3205: [pulsar-flink]
Implements a batch program on Pulsar topic by writing Flink DataSet as Avro
URL: https://github.com/apache/pulsar/pull/3205#discussion_r242291244
##
File path:
examples/flink-consumer-source/src/main/scal
erenavsarogullari commented on a change in pull request #3205: [pulsar-flink]
Implements a batch program on Pulsar topic by writing Flink DataSet as Avro
URL: https://github.com/apache/pulsar/pull/3205#discussion_r242291244
##
File path:
examples/flink-consumer-source/src/main/scal
erenavsarogullari commented on a change in pull request #3205: [pulsar-flink]
Implements a batch program on Pulsar topic by writing Flink DataSet as Avro
URL: https://github.com/apache/pulsar/pull/3205#discussion_r242290430
##
File path:
examples/flink-consumer-source/src/main/scal
erenavsarogullari commented on a change in pull request #3205: [pulsar-flink]
Implements a batch program on Pulsar topic by writing Flink DataSet as Avro
URL: https://github.com/apache/pulsar/pull/3205#discussion_r242290430
##
File path:
examples/flink-consumer-source/src/main/scal
erenavsarogullari commented on a change in pull request #3205: [pulsar-flink]
Implements a batch program on Pulsar topic by writing Flink DataSet as Avro
URL: https://github.com/apache/pulsar/pull/3205#discussion_r242291244
##
File path:
examples/flink-consumer-source/src/main/scal
ivankelly commented on issue #2865: Refactored JCloud Tiered Storage
URL: https://github.com/apache/pulsar/pull/2865#issuecomment-447974459
rerun integration tests
rerun java8 test
This is an automated message from the Apac
ivankelly commented on a change in pull request #2865: Refactored JCloud Tiered
Storage
URL: https://github.com/apache/pulsar/pull/2865#discussion_r242291123
##
File path:
tests/integration/src/test/java/org/apache/pulsar/tests/integration/suites/PulsarTieredStorageTestSuite.java
ambition119 commented on a change in pull request #3205: [pulsar-flink]
Implements a batch program on Pulsar topic by writing Flink DataSet as Avro
URL: https://github.com/apache/pulsar/pull/3205#discussion_r242224898
##
File path:
pulsar-flink/src/main/java/org/apache/flink/batch/
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/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new ee53ab6 improve datagenerator source (#3203)
srkukarni closed pull request #3203: improve datagenerator source
URL: https://github.com/apache/pulsar/pull/3203
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 request (
ambition119 commented on a change in pull request #3205: [pulsar-flink]
Implements a batch program on Pulsar topic by writing Flink DataSet as Avro
URL: https://github.com/apache/pulsar/pull/3205#discussion_r242224898
##
File path:
pulsar-flink/src/main/java/org/apache/flink/batch/
jiazhai commented on issue #3131: Consumer stop receive messages from broker
URL: https://github.com/apache/pulsar/issues/3131#issuecomment-447900445
Hi @codelipenghui, Do you think this is related with #3185?
This is an autom
legendtkl commented on a change in pull request #3196: add Rest API for
Persistent Topic GetLastMessageId
URL: https://github.com/apache/pulsar/pull/3196#discussion_r242164560
##
File path:
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiGetLastMessageIdTest.java
legendtkl commented on a change in pull request #3196: add Rest API for
Persistent Topic GetLastMessageId
URL: https://github.com/apache/pulsar/pull/3196#discussion_r242164458
##
File path:
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java
#
sijie commented on issue #3203: improve datagenerator source
URL: https://github.com/apache/pulsar/pull/3203#issuecomment-447847688
run integration tests
This is an automated message from the Apache Git Service.
To respond to
ambition119 commented on a change in pull request #3205: [pulsar-flink]
Implements a batch program on Pulsar topic by writing Flink DataSet as Avro
URL: https://github.com/apache/pulsar/pull/3205#discussion_r242146231
##
File path:
pulsar-flink/src/test/java/org/apache/flink/batch/
ambition119 commented on a change in pull request #3205: [pulsar-flink]
Implements a batch program on Pulsar topic by writing Flink DataSet as Avro
URL: https://github.com/apache/pulsar/pull/3205#discussion_r242144375
##
File path:
pulsar-flink/src/main/java/org/apache/flink/batch/
ambition119 commented on a change in pull request #3205: [pulsar-flink]
Implements a batch program on Pulsar topic by writing Flink DataSet as Avro
URL: https://github.com/apache/pulsar/pull/3205#discussion_r242144342
##
File path:
pulsar-flink/src/main/java/org/apache/flink/batch/
sijie commented on a change in pull request #3200: [Pulsar-Client] Extends
ConsumerBuilder Validations
URL: https://github.com/apache/pulsar/pull/3200#discussion_r242141064
##
File path:
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBuilderImpl.java
##
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 b6c25ed Error open RocksDB database in docker fo
sijie closed pull request #3201: Error open RocksDB database in docker for
windows
URL: https://github.com/apache/pulsar/pull/3201
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 fore
sijie commented on a change in pull request #3205: [pulsar-flink] Implements a
batch program on Pulsar topic by writing Flink DataSet as Avro
URL: https://github.com/apache/pulsar/pull/3205#discussion_r242138810
##
File path:
pulsar-flink/src/main/java/org/apache/flink/batch/connec
sijie commented on a change in pull request #3205: [pulsar-flink] Implements a
batch program on Pulsar topic by writing Flink DataSet as Avro
URL: https://github.com/apache/pulsar/pull/3205#discussion_r242138722
##
File path:
pulsar-flink/src/main/java/org/apache/flink/batch/connec
sijie commented on a change in pull request #3205: [pulsar-flink] Implements a
batch program on Pulsar topic by writing Flink DataSet as Avro
URL: https://github.com/apache/pulsar/pull/3205#discussion_r242138972
##
File path:
pulsar-flink/src/main/java/org/apache/flink/batch/connec
sijie commented on a change in pull request #3205: [pulsar-flink] Implements a
batch program on Pulsar topic by writing Flink DataSet as Avro
URL: https://github.com/apache/pulsar/pull/3205#discussion_r242139579
##
File path:
pulsar-flink/src/test/java/org/apache/flink/batch/connec
sijie closed pull request #3204: Fixes to get the travis build running again
URL: https://github.com/apache/pulsar/pull/3204
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 pul
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 68b5dd5 Fixes to get the travis build running ag
sijie commented on a change in pull request #3196: add Rest API for Persistent
Topic GetLastMessageId
URL: https://github.com/apache/pulsar/pull/3196#discussion_r242136231
##
File path:
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java
#
legendtkl commented on a change in pull request #3196: add Rest API for
Persistent Topic GetLastMessageId
URL: https://github.com/apache/pulsar/pull/3196#discussion_r242134295
##
File path:
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiGetLastMessageIdTest.java
ambition119 edited a comment on issue #3205: [pulsar-flink] Implements a batch
program on Pulsar topic by writing Flink DataSet as Avro
URL: https://github.com/apache/pulsar/pull/3205#issuecomment-447819586
```java
2018-12-17\T\11:44:14.874 [ERROR] Tests run: 2, Failures: 1, Errors: 0,
ambition119 commented on issue #3205: [pulsar-flink] Implements a batch program
on Pulsar topic by writing Flink DataSet as Avro
URL: https://github.com/apache/pulsar/pull/3205#issuecomment-447819586
```java
2018-12-17\T\11:44:14.874 [ERROR] Tests run: 2, Failures: 1, Errors: 0,
Skipped
codelipenghui commented on issue #3185: Re-delivery un-acked message repeated
in different consumers
URL: https://github.com/apache/pulsar/issues/3185#issuecomment-447812894
Already fix in master branch, this problem seems cause by #2590 and revert
by #3059.
If consumer redelivery h
ambition119 commented on issue #3205: [pulsar-flink] Implements a batch program
on Pulsar topic by writing Flink DataSet as Avro
URL: https://github.com/apache/pulsar/pull/3205#issuecomment-447789270
```java
[ERROR]
testFunctionAssignmentsWithRestart(org.apache.pulsar.functions.work
jai1 commented on issue #3204: Fixes to get the travis build running again
URL: https://github.com/apache/pulsar/pull/3204#issuecomment-447781927
rerun unit tests
This is an automated message from the Apache Git Service.
To re
jai1 commented on issue #3204: Fixes to get the travis build running again
URL: https://github.com/apache/pulsar/pull/3204#issuecomment-447782026
rerun java8 tests
This is an automated message from the Apache Git Service.
To r
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 7e88fc7 Updated site at revision da07af9
7e
ambition119 opened a new pull request #3205: [pulsar-flink] Implements a batch
program on Pulsar topic by writing Flink DataSet as Avro
URL: https://github.com/apache/pulsar/pull/3205
Implements a batch program on Pulsar topic by writing Flink DataSet as Avro
data Type
---
jai1 opened a new pull request #3204: Fixes to get the travis build running
again
URL: https://github.com/apache/pulsar/pull/3204
Travis build was broken for some time now, made some fixes to get it working
again.
T
83 matches
Mail list logo
