Fork me on GitHub
#onyx
<
2015-09-18
>
lowl4tency22:09:26

michaeldrogalis: hi Michael

lowl4tency22:09:35

I have next errors on zookeeper

lowl4tency22:09:37

2015-09-18 22:04:24,249 [myid:] - INFO [ProcessThread(sid:0 cport:-1)[email protected]] - Got user-level KeeperException when processing sessionid:0x14fd65dd8ff00df type:create cxid:0xe zxid:0xd280 txntype:-1 reqpath:n/a Error Path:/onyx/4068bfc4-7049-4a9d-a4f3-0dc5dcdb3aa7/job-scheduler Error:KeeperErrorCode = NodeExists for /onyx/4068bfc4-7049-4a9d-a4f3-0dc5dcdb3aa7/job-scheduler 2015-09-18 22:04:24,250 [myid:] - INFO [ProcessThread(sid:0 cport:-1)[email protected]] - Got user-level KeeperException when processing sessionid:0x14fd65dd8ff00df type:create cxid:0xf zxid:0xd281 txntype:-1 reqpath:n/a Error Path:/onyx/4068bfc4-7049-4a9d-a4f3-0dc5dcdb3aa7/messaging Error:KeeperErrorCode = NodeExists for /onyx/4068bfc4-7049-4a9d-a4f3-0dc5dcdb3aa7/messaging

lowl4tency22:09:03

Have not an idea what is it and how to fix

arohner22:09:53

are there any docs on how to do real-time processing? I’ve perused the docs, and I think I understand how to make onyx do map-reduce style jobs, but I don’t understand how to make it do storm-style jobs

arohner22:09:28

taking a step back, I have some time-series data. I’d like to do some transducer-style processing to it, breaking into buckets and computing metrics, etc, then store those metrics in different buckets, per-minute, per-hour, per-day.

arohner22:09:56

ideally, I’d also like to be able to get a real-time view on the current hour “for the hour that is currently in process, the metric is X”. Does that sound like a good fit for onyx?

tcrayford22:09:22

@lowl4tency: that zookeeper error is probably fine

tcrayford22:09:45

Zookeeper is bad and logs a lot of "errors" that aren't actually errors

arohner22:09:18

ah, so for realtime, it’s all just core.async, so I don’t stick :done in the channel

arohner22:09:29

so then I just need an output channel that behaves the way I want

arohner23:09:19

one tap sending unique values to the DB, one tap that has the ‘current’ value