[GitHub] [pulsar] MarvinCai commented on issue #5148: Validate topic name before creating partition/non partition topic via admin cli.
MarvinCai commented on issue #5148: Validate topic name before creating partition/non partition topic via admin cli. URL: https://github.com/apache/pulsar/pull/5148#issuecomment-542536817 run java8 tests run integration tests 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 specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[pulsar-manager] branch master updated: Support gradle bump version (#201)
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-manager.git The following commit(s) were added to refs/heads/master by this push: new e4242d8 Support gradle bump version (#201) e4242d8 is described below commit e4242d8a09d852f02d50432b5c1123b3e588808e Author: tuteng AuthorDate: Wed Oct 16 13:51:51 2019 +0800 Support gradle bump version (#201) ### Modifications * Add a task to change the version when releasing the project, use the following command to change the version number. ``` ./gradlew incrementVersion -Pversion=0.0.3 ``` * Update front-end version to 0.0.2 consistent with backend --- build.gradle | 5 + front-end/package.json | 2 +- 2 files changed, 6 insertions(+), 1 deletion(-) diff --git a/build.gradle b/build.gradle index 9f0c0b5..81a6699 100644 --- a/build.gradle +++ b/build.gradle @@ -63,6 +63,11 @@ task licenseCheckNode(type: com.hierynomus.gradle.license.tasks.LicenseCheck) { source = fileTree(dir: "src").include("**/*") } +// Add VERSION +task incrementVersion<<{ +new File(projectDir, "VERSION").text = version +} + dependencyManagement { imports { mavenBom org.springframework.boot.gradle.plugin.SpringBootPlugin.BOM_COORDINATES diff --git a/front-end/package.json b/front-end/package.json index 8a2ca34..104065f 100644 --- a/front-end/package.json +++ b/front-end/package.json @@ -1,6 +1,6 @@ { "name": "pulsar-manager", - "version": "0.0.1", + "version": "0.0.2", "description": "A tool for managing Apache Pulsar.", "author": "", "license": "Apache License 2.0",
[GitHub] [pulsar] aahmed-se commented on issue #5390: Use pure-java Air-Compressor instead of JNI based libraries
aahmed-se commented on issue #5390: Use pure-java Air-Compressor instead of JNI based libraries URL: https://github.com/apache/pulsar/pull/5390#issuecomment-542515686 run java8 tests 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 specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] aahmed-se commented on issue #5388: [PIP-46] Introduce sticky consumer
aahmed-se commented on issue #5388: [PIP-46] Introduce sticky consumer URL: https://github.com/apache/pulsar/pull/5388#issuecomment-542499826 run java8 tests run integration tests. 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 specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] aahmed-se commented on issue #5386: Update presto to 0.226
aahmed-se commented on issue #5386: Update presto to 0.226 URL: https://github.com/apache/pulsar/pull/5386#issuecomment-542493790 run integration tests 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 specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] aahmed-se commented on issue #5386: Update presto to 0.226
aahmed-se commented on issue #5386: Update presto to 0.226 URL: https://github.com/apache/pulsar/pull/5386#issuecomment-542493744 run java8 tests 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 specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] aahmed-se commented on issue #5390: Use pure-java Air-Compressor instead of JNI based libraries
aahmed-se commented on issue #5390: Use pure-java Air-Compressor instead of JNI based libraries URL: https://github.com/apache/pulsar/pull/5390#issuecomment-542491599 run java8 tests 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 specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] aahmed-se commented on issue #5390: Use pure-java Air-Compressor instead of JNI based libraries
aahmed-se commented on issue #5390: Use pure-java Air-Compressor instead of JNI based libraries URL: https://github.com/apache/pulsar/pull/5390#issuecomment-542491636 run integration tests 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 specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] codelipenghui commented on issue #5388: [PIP-46] Introduce sticky consumer
codelipenghui commented on issue #5388: [PIP-46] Introduce sticky consumer URL: https://github.com/apache/pulsar/pull/5388#issuecomment-542486820 run java8 tests run Integration Tests 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 specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] xujianhai666 opened a new issue #5393: Support service mesh for pulsar
xujianhai666 opened a new issue #5393: Support service mesh for pulsar URL: https://github.com/apache/pulsar/issues/5393 **Is your feature request related to a problem? Please describe.** A clear and concise description of what the problem is. Ex. I'm always frustrated when [...] service mesh save lots of devops time. **Describe the solution you'd like** A clear and concise description of what you want to happen. **Describe alternatives you've considered** A clear and concise description of any alternative solutions or features you've considered. **Additional context** Add any other context or screenshots about the feature request here. 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 specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] codelipenghui commented on issue #5391: [pulsar-broker] Fix: race condition : Failed to read-more entries on dispatcher
codelipenghui commented on issue #5391: [pulsar-broker] Fix: race condition : Failed to read-more entries on dispatcher URL: https://github.com/apache/pulsar/pull/5391#issuecomment-542485610 Seems hasMessagesToReplay() method will never be used, shall we delete it? 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 specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] rdhabalia commented on issue #5391: [pulsar-broker] Fix: race condition : Failed to read-more entries on dispatcher
rdhabalia commented on issue #5391: [pulsar-broker] Fix: race condition : Failed to read-more entries on dispatcher URL: https://github.com/apache/pulsar/pull/5391#issuecomment-542483684 rerun java8 tests rerun integration tests 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 specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] junlia opened a new issue #5392: Error open RocksDB database when 'Set up a standalone Pulsar in Docker'
junlia opened a new issue #5392: Error open RocksDB database when 'Set up a standalone Pulsar in Docker' URL: https://github.com/apache/pulsar/issues/5392 Hello, I am following the instruction on Set up a standalone Pulsar in Docker to setup Pular on windows 10 with the following command on both cmd.exe and powershell: `docker run -it -p 6650:6650 -p 8080:8080 -v "c:\docker\pulsar:/pulsar/data" apachepulsar/pulsar:2.4.1 bin/pulsar standalone` I am getting this error as appeared to be fixed already - per https://github.com/apache/pulsar/issues/3031: ``` 01:24:26.913 [main] INFO org.apache.bookkeeper.discover.ZKRegistrationManager - INSTANCEID not exists in zookeeper. Not considering it for data verification 01:24:26.998 [main] INFO org.apache.bookkeeper.bookie.Bookie - instantiate ledger manager org.apache.bookkeeper.meta.HierarchicalLedgerManagerFactory 01:24:27.019 [main] ERROR org.apache.bookkeeper.bookie.Journal - Problems reading from data/standalone/bookkeeper0/current/lastMark (this is okay if it is the first time starting this bookie 01:24:27.021 [main] INFO org.apache.bookkeeper.bookie.Bookie - Using ledger storage: org.apache.bookkeeper.bookie.storage.ldb.DbLedgerStorage 01:24:27.024 [main] INFO org.apache.bookkeeper.bookie.storage.ldb.DbLedgerStorage - Started Db Ledger Storage 01:24:27.025 [main] INFO org.apache.bookkeeper.bookie.storage.ldb.DbLedgerStorage - - Number of directories: 1 01:24:27.025 [main] INFO org.apache.bookkeeper.bookie.storage.ldb.DbLedgerStorage - - Write cache size: 1024 MB 01:24:27.025 [main] INFO org.apache.bookkeeper.bookie.storage.ldb.DbLedgerStorage - - Read Cache: 1024 MB 01:24:27.028 [main] INFO org.apache.bookkeeper.bookie.storage.ldb.DbLedgerStorage - Creating single directory db ledger storage on data/standalone/bookkeeper0/current 01:24:27.139 [main] INFO org.apache.bookkeeper.proto.BookieNettyServer - Shutting down BookieNettyServer 01:24:27.172 [main] ERROR org.apache.pulsar.PulsarStandaloneStarter - Failed to start pulsar service. java.io.IOException: Error open RocksDB database at org.apache.bookkeeper.bookie.storage.ldb.KeyValueStorageRocksDB.(KeyValueStorageRocksDB.java:182) ~[org.apache.bookkeeper-bookkeeper-server-4.9.2.jar:4.9.2] at org.apache.bookkeeper.bookie.storage.ldb.KeyValueStorageRocksDB.(KeyValueStorageRocksDB.java:83) ~[org.apache.bookkeeper-bookkeeper-server-4.9.2.jar:4.9.2] at org.apache.bookkeeper.bookie.storage.ldb.KeyValueStorageRocksDB.lambda$static$0(KeyValueStorageRocksDB.java:58) ~[org.apache.bookkeeper-bookkeeper-server-4.9.2.jar:4.9.2] at org.apache.bookkeeper.bookie.storage.ldb.LedgerMetadataIndex.(LedgerMetadataIndex.java:69) ~[org.apache.bookkeeper-bookkeeper-server-4.9.2.jar:4.9.2] at org.apache.bookkeeper.bookie.storage.ldb.SingleDirectoryDbLedgerStorage.(SingleDirectoryDbLedgerStorage.java:160) ~[org.apache.bookkeeper-bookkeeper-server-4.9.2.jar:4.9.2] at org.apache.bookkeeper.bookie.storage.ldb.DbLedgerStorage.newSingleDirectoryDbLedgerStorage(DbLedgerStorage.java:148) ~[org.apache.bookkeeper-bookkeeper-server-4.9.2.jar:4.9.2] at org.apache.bookkeeper.bookie.storage.ldb.DbLedgerStorage.initialize(DbLedgerStorage.java:128) ~[org.apache.bookkeeper-bookkeeper-server-4.9.2.jar:4.9.2] at org.apache.bookkeeper.bookie.Bookie.(Bookie.java:790) ~[org.apache.bookkeeper-bookkeeper-server-4.9.2.jar:4.9.2] at org.apache.bookkeeper.proto.BookieServer.newBookie(BookieServer.java:137) ~[org.apache.bookkeeper-bookkeeper-server-4.9.2.jar:4.9.2] at org.apache.bookkeeper.proto.BookieServer.(BookieServer.java:106) ~[org.apache.bookkeeper-bookkeeper-server-4.9.2.jar:4.9.2] at org.apache.pulsar.zookeeper.LocalBookkeeperEnsemble.runBookies(LocalBookkeeperEnsemble.java:272) ~[org.apache.pulsar-pulsar-zookeeper-utils-2.4.1.jar:2.4.1] at org.apache.pulsar.zookeeper.LocalBookkeeperEnsemble.startStandalone(LocalBookkeeperEnsemble.java:396) ~[org.apache.pulsar-pulsar-zookeeper-utils-2.4.1.jar:2.4.1] at org.apache.pulsar.PulsarStandalone.start(PulsarStandalone.java:259) ~[org.apache.pulsar-pulsar-broker-2.4.1.jar:2.4.1] at org.apache.pulsar.PulsarStandaloneStarter.main(PulsarStandaloneStarter.java:121) [org.apache.pulsar-pulsar-broker-2.4.1.jar:2.4.1] Caused by: org.rocksdb.RocksDBException: While fsync: a directory: Invalid argument at org.rocksdb.RocksDB.open(Native Method) ~[org.rocksdb-rocksdbjni-5.13.3.jar:?] at org.rocksdb.RocksDB.open(RocksDB.java:231) ~[org.rocksdb-rocksdbjni-5.13.3.jar:?] at org.apache.bookkeeper.bookie.storage.ldb.KeyValueStorageRocksDB.(KeyValueStorageRocksDB.java:179) ~[org.apache.bookkeeper-bookkeeper-server-4.9.2.jar:4.9.2] ... 13 more 01:24:27.182 [Thread-1] ERROR org.apache.pulsar.Pul
[GitHub] [pulsar] rdhabalia removed a comment on issue #5391: [pulsar-broker] Fix: race condition : Failed to read-more entries on dispatcher
rdhabalia removed a comment on issue #5391: [pulsar-broker] Fix: race condition : Failed to read-more entries on dispatcher URL: https://github.com/apache/pulsar/pull/5391#issuecomment-542474791 retest this please 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 specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] rdhabalia commented on issue #5391: [pulsar-broker] Fix: race condition : Failed to read-more entries on dispatcher
rdhabalia commented on issue #5391: [pulsar-broker] Fix: race condition : Failed to read-more entries on dispatcher URL: https://github.com/apache/pulsar/pull/5391#issuecomment-542475072 rerun java8 tests 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 specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] rdhabalia removed a comment on issue #5391: [pulsar-broker] Fix: race condition : Failed to read-more entries on dispatcher
rdhabalia removed a comment on issue #5391: [pulsar-broker] Fix: race condition : Failed to read-more entries on dispatcher URL: https://github.com/apache/pulsar/pull/5391#issuecomment-542475072 rerun java8 tests 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 specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] rdhabalia commented on issue #5391: [pulsar-broker] Fix: race condition : Failed to read-more entries on dispatcher
rdhabalia commented on issue #5391: [pulsar-broker] Fix: race condition : Failed to read-more entries on dispatcher URL: https://github.com/apache/pulsar/pull/5391#issuecomment-542474791 retest this please 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 specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] rdhabalia opened a new pull request #5391: [pulsar-broker] Fix: race condition : Failed to read-more entries on dispatcher
rdhabalia opened a new pull request #5391: [pulsar-broker] Fix: race condition : Failed to read-more entries on dispatcher URL: https://github.com/apache/pulsar/pull/5391 ### Motivation Due to race condition on `messagesToRedeliver`, dispatcher tries to access `delayedDeliveryTracker` which is empty and it is getting below exception so, dispatcher is not able to read entries. ``` 22:05:03.693 [pulsar-io-22-7] WARN io.netty.util.concurrent.AbstractEventExecutor - A task raised an exception. Task: org.apache.pulsar.broker.service.persisten t.PersistentDispatcherMultipleConsumers$$Lambda$965/0x000800912840@cdfd37a java.util.NoSuchElementException: No value present at java.util.Optional.get(Optional.java:148) ~[?:?] at org.apache.pulsar.broker.service.persistent.PersistentDispatcherMultipleConsumers.getMessagesToReplayNow(PersistentDispatcherMultipleConsumers.java:728) ~[pulsar-broker-2.4.3-yahoo.jar:2.4.3-yahoo] at org.apache.pulsar.broker.service.persistent.PersistentDispatcherMultipleConsumers.readMoreEntries(PersistentDispatcherMultipleConsumers.java:298) ~[pulsar-broker-2.4.3-yahoo.jar:2.4.3-yahoo] at org.apache.pulsar.broker.service.persistent.PersistentDispatcherMultipleConsumers.lambda$addUnAckedMessages$374(PersistentDispatcherMultipleConsumers.java:646) ~[pulsar-broker-2.4.3-yahoo.jar:2.4.3-yahoo] at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163) [netty-all-4.1.32.Final.jar:4.1.32.Final] at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404) [netty-all-4.1.32.Final.jar:4.1.32.Final] at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:335) [netty-all-4.1.32.Final.jar:4.1.32.Final] at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:909) [netty-all-4.1.32.Final.jar:4.1.32.Final] at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) [netty-all-4.1.32.Final.jar:4.1.32.Final] at java.lang.Thread.run(Thread.java:834) [?:?] ``` With this fix, dispatcher will atomically fetches replay-messages without accessing `delayedDeliveryTracker`. 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 specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] massakam commented on issue #4811: [Issue: 3161][Go client] Return Message ID for send
massakam commented on issue #4811: [Issue: 3161][Go client] Return Message ID for send URL: https://github.com/apache/pulsar/pull/4811#issuecomment-542468099 rerun java8 tests 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 specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] aahmed-se commented on issue #5390: Use pure-java Air-Compressor instead of JNI based libraries
aahmed-se commented on issue #5390: Use pure-java Air-Compressor instead of JNI based libraries URL: https://github.com/apache/pulsar/pull/5390#issuecomment-542467579 run cpp tests 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 specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] liketic commented on issue #5372: Use StandardCharsets.UTF_8 for converting String to bytes
liketic commented on issue #5372: Use StandardCharsets.UTF_8 for converting String to bytes URL: https://github.com/apache/pulsar/pull/5372#issuecomment-542465193 run java8 tests run integration tests 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 specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] merlimat opened a new pull request #5390: Use pure-java Air-Compressor instead of JNI based libraries
merlimat opened a new pull request #5390: Use pure-java Air-Compressor instead of JNI based libraries URL: https://github.com/apache/pulsar/pull/5390 ### Motivation Right now we're using JNI based libraries to perform data compression. These libraries are do have an overhead in terms of size (7Mb out of 20Mb of Pulsar-Client lib) and are incurring the JNI overhead which is typically measurable when compressing many small payloads. We can replaces compression libraries for LZ4, ZStd and Snappy with AirCompressor (https://github.com/airlift/aircompressor), which is a pure Java compression library used by Presto. ### Microbenchmarks Microbenchmark code is available at https://github.com/merlimat/compression-benchmark The results are on-par with the JNI version in most cases. Results: ``` Benchmark (provider) (size) Mode Cnt Score Error Units CompressDecompress.compress Zip 10b thrpt214.639 ops/ms CompressDecompress.compress Zip 1kb thrpt 40.054 ops/ms CompressDecompress.compress Zip10kb thrpt 4.898 ops/ms CompressDecompress.compress Zip64kb thrpt 1.416 ops/ms CompressDecompress.compress JNI-LZ4 10b thrpt 2307.323 ops/ms CompressDecompress.compress JNI-LZ4 1kb thrpt496.654 ops/ms CompressDecompress.compress JNI-LZ410kb thrpt 81.646 ops/ms CompressDecompress.compress JNI-LZ464kb thrpt 20.605 ops/ms CompressDecompress.compress JNI-ZStd 10b thrpt 1635.891 ops/ms CompressDecompress.compress JNI-ZStd 1kb thrpt 98.864 ops/ms CompressDecompress.compress JNI-ZStd10kb thrpt 21.072 ops/ms CompressDecompress.compress JNI-ZStd64kb thrpt 6.316 ops/ms CompressDecompress.compressJNI-Snappy 10b thrpt 2198.521 ops/ms CompressDecompress.compressJNI-Snappy 1kb thrpt264.103 ops/ms CompressDecompress.compressJNI-Snappy10kb thrpt 27.095 ops/ms CompressDecompress.compressJNI-Snappy64kb thrpt 7.961 ops/ms CompressDecompress.compress AC-Snappy 10b thrpt 7542.674 ops/ms CompressDecompress.compress AC-Snappy 1kb thrpt374.631 ops/ms CompressDecompress.compress AC-Snappy10kb thrpt 54.042 ops/ms CompressDecompress.compress AC-Snappy64kb thrpt 16.932 ops/ms CompressDecompress.compressAC-LZ4 10b thrpt 9360.128 ops/ms CompressDecompress.compressAC-LZ4 1kb thrpt374.507 ops/ms CompressDecompress.compressAC-LZ410kb thrpt 50.168 ops/ms CompressDecompress.compressAC-LZ464kb thrpt 12.202 ops/ms CompressDecompress.compress AC-ZStd 10b thrpt3 641.855 ops/ms CompressDecompress.compress AC-ZStd 1kb thrpt340.996 ops/ms CompressDecompress.compress AC-ZStd10kb thrpt3 9.626 ops/ms CompressDecompress.compress AC-ZStd64kb thrpt3 2.979 ops/ms CompressDecompress.decompress Zip 10b thrpt 1856.131 ops/ms CompressDecompress.decompress Zip 1kb thrpt164.930 ops/ms CompressDecompress.decompress Zip10kb thrpt 35.547 ops/ms CompressDecompress.decompress Zip64kb thrpt 7.846 ops/ms CompressDecompress.decompress JNI-LZ4 10b thrpt 4127.293 ops/ms CompressDecompress.decompress JNI-LZ4 1kb thrpt 2003.209 ops/ms CompressDecompress.decompress JNI-LZ410kb thrpt326.834 ops/ms CompressDecompress.decompress JNI-LZ464kb thrpt 66.849 ops/ms CompressDecompress.decompressJNI-ZStd 10b thrpt 1003.361 ops/ms CompressDecompress.decompressJNI-ZStd 1kb thrpt156.012 ops/ms CompressDecompress.decompressJNI-ZStd10kb thrpt 48.902 ops/ms CompressDecompress.decompressJNI-ZStd64kb thrpt 19.477 ops/ms CompressDecompress.decompress JNI-Snappy 10b thrpt 3564.673 ops/ms CompressDecompress.decompress JNI-Snappy 1kb thrpt884.649 ops/ms CompressDecompress.decompress JNI-Snappy10kb thrpt123.879 ops/ms CompressDecompress.decompress JNI-Snappy64kb thrpt 24.231 ops/ms
[GitHub] [pulsar] stupidusername commented on issue #5380: Kubernetes deployment: Pods from a service are being scheduled on the same node
stupidusername commented on issue #5380: Kubernetes deployment: Pods from a service are being scheduled on the same node URL: https://github.com/apache/pulsar/issues/5380#issuecomment-542342311 Solved in #5381. 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 specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] stupidusername closed issue #5380: Kubernetes deployment: Pods from a service are being scheduled on the same node
stupidusername closed issue #5380: Kubernetes deployment: Pods from a service are being scheduled on the same node URL: https://github.com/apache/pulsar/issues/5380 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 specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[pulsar] branch master updated (3a9854e -> 63a73fc)
This is an automated email from the ASF dual-hosted git repository. mmerli pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git. from 3a9854e make skip all messages async. (#5375) add 63a73fc Fixing pod anti-affinity rules in Kubernetes files including the Helm chart (#5381) No new revisions were added by this update. Summary of changes: deployment/kubernetes/aws/zookeeper.yaml | 4 deployment/kubernetes/generic/k8s-1-9-and-above/zookeeper.yaml| 4 deployment/kubernetes/generic/original/zookeeper.yaml | 4 deployment/kubernetes/google-kubernetes-engine/bookie.yaml| 4 deployment/kubernetes/google-kubernetes-engine/zookeeper.yaml | 4 .../kubernetes/helm/pulsar/templates/autorecovery-deployment.yaml | 2 +- .../kubernetes/helm/pulsar/templates/bookkeeper-statefulset.yaml | 2 +- deployment/kubernetes/helm/pulsar/templates/broker-deployment.yaml| 2 +- deployment/kubernetes/helm/pulsar/templates/proxy-deployment.yaml | 2 +- .../kubernetes/helm/pulsar/templates/zookeeper-statefulset.yaml | 2 +- 10 files changed, 25 insertions(+), 5 deletions(-)
[GitHub] [pulsar] merlimat merged pull request #5381: [Issue 5380][deployment]Fixing pod anti-affinity rules in Kubernetes files including Helm chart
merlimat merged pull request #5381: [Issue 5380][deployment]Fixing pod anti-affinity rules in Kubernetes files including Helm chart URL: https://github.com/apache/pulsar/pull/5381 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 specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] merlimat commented on issue #2962: Geo Replication and consumer failover
merlimat commented on issue #2962: Geo Replication and consumer failover URL: https://github.com/apache/pulsar/issues/2962#issuecomment-542289448 The replicated subscription feature was proposed in https://github.com/apache/pulsar/wiki/PIP-33%3A-Replicated-subscriptions and it was released in Pulsar 2.4.0 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 specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] nnivruth commented on issue #2962: Geo Replication and consumer failover
nnivruth commented on issue #2962: Geo Replication and consumer failover URL: https://github.com/apache/pulsar/issues/2962#issuecomment-542288313 @sijie is there an update on this? 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 specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] codelipenghui commented on issue #5388: [PIP-46] Introduce sticky consumer
codelipenghui commented on issue #5388: [PIP-46] Introduce sticky consumer URL: https://github.com/apache/pulsar/pull/5388#issuecomment-542241412 run java8 tests run Integration Tests 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 specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] massakam commented on issue #4811: [Issue: 3161][Go client] Return Message ID for send
massakam commented on issue #4811: [Issue: 3161][Go client] Return Message ID for send URL: https://github.com/apache/pulsar/pull/4811#issuecomment-542188676 rerun java8 tests rerun cpp tests 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 specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] wolfstudy commented on issue #5389: [Docs] Add delete-dynamic-config command for brokers
wolfstudy commented on issue #5389: [Docs] Add delete-dynamic-config command for brokers URL: https://github.com/apache/pulsar/pull/5389#issuecomment-542181606 @sijie @jiazhai @codelipenghui PTAL 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 specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] wolfstudy opened a new pull request #5389: [Docs] Add delete-dynamic-config command for brokers
wolfstudy opened a new pull request #5389: [Docs] Add delete-dynamic-config command for brokers URL: https://github.com/apache/pulsar/pull/5389 Signed-off-by: xiaolong.ran ### Motivation `delete-dynamic-config` document missing ### Modifications Add `delete-dynamic-config` command for **pulsar-admin brokers**. 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 specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] codelipenghui opened a new pull request #5388: [PIP-46] Introduce sticky consumer
codelipenghui opened a new pull request #5388: [PIP-46] Introduce sticky consumer URL: https://github.com/apache/pulsar/pull/5388 ### Motivation Introduce sticky consumer, users can enable it by ```java client.newConsumer() .keySharedPolicy(KeySharedPolicy.exclusiveHashRange().hashRangeTotal(10).ranges(Range.of(0, 10))) .subscribe(); ``` ### Modifications Add a new consumer selector named HashRangeExclusiveStickyKeyConsumerSelector to support sticky consumer. This change added tests and can be verified as follows: Add new unit tests. ### Does this pull request potentially affect one of the following parts: *If `yes` was chosen, please highlight the changes* - Dependencies (does it add or upgrade a dependency): (no) - The public API: (yes) - The schema: (no) - The default values of configurations: (no) - The wire protocol: (yes) - The rest endpoints: (no) - The admin cli options: (no) - Anything that affects deployment: (no) ### Documentation - Does this pull request introduce a new feature? (yes) 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 specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] congbobo184 commented on issue #5227: [PIP-44] Separate schema compatibility checker for producer and consumer
congbobo184 commented on issue #5227: [PIP-44] Separate schema compatibility checker for producer and consumer URL: https://github.com/apache/pulsar/pull/5227#issuecomment-542122965 run Integration Tests 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 specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] congbobo184 removed a comment on issue #5227: [PIP-44] Separate schema compatibility checker for producer and consumer
congbobo184 removed a comment on issue #5227: [PIP-44] Separate schema compatibility checker for producer and consumer URL: https://github.com/apache/pulsar/pull/5227#issuecomment-542122877 run java8 tests 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 specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] congbobo184 removed a comment on issue #5227: [PIP-44] Separate schema compatibility checker for producer and consumer
congbobo184 removed a comment on issue #5227: [PIP-44] Separate schema compatibility checker for producer and consumer URL: https://github.com/apache/pulsar/pull/5227#issuecomment-542122965 run Integration Tests 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 specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] congbobo184 removed a comment on issue #5227: [PIP-44] Separate schema compatibility checker for producer and consumer
congbobo184 removed a comment on issue #5227: [PIP-44] Separate schema compatibility checker for producer and consumer URL: https://github.com/apache/pulsar/pull/5227#issuecomment-542116243 run Integration Tests 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 specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] congbobo184 commented on issue #5227: [PIP-44] Separate schema compatibility checker for producer and consumer
congbobo184 commented on issue #5227: [PIP-44] Separate schema compatibility checker for producer and consumer URL: https://github.com/apache/pulsar/pull/5227#issuecomment-542122877 run java8 tests 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 specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] congbobo184 commented on issue #5227: [PIP-44] Separate schema compatibility checker for producer and consumer
congbobo184 commented on issue #5227: [PIP-44] Separate schema compatibility checker for producer and consumer URL: https://github.com/apache/pulsar/pull/5227#issuecomment-542116243 run Integration Tests 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 specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] congbobo184 commented on issue #5227: [PIP-44] Separate schema compatibility checker for producer and consumer
congbobo184 commented on issue #5227: [PIP-44] Separate schema compatibility checker for producer and consumer URL: https://github.com/apache/pulsar/pull/5227#issuecomment-542104823 run Integration Tests run java8 tests 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 specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] congbobo184 removed a comment on issue #5227: [PIP-44] Separate schema compatibility checker for producer and consumer
congbobo184 removed a comment on issue #5227: [PIP-44] Separate schema compatibility checker for producer and consumer URL: https://github.com/apache/pulsar/pull/5227#issuecomment-542056765 run Integration Tests 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 specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] congbobo184 removed a comment on issue #5227: [PIP-44] Separate schema compatibility checker for producer and consumer
congbobo184 removed a comment on issue #5227: [PIP-44] Separate schema compatibility checker for producer and consumer URL: https://github.com/apache/pulsar/pull/5227#issuecomment-542068298 run Integration Tests 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 specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] massakam commented on issue #5371: fix potential deadlock that can occur in addConsumer
massakam commented on issue #5371: fix potential deadlock that can occur in addConsumer URL: https://github.com/apache/pulsar/pull/5371#issuecomment-542085735 Do we need to modify other dispatchers (such as `PersistentDispatcherSingleActiveConsumer`) in the same way? 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 specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] jiazhai commented on issue #5045: [client] Introduce `batchingMaxBytes` setting in pulsar producer
jiazhai commented on issue #5045: [client] Introduce `batchingMaxBytes` setting in pulsar producer URL: https://github.com/apache/pulsar/pull/5045#issuecomment-542073228 run java8 tests 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 specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services