Re: [PR] [feature] use async methods to read from Pulsar topic [pinot]

2024-04-18 Thread via GitHub
Jackie-Jiang commented on PR #12061: URL: https://github.com/apache/pinot/pull/12061#issuecomment-2065467205 This no longer apply after #12812 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

Re: [PR] [feature] use async methods to read from Pulsar topic [pinot]

2024-04-18 Thread via GitHub
Jackie-Jiang closed pull request #12061: [feature] use async methods to read from Pulsar topic URL: https://github.com/apache/pinot/pull/12061 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the sp

Re: [PR] [feature] use async methods to read from Pulsar topic [pinot]

2024-03-05 Thread via GitHub
Jackie-Jiang commented on PR #12061: URL: https://github.com/apache/pinot/pull/12061#issuecomment-1979756517 There are test failures. @JeffBolle Can you take a look? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

Re: [PR] [feature] use async methods to read from Pulsar topic [pinot]

2024-03-01 Thread via GitHub
enzo-dechaene commented on PR #12061: URL: https://github.com/apache/pinot/pull/12061#issuecomment-1973221062 Hii @KKcorps, can we merge this PR in the 1.1.0 release ? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use th

Re: [PR] [feature] use async methods to read from Pulsar topic [pinot]

2023-12-18 Thread via GitHub
KKcorps commented on PR #12061: URL: https://github.com/apache/pinot/pull/12061#issuecomment-1859958543 > This PR started from addressing a concurrency issue when interacting with the List used to hold messages pulled from Pulsar after the read timeout expired. It then evolved into a refact

Re: [PR] [feature] use async methods to read from Pulsar topic [pinot]

2023-12-18 Thread via GitHub
KKcorps commented on code in PR #12061: URL: https://github.com/apache/pinot/pull/12061#discussion_r1429804967 ## pinot-plugins/pinot-stream-ingestion/pinot-pulsar/src/main/java/org/apache/pinot/plugin/stream/pulsar/PulsarPartitionLevelConsumer.java: ## @@ -75,81 +71,68 @@ publi

Re: [PR] [feature] use async methods to read from Pulsar topic [pinot]

2023-12-14 Thread via GitHub
JeffBolle commented on PR #12061: URL: https://github.com/apache/pinot/pull/12061#issuecomment-1855876618 This PR started from addressing a concurrency issue when interacting with the List used to hold messages pulled from Pulsar after the read timeout expired. It then evolved into a refac

Re: [PR] [feature] use async methods to read from Pulsar topic [pinot]

2023-11-28 Thread via GitHub
codecov-commenter commented on PR #12061: URL: https://github.com/apache/pinot/pull/12061#issuecomment-1830274214 ## [Codecov](https://app.codecov.io/gh/apache/pinot/pull/12061?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) R

[PR] [feature] use async methods to read from Pulsar topic [pinot]

2023-11-28 Thread via GitHub
JeffBolle opened a new pull request, #12061: URL: https://github.com/apache/pinot/pull/12061 Addresses ConcurrentModificationException in reading from Pulsar topic and uses fully async calls to read from a Pulsar Reader. -- This is an automated message from the Apache Git Service. To resp