I restarted Storm and ingest some data over the last few hours. I still get
the casual NPE but some data gets profiled. It definitely skips data as I
fed 160 unique tld's but only get 9 mad profile entries. The list seems
random as I would least expect my top talkers to show up.


[Stellar]>>> OUTLIER_MAD_STATE_MERGE(PROFILE_GET('sketchy_mad', 'krxd.net',
5, 'HOURS'))
org.apache.metron.statistics.outlier.MedianAbsoluteDeviationFunctions$State@5b307115
[Stellar]>>> PROFILE_GET('sketchy_mad', 'krxd.net', 5, 'HOURS')
[]
[Stellar]>>> OUTLIER_MAD_STATE_MERGE(PROFILE_GET('sketchy_mad', 'krxd.net',
5, 'MINUTES'))
org.apache.metron.statistics.outlier.MedianAbsoluteDeviationFunctions$State@714c575b
[Stellar]>>> PROFILE_GET('sketchy_mad', 'krxd.net', 5, 'MINUTES')
[]

[Stellar]>>> bytes := 700
[Stellar]>>> OUTLIER_MAD_SCORE( OUTLIER_MAD_STATE_MERGE( PROFILE_GET(
'sketchy_mad', 'krxd.net', 5, 'MINUTES')), bytes)
NaN
[Stellar]>>> OUTLIER_MAD_SCORE( OUTLIER_MAD_STATE_MERGE( PROFILE_GET(
'sketchy_mad', 'krxd.net', 5, 'HOURS')), bytes)
NaN
[Stellar]>>> OUTLIER_MAD_SCORE( OUTLIER_MAD_STATE_MERGE( PROFILE_GET(
'sketchy_mad', 'krxd.net', 5, 'DAYS')), bytes)
3.8971111111111107


# echo "scan 'profiler'" | hbase shell > /tmp/test.txt && egrep
'sketchy_mad' /tmp/test.txt | awk '{print $1}'
\x00\x00\x00xsketchy_madoptimicdn.com\x00\x00\x00\x00\x00\x19;s
\x00\x00\x01dsketchy_madajax.googleapis.com\x00\x00\x00\x00\x00\x19;g
\x00\x00\x02\x86sketchy_madrlcdn.com\x00\x00\x00\x00\x00\x19;c
\x00\x00\x02\x86sketchy_madshareaholic.com\x00\x00\x00\x00\x00\x19;c
\x00\x00\x02\xDBsketchy_madnewsnetz.ch\x00\x00\x00\x00\x00\x19;k
\xFF\xFF\xFC\x8Esketchy_madajax.googleapis.com\x00\x00\x00\x00\x00\x19;r
\xFF\xFF\xFC\xEBsketchy_madkrxd.net\x00\x00\x00\x00\x00\x19;[
\xFF\xFF\xFE\x87sketchy_madkrxd.net\x00\x00\x00\x00\x00\x19;^
\xFF\xFF\xFE\xF2sketchy_madoptimicdn.com\x00\x00\x00\x00\x00\x19;\x5C

On Tue, Feb 28, 2017 at 8:10 AM, Casey Stella <ceste...@gmail.com> wrote:

> Ok, from the Stellar REPL (started with -z and the zookeeper quorum), what
> does the following yield:
>
>    - OUTLIER_MAD_STATE_MERGE(PROFILE_GET('sketchy_mad', 'krxd.net', 5,
>    'HOURS'))
>    - PROFILE_GET('sketchy_mad', 'krxd.net', 5, 'HOURS')
>    - OUTLIER_MAD_STATE_MERGE(PROFILE_GET('sketchy_mad', 'krxd.net', 5,
>    'MINUTES'))
>    - PROFILE_GET('sketchy_mad', 'krxd.net', 5, 'MINUTES')
>
>
> On Tue, Feb 28, 2017 at 1:36 AM, shoggi <sho...@gmail.com> wrote:
>
>> This is what I've got..
>>
>>     {
>>       "profile": "sketchy_mad",
>>       "foreach": "if exists(domain_without_subdomains) then
>> domain_without_subdomains else 'n/a'",
>>       "onlyif": "exists(domain_without_subdomains) && source.type ==
>> 'squid'",
>>       "init" : {
>>         "s": "OUTLIER_MAD_STATE_MERGE(PROFILE_GET('sketchy_mad',
>> domain_without_subdomains, 5, 'MINUTES'))"
>>       },
>>       "update": {
>>         "s": "OUTLIER_MAD_ADD(s, bytes)"
>>       },
>>       "result": "s"
>>     }
>>
>> On Tue, Feb 28, 2017 at 3:34 AM, Casey Stella <ceste...@gmail.com> wrote:
>>
>>> Sorry, waht does the current profile config look like for that very last
>>> error?
>>>
>>> On Mon, Feb 27, 2017 at 6:39 PM, shoggi <sho...@gmail.com> wrote:
>>>
>>>> Seems not to be the culprit..
>>>>
>>>>
>>>> 2017-02-28 00:35:43.367 o.a.m.p.b.ProfileBuilderBolt [INFO] Flushing
>>>> profile: profile=sketchy_mad, entity=optimicdn.com
>>>> 2017-02-28 00:35:43.368 o.a.m.p.b.ProfileBuilderBolt [ERROR] Unexpected
>>>> failure: message='Unable to execute: org.apache.metron.statistics.o
>>>> utlier.MedianAbsoluteDeviationFunctions$State cannot be cast to
>>>> java.util.List', tuple='source: __system:-1, stream: __tick, id: {}, [900]'
>>>> org.apache.metron.common.dsl.ParseException: Unable to execute:
>>>> org.apache.metron.statistics.outlier.MedianAbsoluteDeviationFunctions$State
>>>> cannot be cast to java.util.List
>>>> at 
>>>> org.apache.metron.common.stellar.StellarCompiler.getResult(StellarCompiler.java:428)
>>>> ~[stormjar.jar:?]
>>>> at 
>>>> org.apache.metron.common.stellar.BaseStellarProcessor.parse(BaseStellarProcessor.java:90)
>>>> ~[stormjar.jar:?]
>>>> at org.apache.metron.profiler.stellar.DefaultStellarExecutor.ex
>>>> ecute(DefaultStellarExecutor.java:148) ~[stormjar.jar:?]
>>>> at org.apache.metron.profiler.stellar.DefaultStellarExecutor.as
>>>> sign(DefaultStellarExecutor.java:94) ~[stormjar.jar:?]
>>>> at org.apache.metron.profiler.bolt.ProfileBuilderBolt.lambda$nu
>>>> ll$2(ProfileBuilderBolt.java:258) ~[stormjar.jar:?]
>>>> at java.util.LinkedHashMap.forEach(LinkedHashMap.java:676)
>>>> ~[?:1.8.0_77]
>>>> at org.apache.metron.profiler.bolt.ProfileBuilderBolt.lambda$fl
>>>> ush$4(ProfileBuilderBolt.java:258) ~[stormjar.jar:?]
>>>> at java.util.concurrent.ConcurrentMap.forEach(ConcurrentMap.java:114)
>>>> ~[?:1.8.0_77]
>>>> at 
>>>> org.apache.metron.profiler.bolt.ProfileBuilderBolt.flush(ProfileBuilderBolt.java:237)
>>>> ~[stormjar.jar:?]
>>>> at 
>>>> org.apache.metron.profiler.bolt.ProfileBuilderBolt.doExecute(ProfileBuilderBolt.java:164)
>>>> ~[stormjar.jar:?]
>>>> at 
>>>> org.apache.metron.profiler.bolt.ProfileBuilderBolt.execute(ProfileBuilderBolt.java:144)
>>>> [stormjar.jar:?]
>>>> at 
>>>> org.apache.storm.daemon.executor$fn__6571$tuple_action_fn__6573.invoke(executor.clj:734)
>>>> [storm-core-1.0.1.2.5.0.0-1245.jar:1.0.1.2.5.0.0-1245]
>>>> at 
>>>> org.apache.storm.daemon.executor$mk_task_receiver$fn__6492.invoke(executor.clj:469)
>>>> [storm-core-1.0.1.2.5.0.0-1245.jar:1.0.1.2.5.0.0-1245]
>>>> at 
>>>> org.apache.storm.disruptor$clojure_handler$reify__6005.onEvent(disruptor.clj:40)
>>>> [storm-core-1.0.1.2.5.0.0-1245.jar:1.0.1.2.5.0.0-1245]
>>>> at 
>>>> org.apache.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:451)
>>>> [storm-core-1.0.1.2.5.0.0-1245.jar:1.0.1.2.5.0.0-1245]
>>>> at 
>>>> org.apache.storm.utils.DisruptorQueue.consumeBatchWhenAvailable(DisruptorQueue.java:430)
>>>> [storm-core-1.0.1.2.5.0.0-1245.jar:1.0.1.2.5.0.0-1245]
>>>> at 
>>>> org.apache.storm.disruptor$consume_batch_when_available.invoke(disruptor.clj:73)
>>>> [storm-core-1.0.1.2.5.0.0-1245.jar:1.0.1.2.5.0.0-1245]
>>>> at 
>>>> org.apache.storm.daemon.executor$fn__6571$fn__6584$fn__6637.invoke(executor.clj:853)
>>>> [storm-core-1.0.1.2.5.0.0-1245.jar:1.0.1.2.5.0.0-1245]
>>>> at org.apache.storm.util$async_loop$fn__554.invoke(util.clj:484)
>>>> [storm-core-1.0.1.2.5.0.0-1245.jar:1.0.1.2.5.0.0-1245]
>>>> at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
>>>> at java.lang.Thread.run(Thread.java:745) [?:1.8.0_77]
>>>> Caused by: java.lang.ClassCastException: org.apache.metron.statistics.o
>>>> utlier.MedianAbsoluteDeviationFunctions$State cannot be cast to
>>>> java.util.List
>>>> at org.apache.metron.statistics.outlier.MedianAbsoluteDeviation
>>>> Functions$StateUpdate.apply(MedianAbsoluteDeviationFunctions.java:85)
>>>> ~[stormjar.jar:?]
>>>> at org.apache.metron.common.stellar.StellarCompiler.exitTransfo
>>>> rmationFunc(StellarCompiler.java:246) ~[stormjar.jar:?]
>>>> at org.apache.metron.common.stellar.generated.StellarParser$Tra
>>>> nsformationFuncContext.exitRule(StellarParser.java:1617)
>>>> ~[stormjar.jar:?]
>>>> at org.antlr.v4.runtime.Parser.triggerExitRuleEvent(Parser.java:422)
>>>> ~[stormjar.jar:?]
>>>> at org.antlr.v4.runtime.Parser.exitRule(Parser.java:632)
>>>> ~[stormjar.jar:?]
>>>> at org.apache.metron.common.stellar.generated.StellarParser.fun
>>>> ctions(StellarParser.java:1640) ~[stormjar.jar:?]
>>>> at org.apache.metron.common.stellar.generated.StellarParser.ari
>>>> thmetic_operands(StellarParser.java:1750) ~[stormjar.jar:?]
>>>> at org.apache.metron.common.stellar.generated.StellarParser.ari
>>>> thmetic_expr_mul(StellarParser.java:1537) ~[stormjar.jar:?]
>>>> at org.apache.metron.common.stellar.generated.StellarParser.ari
>>>> thmetic_expr(StellarParser.java:1397) ~[stormjar.jar:?]
>>>> at org.apache.metron.common.stellar.generated.StellarParser.tra
>>>> nsformation_expr(StellarParser.java:278) ~[stormjar.jar:?]
>>>> at org.apache.metron.common.stellar.generated.StellarParser.tra
>>>> nsformation(StellarParser.java:147) ~[stormjar.jar:?]
>>>> at 
>>>> org.apache.metron.common.stellar.BaseStellarProcessor.parse(BaseStellarProcessor.java:89)
>>>> ~[stormjar.jar:?]
>>>> ... 19 more
>>>>
>>>> On Tue, Feb 28, 2017 at 12:18 AM, Casey Stella <ceste...@gmail.com>
>>>> wrote:
>>>>
>>>>> Ok, try something for me and tell me if it fixes it: adjust the config
>>>>> to remove the tickUpdate (it didn't work anyway and we have since removed
>>>>> it in 0.3.1).
>>>>>
>>>>>
>>>>> On Mon, Feb 27, 2017 at 6:07 PM, shoggi <sho...@gmail.com> wrote:
>>>>>
>>>>>> Yes, this is 0.3.0.
>>>>>>
>>>>>> Here is the full trace.
>>>>>>
>>>>>> 2017-02-28 00:05:43.367 o.a.m.p.b.ProfileBuilderBolt [INFO] Flushing
>>>>>> profile: profile=sketchy_mad, entity=krxd.net
>>>>>> 2017-02-28 00:05:43.374 o.a.m.p.b.ProfileBuilderBolt [ERROR]
>>>>>> Unexpected failure: message='Unable to execute:
>>>>>> org.apache.metron.statistics.outlier.MedianAbsoluteDeviationFunctions$State
>>>>>> cannot be cast to java.util.List', tuple='source: __system:-1, stream:
>>>>>> __tick, id: {}, [900]'
>>>>>> org.apache.metron.common.dsl.ParseException: Unable to execute:
>>>>>> org.apache.metron.statistics.outlier.MedianAbsoluteDeviationFunctions$State
>>>>>> cannot be cast to java.util.List
>>>>>> at 
>>>>>> org.apache.metron.common.stellar.StellarCompiler.getResult(StellarCompiler.java:428)
>>>>>> ~[stormjar.jar:?]
>>>>>> at 
>>>>>> org.apache.metron.common.stellar.BaseStellarProcessor.parse(BaseStellarProcessor.java:90)
>>>>>> ~[stormjar.jar:?]
>>>>>> at org.apache.metron.profiler.stellar.DefaultStellarExecutor.ex
>>>>>> ecute(DefaultStellarExecutor.java:148) ~[stormjar.jar:?]
>>>>>> at org.apache.metron.profiler.stellar.DefaultStellarExecutor.as
>>>>>> sign(DefaultStellarExecutor.java:94) ~[stormjar.jar:?]
>>>>>> at org.apache.metron.profiler.bolt.ProfileBuilderBolt.lambda$nu
>>>>>> ll$2(ProfileBuilderBolt.java:258) ~[stormjar.jar:?]
>>>>>> at java.util.LinkedHashMap.forEach(LinkedHashMap.java:676)
>>>>>> ~[?:1.8.0_77]
>>>>>> at org.apache.metron.profiler.bolt.ProfileBuilderBolt.lambda$fl
>>>>>> ush$4(ProfileBuilderBolt.java:258) ~[stormjar.jar:?]
>>>>>> at java.util.concurrent.ConcurrentMap.forEach(ConcurrentMap.java:114)
>>>>>> ~[?:1.8.0_77]
>>>>>> at 
>>>>>> org.apache.metron.profiler.bolt.ProfileBuilderBolt.flush(ProfileBuilderBolt.java:237)
>>>>>> ~[stormjar.jar:?]
>>>>>> at 
>>>>>> org.apache.metron.profiler.bolt.ProfileBuilderBolt.doExecute(ProfileBuilderBolt.java:164)
>>>>>> ~[stormjar.jar:?]
>>>>>> at 
>>>>>> org.apache.metron.profiler.bolt.ProfileBuilderBolt.execute(ProfileBuilderBolt.java:144)
>>>>>> [stormjar.jar:?]
>>>>>> at 
>>>>>> org.apache.storm.daemon.executor$fn__6571$tuple_action_fn__6573.invoke(executor.clj:734)
>>>>>> [storm-core-1.0.1.2.5.0.0-1245.jar:1.0.1.2.5.0.0-1245]
>>>>>> at 
>>>>>> org.apache.storm.daemon.executor$mk_task_receiver$fn__6492.invoke(executor.clj:469)
>>>>>> [storm-core-1.0.1.2.5.0.0-1245.jar:1.0.1.2.5.0.0-1245]
>>>>>> at 
>>>>>> org.apache.storm.disruptor$clojure_handler$reify__6005.onEvent(disruptor.clj:40)
>>>>>> [storm-core-1.0.1.2.5.0.0-1245.jar:1.0.1.2.5.0.0-1245]
>>>>>> at 
>>>>>> org.apache.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:451)
>>>>>> [storm-core-1.0.1.2.5.0.0-1245.jar:1.0.1.2.5.0.0-1245]
>>>>>> at 
>>>>>> org.apache.storm.utils.DisruptorQueue.consumeBatchWhenAvailable(DisruptorQueue.java:430)
>>>>>> [storm-core-1.0.1.2.5.0.0-1245.jar:1.0.1.2.5.0.0-1245]
>>>>>> at 
>>>>>> org.apache.storm.disruptor$consume_batch_when_available.invoke(disruptor.clj:73)
>>>>>> [storm-core-1.0.1.2.5.0.0-1245.jar:1.0.1.2.5.0.0-1245]
>>>>>> at 
>>>>>> org.apache.storm.daemon.executor$fn__6571$fn__6584$fn__6637.invoke(executor.clj:853)
>>>>>> [storm-core-1.0.1.2.5.0.0-1245.jar:1.0.1.2.5.0.0-1245]
>>>>>> at org.apache.storm.util$async_loop$fn__554.invoke(util.clj:484)
>>>>>> [storm-core-1.0.1.2.5.0.0-1245.jar:1.0.1.2.5.0.0-1245]
>>>>>> at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
>>>>>> at java.lang.Thread.run(Thread.java:745) [?:1.8.0_77]
>>>>>> Caused by: java.lang.ClassCastException:
>>>>>> org.apache.metron.statistics.outlier.MedianAbsoluteDeviationFunctions$State
>>>>>> cannot be cast to java.util.List
>>>>>> at org.apache.metron.statistics.outlier.MedianAbsoluteDeviation
>>>>>> Functions$StateUpdate.apply(MedianAbsoluteDeviationFunctions.java:85)
>>>>>> ~[stormjar.jar:?]
>>>>>> at org.apache.metron.common.stellar.StellarCompiler.exitTransfo
>>>>>> rmationFunc(StellarCompiler.java:246) ~[stormjar.jar:?]
>>>>>> at org.apache.metron.common.stellar.generated.StellarParser$Tra
>>>>>> nsformationFuncContext.exitRule(StellarParser.java:1617)
>>>>>> ~[stormjar.jar:?]
>>>>>> at org.antlr.v4.runtime.Parser.triggerExitRuleEvent(Parser.java:422)
>>>>>> ~[stormjar.jar:?]
>>>>>> at org.antlr.v4.runtime.Parser.exitRule(Parser.java:632)
>>>>>> ~[stormjar.jar:?]
>>>>>> at org.apache.metron.common.stellar.generated.StellarParser.fun
>>>>>> ctions(StellarParser.java:1640) ~[stormjar.jar:?]
>>>>>> at org.apache.metron.common.stellar.generated.StellarParser.ari
>>>>>> thmetic_operands(StellarParser.java:1750) ~[stormjar.jar:?]
>>>>>> at org.apache.metron.common.stellar.generated.StellarParser.ari
>>>>>> thmetic_expr_mul(StellarParser.java:1537) ~[stormjar.jar:?]
>>>>>> at org.apache.metron.common.stellar.generated.StellarParser.ari
>>>>>> thmetic_expr(StellarParser.java:1397) ~[stormjar.jar:?]
>>>>>> at org.apache.metron.common.stellar.generated.StellarParser.tra
>>>>>> nsformation_expr(StellarParser.java:278) ~[stormjar.jar:?]
>>>>>> at org.apache.metron.common.stellar.generated.StellarParser.tra
>>>>>> nsformation(StellarParser.java:147) ~[stormjar.jar:?]
>>>>>> at 
>>>>>> org.apache.metron.common.stellar.BaseStellarProcessor.parse(BaseStellarProcessor.java:89)
>>>>>> ~[stormjar.jar:?]
>>>>>> ... 19 more
>>>>>> 2017-02-28 00:05:43.377 o.a.s.d.executor [ERROR]
>>>>>> org.apache.metron.common.dsl.ParseException: Unable to execute:
>>>>>> org.apache.metron.statistics.outlier.MedianAbsoluteDeviationFunctions$State
>>>>>> cannot be cast to java.util.List
>>>>>> at 
>>>>>> org.apache.metron.common.stellar.StellarCompiler.getResult(StellarCompiler.java:428)
>>>>>> ~[stormjar.jar:?]
>>>>>> at 
>>>>>> org.apache.metron.common.stellar.BaseStellarProcessor.parse(BaseStellarProcessor.java:90)
>>>>>> ~[stormjar.jar:?]
>>>>>> at org.apache.metron.profiler.stellar.DefaultStellarExecutor.ex
>>>>>> ecute(DefaultStellarExecutor.java:148) ~[stormjar.jar:?]
>>>>>> at org.apache.metron.profiler.stellar.DefaultStellarExecutor.as
>>>>>> sign(DefaultStellarExecutor.java:94) ~[stormjar.jar:?]
>>>>>> at org.apache.metron.profiler.bolt.ProfileBuilderBolt.lambda$nu
>>>>>> ll$2(ProfileBuilderBolt.java:258) ~[stormjar.jar:?]
>>>>>> at java.util.LinkedHashMap.forEach(LinkedHashMap.java:676)
>>>>>> ~[?:1.8.0_77]
>>>>>> at org.apache.metron.profiler.bolt.ProfileBuilderBolt.lambda$fl
>>>>>> ush$4(ProfileBuilderBolt.java:258) ~[stormjar.jar:?]
>>>>>> at java.util.concurrent.ConcurrentMap.forEach(ConcurrentMap.java:114)
>>>>>> ~[?:1.8.0_77]
>>>>>> at 
>>>>>> org.apache.metron.profiler.bolt.ProfileBuilderBolt.flush(ProfileBuilderBolt.java:237)
>>>>>> ~[stormjar.jar:?]
>>>>>> at 
>>>>>> org.apache.metron.profiler.bolt.ProfileBuilderBolt.doExecute(ProfileBuilderBolt.java:164)
>>>>>> ~[stormjar.jar:?]
>>>>>> at 
>>>>>> org.apache.metron.profiler.bolt.ProfileBuilderBolt.execute(ProfileBuilderBolt.java:144)
>>>>>> [stormjar.jar:?]
>>>>>> at 
>>>>>> org.apache.storm.daemon.executor$fn__6571$tuple_action_fn__6573.invoke(executor.clj:734)
>>>>>> [storm-core-1.0.1.2.5.0.0-1245.jar:1.0.1.2.5.0.0-1245]
>>>>>> at 
>>>>>> org.apache.storm.daemon.executor$mk_task_receiver$fn__6492.invoke(executor.clj:469)
>>>>>> [storm-core-1.0.1.2.5.0.0-1245.jar:1.0.1.2.5.0.0-1245]
>>>>>> at 
>>>>>> org.apache.storm.disruptor$clojure_handler$reify__6005.onEvent(disruptor.clj:40)
>>>>>> [storm-core-1.0.1.2.5.0.0-1245.jar:1.0.1.2.5.0.0-1245]
>>>>>> at 
>>>>>> org.apache.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:451)
>>>>>> [storm-core-1.0.1.2.5.0.0-1245.jar:1.0.1.2.5.0.0-1245]
>>>>>> at 
>>>>>> org.apache.storm.utils.DisruptorQueue.consumeBatchWhenAvailable(DisruptorQueue.java:430)
>>>>>> [storm-core-1.0.1.2.5.0.0-1245.jar:1.0.1.2.5.0.0-1245]
>>>>>> at 
>>>>>> org.apache.storm.disruptor$consume_batch_when_available.invoke(disruptor.clj:73)
>>>>>> [storm-core-1.0.1.2.5.0.0-1245.jar:1.0.1.2.5.0.0-1245]
>>>>>> at 
>>>>>> org.apache.storm.daemon.executor$fn__6571$fn__6584$fn__6637.invoke(executor.clj:853)
>>>>>> [storm-core-1.0.1.2.5.0.0-1245.jar:1.0.1.2.5.0.0-1245]
>>>>>> at org.apache.storm.util$async_loop$fn__554.invoke(util.clj:484)
>>>>>> [storm-core-1.0.1.2.5.0.0-1245.jar:1.0.1.2.5.0.0-1245]
>>>>>> at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
>>>>>> at java.lang.Thread.run(Thread.java:745) [?:1.8.0_77]
>>>>>> Caused by: java.lang.ClassCastException:
>>>>>> org.apache.metron.statistics.outlier.MedianAbsoluteDeviationFunctions$State
>>>>>> cannot be cast to java.util.List
>>>>>> at org.apache.metron.statistics.outlier.MedianAbsoluteDeviation
>>>>>> Functions$StateUpdate.apply(MedianAbsoluteDeviationFunctions.java:85)
>>>>>> ~[stormjar.jar:?]
>>>>>> at org.apache.metron.common.stellar.StellarCompiler.exitTransfo
>>>>>> rmationFunc(StellarCompiler.java:246) ~[stormjar.jar:?]
>>>>>> at org.apache.metron.common.stellar.generated.StellarParser$Tra
>>>>>> nsformationFuncContext.exitRule(StellarParser.java:1617)
>>>>>> ~[stormjar.jar:?]
>>>>>> at org.antlr.v4.runtime.Parser.triggerExitRuleEvent(Parser.java:422)
>>>>>> ~[stormjar.jar:?]
>>>>>> at org.antlr.v4.runtime.Parser.exitRule(Parser.java:632)
>>>>>> ~[stormjar.jar:?]
>>>>>> at org.apache.metron.common.stellar.generated.StellarParser.fun
>>>>>> ctions(StellarParser.java:1640) ~[stormjar.jar:?]
>>>>>> at org.apache.metron.common.stellar.generated.StellarParser.ari
>>>>>> thmetic_operands(StellarParser.java:1750) ~[stormjar.jar:?]
>>>>>> at org.apache.metron.common.stellar.generated.StellarParser.ari
>>>>>> thmetic_expr_mul(StellarParser.java:1537) ~[stormjar.jar:?]
>>>>>> at org.apache.metron.common.stellar.generated.StellarParser.ari
>>>>>> thmetic_expr(StellarParser.java:1397) ~[stormjar.jar:?]
>>>>>> at org.apache.metron.common.stellar.generated.StellarParser.tra
>>>>>> nsformation_expr(StellarParser.java:278) ~[stormjar.jar:?]
>>>>>> at org.apache.metron.common.stellar.generated.StellarParser.tra
>>>>>> nsformation(StellarParser.java:147) ~[stormjar.jar:?]
>>>>>> at 
>>>>>> org.apache.metron.common.stellar.BaseStellarProcessor.parse(BaseStellarProcessor.java:89)
>>>>>> ~[stormjar.jar:?]
>>>>>> ... 19 more
>>>>>>
>>>>>>
>>>>>>
>>>>>> On Mon, Feb 27, 2017 at 11:33 PM, Casey Stella <ceste...@gmail.com>
>>>>>> wrote:
>>>>>>
>>>>>>> Any chance there's a full stacktrace associated with that NPE
>>>>>>> anywhere?  Also, I assume this is 0.3.0, right?
>>>>>>>
>>>>>>> On Mon, Feb 27, 2017 at 5:29 PM, shoggi <sho...@gmail.com> wrote:
>>>>>>>
>>>>>>>> Hi all
>>>>>>>>
>>>>>>>> Has anyone come across following profiler error, when trying to
>>>>>>>> work with the MAD functions? The configuration loads fine and I only 
>>>>>>>> get
>>>>>>>> the error when the profiler is pushing its data. I don't think its a 
>>>>>>>> typo
>>>>>>>> but maybe the logic is not sound.
>>>>>>>>
>>>>>>>> Error from the profiler worker:
>>>>>>>> 2017-02-27 23:20:43.368 o.a.m.p.b.ProfileBuilderBolt [INFO]
>>>>>>>> Flushing profile: profile=sketchy_mad, entity=krxd.net
>>>>>>>> 2017-02-27 23:20:43.368 o.a.m.p.b.ProfileBuilderBolt [ERROR]
>>>>>>>> Unexpected failure: message='null', tuple='source: __system:-1, stream:
>>>>>>>> __tick, id: {}, [900]'
>>>>>>>> java.lang.NullPointerException
>>>>>>>> 2017-02-27 23:20:43.368 o.a.s.d.executor [ERROR]
>>>>>>>> java.lang.NullPointerException
>>>>>>>>
>>>>>>>>
>>>>>>>> My Profiler config:
>>>>>>>>
>>>>>>>>     {
>>>>>>>>       "profile": "sketchy_mad",
>>>>>>>>       "foreach": "if exists(domain_without_subdomains) then
>>>>>>>> domain_without_subdomains else 'n/a'",
>>>>>>>>       "onlyif": "exists(domain_without_subdomains) && source.type
>>>>>>>> == 'squid'",
>>>>>>>>       "init" : {
>>>>>>>>         "s": "OUTLIER_MAD_STATE_MERGE(PROFILE_GET('sketchy_mad',
>>>>>>>> domain_without_subdomains, 5, 'MINUTES'))"
>>>>>>>>       },
>>>>>>>>       "tickUpdate" : {
>>>>>>>>         "s": "OUTLIER_MAD_STATE_MERGE(PROFILE_GET('sketchy_mad',
>>>>>>>> domain_without_subdomains, 5, 'MINUTES'), s)"
>>>>>>>>       },
>>>>>>>>       "update": {
>>>>>>>>         "s": "OUTLIER_MAD_ADD(s, bytes)"
>>>>>>>>       },
>>>>>>>>       "result": "s"
>>>>>>>>     }
>>>>>>>>
>>>>>>>> Regards
>>>>>>>> shoggi
>>>>>>>>
>>>>>>>
>>>>>>>
>>>>>>
>>>>>
>>>>
>>>
>>
>

Reply via email to