sijie commented on issue #1533: [functions] Refactor JavaInstanceRunnable
URL: https://github.com/apache/incubator-pulsar/pull/1533#issuecomment-380008954
retest this please
This is an automated message from the Apache Git Ser
yush1ga commented on issue #1352: Delete inactive subscriptions automatically
URL: https://github.com/apache/incubator-pulsar/pull/1352#issuecomment-380010347
retest this please
This is an automated message from the Apache Git
yush1ga commented on issue #1352: Delete inactive subscriptions automatically
URL: https://github.com/apache/incubator-pulsar/pull/1352#issuecomment-380010347
retest this please
This is an automated message from the Apache Git
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 00a6daf Updated site at revision
ivankelly commented on issue #1513: Managed ledger uses ReadHandle in read path
URL: https://github.com/apache/incubator-pulsar/pull/1513#issuecomment-380022561
retest this please //
ManagedCursorTest.cursorPersistenceAsyncMarkDeleteSameThread
--
sijie opened a new pull request #1535: (WIP) Introduce Short Topic Name
URL: https://github.com/apache/incubator-pulsar/pull/1535
Short Topic Name can be 1) "//" or 2) ""
This is an automated message from the Apache Git Se
sijie commented on issue #1535: (WIP) Introduce Short Topic Name
URL: https://github.com/apache/incubator-pulsar/pull/1535#issuecomment-380032082
@merlimat - here the WIP for PIP-11. Can you check if this is what you were
thinking? If so, I can continue in this direction.
-
srkukarni commented on issue #1534: Implement Cassandra Sink
URL: https://github.com/apache/incubator-pulsar/pull/1534#issuecomment-380034457
retest this please
This is an automated message from the Apache Git Service.
To resp
srkukarni commented on issue #1533: [functions] Refactor JavaInstanceRunnable
URL: https://github.com/apache/incubator-pulsar/pull/1533#issuecomment-380036927
retest this please
This is an automated message from the Apache Git
sijie opened a new issue #1536: Add "default" tenant & "default" namespace
URL: https://github.com/apache/incubator-pulsar/issues/1536
This is an automated message from the Apache Git Service.
To respond to the message, pleas
srkukarni commented on issue #1533: [functions] Refactor JavaInstanceRunnable
URL: https://github.com/apache/incubator-pulsar/pull/1533#issuecomment-380052303
retest this please
This is an automated message from the Apache Git
massakam opened a new pull request #1537: Log warn message if exception occurs
while WebSocket proxy is sending…
URL: https://github.com/apache/incubator-pulsar/pull/1537
…/receiving message
Currently, even if an exception occurs while a producer/consumer inside
WebSocket proxy is s
srkukarni commented on issue #1533: [functions] Refactor JavaInstanceRunnable
URL: https://github.com/apache/incubator-pulsar/pull/1533#issuecomment-380056517
retest this please
This is an automated message from the Apache Git
massakam commented on issue #1537: Log warn message if exception occurs while
WebSocket proxy is sending…
URL: https://github.com/apache/incubator-pulsar/pull/1537#issuecomment-380065235
retest this please
This is an automate
ivankelly commented on issue #1513: Managed ledger uses ReadHandle in read path
URL: https://github.com/apache/incubator-pulsar/pull/1513#issuecomment-380079263
retest this please //
ManagedCursorTest.cursorPersistenceAsyncMarkDeleteSameThread again (passes
locally) & c++ test timeout
---
massakam commented on issue #1537: Log warn message if exception occurs while
WebSocket proxy is sending…
URL: https://github.com/apache/incubator-pulsar/pull/1537#issuecomment-380094596
retest this please
This is an automate
massakam commented on issue #1537: Log warn message if exception occurs while
WebSocket proxy is sending…
URL: https://github.com/apache/incubator-pulsar/pull/1537#issuecomment-380094596
retest this please
This is an automate
massakam commented on issue #1537: Log warn message if exception occurs while
WebSocket proxy is sending…
URL: https://github.com/apache/incubator-pulsar/pull/1537#issuecomment-380116513
retest this please
This is an automate
zhaijack opened a new pull request #1538: Add rate limit for client lookup
request
URL: https://github.com/apache/incubator-pulsar/pull/1538
### Motivation
Currently broker side has config `maxConcurrentLookupRequest`, and client
side has config `concurrentLookupRequest `. If clien
srkukarni commented on issue #1534: Implement Cassandra Sink
URL: https://github.com/apache/incubator-pulsar/pull/1534#issuecomment-380144770
retest this please
This is an automated message from the Apache Git Service.
To resp
srkukarni commented on issue #1533: [functions] Refactor JavaInstanceRunnable
URL: https://github.com/apache/incubator-pulsar/pull/1533#issuecomment-380144838
retest this please
This is an automated message from the Apache Git
merlimat closed pull request #1513: Managed ledger uses ReadHandle in read path
URL: https://github.com/apache/incubator-pulsar/pull/1513
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
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 ab67386 Managed ledger uses ReadHandl
merlimat commented on a change in pull request #1507: Using Pulsar as a message
queue (cookbook)
URL: https://github.com/apache/incubator-pulsar/pull/1507#discussion_r180496422
##
File path: site/docs/latest/cookbooks/message-queue.md
##
@@ -0,0 +1,89 @@
+---
+title: Using
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 9525047 Fix for FQFN flag (#1528)
952
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 f4300bd Log warn message if exception
merlimat closed pull request #1537: Log warn message if exception occurs while
WebSocket proxy is sending…
URL: https://github.com/apache/incubator-pulsar/pull/1537
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake
merlimat closed pull request #1528: Fix for FQFN flag
URL: https://github.com/apache/incubator-pulsar/pull/1528
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 (fr
merlimat commented on issue #1468: Documentation for non-persistent topics
URL: https://github.com/apache/incubator-pulsar/pull/1468#issuecomment-380184315
@rdhabalia Please take a look as well
This is an automated message fro
merlimat commented on issue #1527: Reduce un-necessary work when doing bundle
lookup for partitioned topic
URL: https://github.com/apache/incubator-pulsar/pull/1527#issuecomment-380185898
> Thanks. From the test logs, ownership acquire seems not take to much time,
but loadNamespaceTopics t
lucperkins commented on a change in pull request #1507: Using Pulsar as a
message queue (cookbook)
URL: https://github.com/apache/incubator-pulsar/pull/1507#discussion_r180510283
##
File path: site/docs/latest/cookbooks/message-queue.md
##
@@ -0,0 +1,89 @@
+---
+title: Usi
merlimat opened a new pull request #1539: Fixed flaky test in managed ledger
close path
URL: https://github.com/apache/incubator-pulsar/pull/1539
### Motivation
After recent changed, the managed ledger test with closing while add entry
operations were happening became flaky. Fixed t
lucperkins commented on issue #1011: Managed ledger admin docs (WIP)
URL: https://github.com/apache/incubator-pulsar/pull/1011#issuecomment-380200101
I'm going to close this for now and potentially re-open at a later date. I
don't envision working on this within the next few weeks. Best to
lucperkins closed pull request #1011: Managed ledger admin docs (WIP)
URL: https://github.com/apache/incubator-pulsar/pull/1011
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
lucperkins commented on issue #1531: remove unnecessary proto def in
FunctionsConfig
URL: https://github.com/apache/incubator-pulsar/pull/1531#issuecomment-380207479
I think the underlying issue here is that using a Protobuf definition as a
source of truth for configuration management is a
ivankelly opened a new pull request #1540: Compaction sets read compacted flag
when reading
URL: https://github.com/apache/incubator-pulsar/pull/1540
Previously compaction would read the whole backlog again, even though
what was in the compacted topic ledger was sufficient for its
pur
merlimat opened a new pull request #1541: Forget to recycle MessageMetadata
protobuf object
URL: https://github.com/apache/incubator-pulsar/pull/1541
### Motivation
`MessageMetadata` protobuf object was not not being put back into recycler
pool.
jerrypeng commented on issue #1531: remove unnecessary proto def in
FunctionsConfig
URL: https://github.com/apache/incubator-pulsar/pull/1531#issuecomment-380215913
@lucperkins I have discussed with @sijie @srkukarni, we are going to create
another class for functions that is user facing a
ivankelly opened a new pull request #1542: LedgerOffloader interface for
ManagedLedger
URL: https://github.com/apache/incubator-pulsar/pull/1542
An interface which can be used for offloading ledgers to longterm
storage.
Master issue #1511
-
ivankelly commented on issue #1543: offloadPrefix interface for ManagedLedger
URL: https://github.com/apache/incubator-pulsar/pull/1543#issuecomment-380217494
@zhaijack
This is an automated message from the Apache Git Service
ivankelly opened a new pull request #1543: offloadPrefix interface for
ManagedLedger
URL: https://github.com/apache/incubator-pulsar/pull/1543
Method to offload a prefix of a managed ledger to longterm storage.
Depends on a LedgerOffloader having been provided to the ManagedLedgerCon
ivankelly commented on issue #1542: LedgerOffloader interface for ManagedLedger
URL: https://github.com/apache/incubator-pulsar/pull/1542#issuecomment-380217780
@zhaijack
This is an automated message from the Apache Git Servi
ivankelly commented on issue #1542: LedgerOffloader interface for ManagedLedger
URL: https://github.com/apache/incubator-pulsar/pull/1542#issuecomment-380217830
retest this please // ManagedLedgerBkTest.managedLedgerClosed
Thi
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 b22769b Fixed flaky test in managed l
merlimat closed pull request #1539: Fixed flaky test in managed ledger close
path
URL: https://github.com/apache/incubator-pulsar/pull/1539
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 770ddf0 Compaction sets read compacte
merlimat closed pull request #1540: Compaction sets read compacted flag when
reading
URL: https://github.com/apache/incubator-pulsar/pull/1540
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 th
lucperkins commented on issue #1431: Additional checks for Pulsar Function jar
submission
URL: https://github.com/apache/incubator-pulsar/pull/1431#issuecomment-380262139
retest this please
This is an automated message from t
lucperkins commented on issue #1431: Additional checks for Pulsar Function jar
submission
URL: https://github.com/apache/incubator-pulsar/pull/1431#issuecomment-380265577
retest this please
This is an automated message from t
sijie closed pull request #1534: Implement Cassandra Sink
URL: https://github.com/apache/incubator-pulsar/pull/1534
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
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 4f3ac36 Implement Cassandra Sink (#153
yush1ga commented on issue #1352: Delete inactive subscriptions automatically
URL: https://github.com/apache/incubator-pulsar/pull/1352#issuecomment-380274796
retest this please
This is an automated message from the Apache Git
yush1ga commented on issue #1352: Delete inactive subscriptions automatically
URL: https://github.com/apache/incubator-pulsar/pull/1352#issuecomment-380274796
retest this please
This is an automated message from the Apache Git
srkukarni commented on issue #1533: [functions] Refactor JavaInstanceRunnable
URL: https://github.com/apache/incubator-pulsar/pull/1533#issuecomment-380277808
retest this please
This is an automated message from the Apache Git
jerrypeng commented on issue #1533: [functions] Refactor JavaInstanceRunnable
URL: https://github.com/apache/incubator-pulsar/pull/1533#issuecomment-380278950
retest this please
This is an automated message from the Apache Git
merlimat opened a new pull request #1544: Fix for
cursorPersistenceAsyncMarkDeleteSameThread
URL: https://github.com/apache/incubator-pulsar/pull/1544
### Motivation
In #1539 there was an attempt to fix the
`ManagedCursorTest.cursorPersistenceAsyncMarkDeleteSameThread()` test. One
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 884b1d1 Pulsar Functions triggering o
sijie commented on issue #1533: [functions] Refactor JavaInstanceRunnable
URL: https://github.com/apache/incubator-pulsar/pull/1533#issuecomment-380282031
retest this please
This is an automated message from the Apache Git Ser
merlimat closed pull request #1503: Pulsar Functions triggering overview
URL: https://github.com/apache/incubator-pulsar/pull/1503
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 forei
srkukarni opened a new pull request #1545: Added Aerospike Sink
URL: https://github.com/apache/incubator-pulsar/pull/1545
### Motivation
Added Aerospike Sink to the Pulsar Connect framework
### Modifications
Describe the modifications you've done.
### Result
srkukarni commented on issue #1545: Added Aerospike Sink
URL: https://github.com/apache/incubator-pulsar/pull/1545#issuecomment-380284965
@merlimat @sijie
This is an automated message from the Apache Git Service.
To respo
merlimat closed pull request #1544: Fix for
cursorPersistenceAsyncMarkDeleteSameThread
URL: https://github.com/apache/incubator-pulsar/pull/1544
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 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 ede7ffe Fix for cursorPersistenceAsyn
rdhabalia opened a new pull request #1546: Fix: handle failure of topic stat
update
URL: https://github.com/apache/incubator-pulsar/pull/1546
### Motivation
Recently, we have seen multiple scenarios where due to incorrect state of
one of the `ManagedCursor`, broker fails to prepare
zhaijack commented on issue #1538: Add rate limit for client lookup requests
URL: https://github.com/apache/incubator-pulsar/pull/1538#issuecomment-380297860
retest this please
This is an automated message from the Apache Git
jerrypeng commented on issue #1531: remove unnecessary proto def in
FunctionsConfig
URL: https://github.com/apache/incubator-pulsar/pull/1531#issuecomment-380298095
retest this please
This is an automated message from the Apa
zhaijack opened a new pull request #1547: Make client keepAliveInterval
configurable in client side
URL: https://github.com/apache/incubator-pulsar/pull/1547
### Motivation
Currently `keepAliveInterval` is hard coded as 30s in ClientCnx, Would like
to make it configurable.
##
massakam commented on a change in pull request #1352: Delete inactive
subscriptions automatically
URL: https://github.com/apache/incubator-pulsar/pull/1352#discussion_r180613509
##
File path:
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ManagedCursor.java
##
yush1ga commented on a change in pull request #1352: Delete inactive
subscriptions automatically
URL: https://github.com/apache/incubator-pulsar/pull/1352#discussion_r180614996
##
File path:
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ManagedCursor.java
##
srkukarni commented on issue #1545: Added Aerospike Sink
URL: https://github.com/apache/incubator-pulsar/pull/1545#issuecomment-380309676
retest this please
This is an automated message from the Apache Git Service.
To respond
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 22e45e7 Refactor JavaInstanceRunnable
merlimat closed pull request #1533: [functions] Refactor JavaInstanceRunnable
URL: https://github.com/apache/incubator-pulsar/pull/1533
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
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 e370b97 Added Aerospike Sink (#1545)
e
sijie closed pull request #1545: Added Aerospike Sink
URL: https://github.com/apache/incubator-pulsar/pull/1545
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 (fr
merlimat commented on a change in pull request #1547: Make client
keepAliveInterval configurable in client side
URL: https://github.com/apache/incubator-pulsar/pull/1547#discussion_r180630809
##
File path:
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientCnx.java
##
merlimat commented on a change in pull request #1547: Make client
keepAliveInterval configurable in client side
URL: https://github.com/apache/incubator-pulsar/pull/1547#discussion_r180630681
##
File path:
pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ClientConfigu
zhaijack commented on issue #1517: Reader#hasMessageAvailable can report false
when it should be true
URL:
https://github.com/apache/incubator-pulsar/issues/1517#issuecomment-380322987
Thanks @ivankelly will handle this.
Th
zhaijack commented on issue #1538: Add rate limit for client lookup requests
URL: https://github.com/apache/incubator-pulsar/pull/1538#issuecomment-380297860
retest this please
This is an automated message from the Apache Git
merlimat opened a new pull request #1548: Fixed race condition intruduced
managed ledger addEntry introduced in #1521
URL: https://github.com/apache/incubator-pulsar/pull/1548
### Motivation
The change in #1521 introduced a race between multiple writers since the
enqueing and sendin
79 matches
Mail list logo
