Github user HeartSaVioR commented on a diff in the pull request:
https://github.com/apache/storm/pull/1862#discussion_r95096103
--- Diff: storm-core/src/jvm/org/apache/storm/utils/DisruptorQueue.java ---
@@ -63,6 +63,18 @@
private static final String PREFIX = "disruptor-";
private static final FlusherPool FLUSHER = new FlusherPool();
+ private static int getNumFlusherPoolThreads() {
+ int numThreads = 100;
+ try {
+ String threads =
System.getProperty("num_flusher_pool_threads", "100");
--- End diff --
Rethinking this a bit: this will be going to be undocumented feature.
Given that we don't reuse this for outside of Storm project, how about
adding property to Config and calling Utils.readStormConfig() to read the value?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
