[
https://issues.apache.org/jira/browse/PHOENIX-1437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14206667#comment-14206667
]
Taylor Finnell commented on PHOENIX-1437:
-----------------------------------------
The query looks like this.
{code}
SELECT * FROM \"user_agency_segment_staging_hbase\" WHERE (rowkey BETWEEN
'ayuFArC07Vqg|' AND 'ayuFArC07Vqg|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey
BETWEEN 'thoam_B_ZNVQ|' AND 'thoam_B_ZNVQ|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR
rowkey BETWEEN 'r1kyWJC2z7Og|' AND
'r1kyWJC2z7Og|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey BETWEEN
'PVxSoTC2z7OA|' AND 'PVxSoTC2z7OA|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey
BETWEEN 'qVGqAKBjnyDD|' AND 'qVGqAKBjnyDD|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR
rowkey BETWEEN 'UhBmlnC2z814|' AND
'UhBmlnC2z814|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey BETWEEN
'z8fiY6C2z81Z|' AND 'z8fiY6C2z81Z|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey
BETWEEN 'Sa7KhOC2z81m|' AND 'Sa7KhOC2z81m|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR
rowkey BETWEEN 'aEmVHQC2z815|' AND
'aEmVHQC2z815|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey BETWEEN
'CFK_FQC2z81s|' AND 'CFK_FQC2z81s|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey
BETWEEN '4yL2u3C2z8fM|' AND '4yL2u3C2z8fM|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR
rowkey BETWEEN 'GktuUtC2z8fR|' AND
'GktuUtC2z8fR|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey BETWEEN
'BVkwHnC2z8fw|' AND 'BVkwHnC2z8fw|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey
BETWEEN '8IkBhYC2z8fv|' AND '8IkBhYC2z8fv|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR
rowkey BETWEEN '1qQH2qBgxwUT|' AND
'1qQH2qBgxwUT|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey BETWEEN
'dvbCpyC2z8f8|' AND 'dvbCpyC2z8f8|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey
BETWEEN 'ECoVyyC2z9IB|' AND 'ECoVyyC2z9IB|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR
rowkey BETWEEN 'LMcctMC2z9Ir|' AND
'LMcctMC2z9Ir|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey BETWEEN
'fnb1QYC2z9Ix|' AND 'fnb1QYC2z9Ix|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey
BETWEEN 'uS2vP_C2z9IH|' AND 'uS2vP_C2z9IH|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR
rowkey BETWEEN 'Xy78JLC2z9IS|' AND
'Xy78JLC2z9IS|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey BETWEEN
'0f7BdDBocSrL|' AND '0f7BdDBocSrL|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey
BETWEEN 'SGWW9IC2z7OL|' AND 'SGWW9IC2z7OL|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR
rowkey BETWEEN '_wWhHhC2z7OH|' AND
'_wWhHhC2z7OH|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey BETWEEN
'ZL1I84C2z7Ol|' AND 'ZL1I84C2z7Ol|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey
BETWEEN 'eXXWcRC2z7Oz|' AND 'eXXWcRC2z7Oz|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR
rowkey BETWEEN 'JAD5adBXIiO3|' AND
'JAD5adBXIiO3|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey BETWEEN
'uaNolQC2z7O5|' AND 'uaNolQC2z7O5|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey
BETWEEN 'jfJVoAC2z7O5|' AND 'jfJVoAC2z7O5|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR
rowkey BETWEEN 'f0c2ANC2z7O0|' AND
'f0c2ANC2z7O0|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey BETWEEN
'tabXQ7C2z7Ob|' AND 'tabXQ7C2z7Ob|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey
BETWEEN 'gO36RVC2z81c|' AND 'gO36RVC2z81c|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR
rowkey BETWEEN 'p1khA3C2z81V|' AND
'p1khA3C2z81V|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey BETWEEN
'CHHW2TC2z81s|' AND 'CHHW2TC2z81s|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey
BETWEEN 'knz816C2z81J|' AND 'knz816C2z81J|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR
rowkey BETWEEN 'c4FMJ_Bw6oJo|' AND
'c4FMJ_Bw6oJo|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey BETWEEN
'ooT1FTBgggVl|' AND 'ooT1FTBgggVl|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey
BETWEEN '1ZGx5nC2z81u|' AND '1ZGx5nC2z81u|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR
rowkey BETWEEN 'L_F8x4C2z81d|' AND
'L_F8x4C2z81d|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey BETWEEN
'7XLcA0C2z81T|' AND '7XLcA0C2z81T|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey
BETWEEN 'UeoZxBC1IBkD|' AND 'UeoZxBC1IBkD|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR
rowkey BETWEEN 'cHFFHVC2z817|' AND
'cHFFHVC2z817|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey BETWEEN
'Yfe8DlC2z817|' AND 'Yfe8DlC2z817|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey
BETWEEN 'pYERt7C2z81r|' AND 'pYERt7C2z81r|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR
rowkey BETWEEN '8AzDn5C2z81A|' AND
'8AzDn5C2z81A|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey BETWEEN
'AmuQ4yC2z815|' AND 'AmuQ4yC2z815|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey
BETWEEN 'Ts_ziaC2z8fT|' AND 'Ts_ziaC2z8fT|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR
rowkey BETWEEN 'lBrCFlC2z8fB|' AND
'lBrCFlC2z8fB|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey BETWEEN
'TQ2FKQC2z8fu|' AND 'TQ2FKQC2z8fu|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey
BETWEEN '2N7IpkC2z8fP|' AND '2N7IpkC2z8fP|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR
rowkey BETWEEN 'YAqtwTC2z8fl|' AND
'YAqtwTC2z8fl|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey BETWEEN
'YIKrwJC2z8fx|' AND 'YIKrwJC2z8fx|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey
BETWEEN 'hlBxQTC2z9IX|' AND 'hlBxQTC2z9IX|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR
rowkey BETWEEN 'ml1jWLC2z9Ip|' AND
'ml1jWLC2z9Ip|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey BETWEEN
'R6MlhzBe4Jas|' AND 'R6MlhzBe4Jas|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey
BETWEEN 'Ds6ZAnC2z9IF|' AND 'Ds6ZAnC2z9IF|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR
rowkey BETWEEN 'qkmF0MC2z9I4|' AND
'qkmF0MC2z9I4|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey BETWEEN
'9Xld3sC2z9Io|' AND '9Xld3sC2z9Io|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey
BETWEEN 'fE_cQeC2z9IO|' AND 'fE_cQeC2z9IO|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR
rowkey BETWEEN 'bGh2duC2z9I8|' AND
'bGh2duC2z9I8|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey BETWEEN
'lTskCgC2z9w4|' AND 'lTskCgC2z9w4|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey
BETWEEN 'LI7r3LC2z9wo|' AND 'LI7r3LC2z9wo|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR
rowkey BETWEEN '0ggO54C2z9wf|' AND
'0ggO54C2z9wf|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey BETWEEN
'4ebgy2C2z9wk|' AND '4ebgy2C2z9wk|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey
BETWEEN 'nSagy5C2z9ww|' AND 'nSagy5C2z9ww|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR
rowkey BETWEEN 's8ver7C2z7OD|' AND
's8ver7C2z7OD|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey BETWEEN
'A_XGBpC2z7Og|' AND 'A_XGBpC2z7Og|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey
BETWEEN '8QpSmGC2z7O9|' AND '8QpSmGC2z7O9|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR
rowkey BETWEEN 'n5zRdXBiIUTe|' AND
'n5zRdXBiIUTe|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey BETWEEN
'Mzx301B_knsI|' AND 'Mzx301B_knsI|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey
BETWEEN 'vLL7M0BsejuT|' AND 'vLL7M0BsejuT|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR
rowkey BETWEEN '7WQFVmC2z8fV|' AND
'7WQFVmC2z8fV|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey BETWEEN
'GC3KccC2z8fv|' AND 'GC3KccC2z8fv|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey
BETWEEN '9XiKOaC2z9wk|' AND '9XiKOaC2z9wk|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR
rowkey BETWEEN 'bnQuBUC2z9wO|' AND
'bnQuBUC2z9wO|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey BETWEEN
'F7OVnQC2z9wW|' AND 'F7OVnQC2z9wW|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey
BETWEEN 't5jbXsC2z9wA|' AND 't5jbXsC2z9wA|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR
rowkey BETWEEN 'irXhNTC2z7OD|' AND
'irXhNTC2z7OD|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey BETWEEN
'030dNBC2z81C|' AND '030dNBC2z81C|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey
BETWEEN 'ArzZMZC2z81v|' AND 'ArzZMZC2z81v|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR
rowkey BETWEEN 'oFh33CC2z8fG|' AND
'oFh33CC2z8fG|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey BETWEEN
'smVVu4BmM5yb|' AND 'smVVu4BmM5yb|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey
BETWEEN 'pYDUXhC1EyZC|' AND 'pYDUXhC1EyZC|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR
rowkey BETWEEN 'oCWEL_C2z7Os|' AND
'oCWEL_C2z7Os|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey BETWEEN
't1GgIwC2z7O2|' AND 't1GgIwC2z7O2|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey
BETWEEN 'm23UAiC2z814|' AND 'm23UAiC2z814|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR
rowkey BETWEEN 'WXWfJxC2z812|' AND
'WXWfJxC2z812|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey BETWEEN
'u6YP5hC2z81R|' AND 'u6YP5hC2z81R|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey
BETWEEN 'uGFq3xC2z8fN|' AND 'uGFq3xC2z8fN|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR
rowkey BETWEEN 'zfGKm6C2z8f4|' AND
'zfGKm6C2z8f4|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey BETWEEN
'_UPwcgC2z9I5|' AND '_UPwcgC2z9I5|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey
BETWEEN '0W9oWuC2z9Id|' AND '0W9oWuC2z9Id|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR
rowkey BETWEEN 'efia2yC2zAZW|' AND
'efia2yC2zAZW|FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF' OR rowkey BETWEEN
'sWvn0PC2z7OX|'
...
{code}
There is sometimes up to 1000 between clauses in the final query, but each
between clause looks like those above.
The phoenix version is 4.1.0
The table schema is
{code}
'user_agency_segment_staging_hbase', {TABLE_ATTRIBUTES => {coprocessor$1 =>
'|org.apache.phoenix.copr true
ocessor.ScanRegionObserver|1|', coprocessor$2 =>
'|org.apache.phoenix.coprocessor.UngroupedAggregateR
egionObserver|1|', coprocessor$3 =>
'|org.apache.phoenix.coprocessor.GroupedAggregateRegionObserver|1
|', coprocessor$4 =>
'|org.apache.phoenix.coprocessor.ServerCachingEndpointImpl|1|', coprocessor$5 =>
'|org.apache.phoenix.hbase.index.Indexer|1073741823|index.builder=org.apache.phoenix.index.PhoenixIn
dexBuilder,org.apache.hadoop.hbase.index.codec.class=org.apache.phoenix.index.PhoenixIndexCodec',
cop
rocessor$6 => '|org.apache.hadoop.hbase.regionserver.LocalIndexSplitter|1|'},
{NAME => 'cf1', DATA_BL
OCK_ENCODING => 'NONE', BLOOMFILTER => 'ROW', REPLICATION_SCOPE => '0',
COMPRESSION => 'NONE', VERSIO
NS => '1', TTL => '2147483647', MIN_VERSIONS => '0', KEEP_DELETED_CELLS =>
'false', BLOCKSIZE => '655
36', IN_MEMORY => 'false', BLOCKCACHE => 'true'}
{code}
> java.lang.OutOfMemoryError: unable to create new native thread
> --------------------------------------------------------------
>
> Key: PHOENIX-1437
> URL: https://issues.apache.org/jira/browse/PHOENIX-1437
> Project: Phoenix
> Issue Type: Bug
> Reporter: Taylor Finnell
>
> Getting a java.lang.OutOfMemoryError when using Phoenix on Storm. Here is the
> full stack trace.
> {code}
> java.lang.OutOfMemoryError: unable to create new native thread
> at java.lang.Thread.start0(Native Method) ~[na:1.7.0_45]
> at java.lang.Thread.start(java/lang/Thread.java:713) ~[na:1.7.0_45]
> at
> java.util.concurrent.ThreadPoolExecutor.addWorker(java/util/concurrent/ThreadPoolExecutor.java:949)
> ~[na:1.7.0_45]
> at
> java.util.concurrent.ThreadPoolExecutor.execute(java/util/concurrent/ThreadPoolExecutor.java:1360)
> ~[na:1.7.0_45]
> at
> java.util.concurrent.AbstractExecutorService.submit(java/util/concurrent/AbstractExecutorService.java:132)
> ~[na:1.7.0_45]
> at
> org.apache.phoenix.iterate.ParallelIterators.submitWork(org/apache/phoenix/iterate/ParallelIterators.java:356)
> ~[stormjar.jar:na]
> at
> org.apache.phoenix.iterate.ParallelIterators.getIterators(org/apache/phoenix/iterate/ParallelIterators.java:265)
> ~[stormjar.jar:na]
> at
> org.apache.phoenix.iterate.ConcatResultIterator.getIterators(org/apache/phoenix/iterate/ConcatResultIterator.java:44)
> ~[stormjar.jar:na]
> at
> org.apache.phoenix.iterate.ConcatResultIterator.currentIterator(org/apache/phoenix/iterate/ConcatResultIterator.java:66)
> ~[stormjar.jar:na]
> at
> org.apache.phoenix.iterate.ConcatResultIterator.next(org/apache/phoenix/iterate/ConcatResultIterator.java:86)
> ~[stormjar.jar:na]
> at
> org.apache.phoenix.jdbc.PhoenixResultSet.next(org/apache/phoenix/jdbc/PhoenixResultSet.java:732)
> ~[stormjar.jar:na]
> at java.lang.reflect.Method.invoke(java/lang/reflect/Method.java:606)
> ~[na:1.7.0_45]
> at
> RUBY.each(file:/mnt/hadoop/storm/supervisor/stormdist/korrelate_match_log_processor_staging_KOR-2325-online_sync_to_hbase_tf_part_three-1-1415715986/stormjar.jar!/lib/korrelate_match_log_processor/cleanroom_online_event_adapter.rb:51)
> ~[na:na]
> at
> RUBY.finish_batch(file:/mnt/hadoop/storm/supervisor/stormdist/korrelate_match_log_processor_staging_KOR-2325-online_sync_to_hbase_tf_part_three-1-1415715986/stormjar.jar!/lib/korrelate_match_log_processor/bolt/abstract_event_reader_bolt.rb:68)
> ~[na:na]
> at
> RUBY.finishBatch(/Users/tfinnell/.rvm/gems/jruby-1.7.11@O2O-jruby/gems/redstorm-0.6.6/lib/red_storm/proxy/batch_bolt.rb:51)
> ~[na:na]
> at
> redstorm.proxy.BatchBolt.finishBatch(redstorm/proxy/BatchBolt.java:149)
> ~[stormjar.jar:na]
> at
> redstorm.storm.jruby.JRubyTransactionalBolt.finishBatch(redstorm/storm/jruby/JRubyTransactionalBolt.java:56)
> ~[stormjar.jar:na]
> at
> backtype.storm.coordination.BatchBoltExecutor.finishedId(backtype/storm/coordination/BatchBoltExecutor.java:76)
> ~[storm-core-0.9.1.2.1.2.0-402.jar:0.9.1.2.1.2.0-402]
> at
> backtype.storm.coordination.CoordinatedBolt.checkFinishId(backtype/storm/coordination/CoordinatedBolt.java:259)
> ~[storm-core-0.9.1.2.1.2.0-402.jar:0.9.1.2.1.2.0-402]
> at
> backtype.storm.coordination.CoordinatedBolt.execute(backtype/storm/coordination/CoordinatedBolt.java:322)
> ~[storm-core-0.9.1.2.1.2.0-402.jar:0.9.1.2.1.2.0-402]
> at
> backtype.storm.daemon.executor$fn__4329$tuple_action_fn__4331.invoke(executor.clj:630)
> ~[storm-core-0.9.1.2.1.2.0-402.jar:0.9.1.2.1.2.0-402]
> at
> backtype.storm.daemon.executor$fn__4329$tuple_action_fn__4331.invoke(backtype/storm/daemon/executor.clj:630)
> ~[storm-core-0.9.1.2.1.2.0-402.jar:0.9.1.2.1.2.0-402]
> at
> backtype.storm.daemon.executor$mk_task_receiver$fn__4252.invoke(executor.clj:398)
> ~[storm-core-0.9.1.2.1.2.0-402.jar:0.9.1.2.1.2.0-402]
> at
> backtype.storm.daemon.executor$mk_task_receiver$fn__4252.invoke(backtype/storm/daemon/executor.clj:398)
> ~[storm-core-0.9.1.2.1.2.0-402.jar:0.9.1.2.1.2.0-402]
> at
> backtype.storm.disruptor$clojure_handler$reify__1747.onEvent(disruptor.clj:58)
> ~[storm-core-0.9.1.2.1.2.0-402.jar:0.9.1.2.1.2.0-402]
> at
> backtype.storm.disruptor$clojure_handler$reify__1747.onEvent(backtype/storm/disruptor.clj:58)
> ~[storm-core-0.9.1.2.1.2.0-402.jar:0.9.1.2.1.2.0-402]
> at
> backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(backtype/storm/utils/DisruptorQueue.java:104)
> ~[storm-core-0.9.1.2.1.2.0-402.jar:0.9.1.2.1.2.0-402]
> at
> backtype.storm.utils.DisruptorQueue.consumeBatchWhenAvailable(backtype/storm/utils/DisruptorQueue.java:78)
> ~[storm-core-0.9.1.2.1.2.0-402.jar:0.9.1.2.1.2.0-402]
> at
> backtype.storm.disruptor$consume_batch_when_available.invoke(disruptor.clj:77)
> ~[storm-core-0.9.1.2.1.2.0-402.jar:0.9.1.2.1.2.0-402]
> at
> backtype.storm.disruptor$consume_batch_when_available.invoke(backtype/storm/disruptor.clj:77)
> ~[storm-core-0.9.1.2.1.2.0-402.jar:0.9.1.2.1.2.0-402]
> at
> backtype.storm.daemon.executor$fn__4329$fn__4341$fn__4388.invoke(executor.clj:745)
> ~[storm-core-0.9.1.2.1.2.0-402.jar:0.9.1.2.1.2.0-402]
> at
> backtype.storm.daemon.executor$fn__4329$fn__4341$fn__4388.invoke(backtype/storm/daemon/executor.clj:745)
> ~[storm-core-0.9.1.2.1.2.0-402.jar:0.9.1.2.1.2.0-402]
> at backtype.storm.util$async_loop$fn__442.invoke(util.clj:436)
> ~[storm-core-0.9.1.2.1.2.0-402.jar:0.9.1.2.1.2.0-402]
> at
> backtype.storm.util$async_loop$fn__442.invoke(backtype/storm/util.clj:436)
> ~[storm-core-0.9.1.2.1.2.0-402.jar:0.9.1.2.1.2.0-402]
> at clojure.lang.AFn.run(clojure/lang/AFn.java:24)
> ~[clojure-1.4.0.jar:na]
> at java.lang.Thread.run(java/lang/Thread.java:744) ~[na:1.7.0_45]
> {code}
> Here is some of the system configuration.
> {code}
> ulimit -a
> core file size (blocks, -c) 0
> data seg size (kbytes, -d) unlimited
> scheduling priority (-e) 0
> file size (blocks, -f) unlimited
> pending signals (-i) 240435
> max locked memory (kbytes, -l) 64
> max memory size (kbytes, -m) unlimited
> open files (-n) 1024
> pipe size (512 bytes, -p) 8
> POSIX message queues (bytes, -q) 819200
> real-time priority (-r) 0
> stack size (kbytes, -s) 10240
> cpu time (seconds, -t) unlimited
> max user processes (-u) 240435
> virtual memory (kbytes, -v) unlimited
> file locks (-x) unlimited
> {code}
> None of the tables I am querying against have more than 4 regions.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
