onyx

FYI: alternative Onyx :onyx: chat is at <https://gitter.im/onyx-platform/onyx> ; log can be found at <https://clojurians-log.clojureverse.org/onyx/index.html>
lucasbradstreet 2018-11-15T01:20:06.025600Z

@lutz.buech might be worth checking the code to see if it’s setting the region even if the endpoint is set. I know someone had it working with minio in the past

lucasbradstreet 2018-11-15T01:20:27.026300Z

@lellis which computing tree are you referring to?

lellis 2018-11-15T01:47:20.027100Z

@lucasbradstreet all tasks of workflow. [in….out]

lellis 2018-11-15T03:13:30.027400Z

when i mean tree of computation i mean all job done.

lellis 2018-11-15T03:18:30.027600Z

Reading the doc about ABS i understand that i can't control time out of a restart of an input, but this happens in my code, so how can i treat this? Or at least capture when its happens this.

manuel 2018-11-15T10:45:50.029300Z

hi everybody. I am trying to run this locally: https://github.com/onyx-platform/onyx-examples/tree/0.14.x/lifecycles I have Zookeeper running via docker with: docker run --name some-zookeeper --restart always -d zookeeper -p 2181:2181 But I get a ConnectionLoss error:

org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss for /onyx
    code: -4
    path: "/onyx"
Is there something I am missing?

manuel 2018-11-15T10:46:43.029800Z

This is the Zookeeper I am using, if it helps: https://hub.docker.com/_/zookeeper/

manuel 2018-11-15T11:51:50.030600Z

If I leave out -p 2181:2181, I see:

❯ docker ps
CONTAINER ID        IMAGE               COMMAND                  CREATED             STATUS              PORTS                          NAMES
30e63d362ba9        zookeeper           "/docker-entrypoint.…"   2 seconds ago       Up 1 second         2181/tcp, 2888/tcp, 3888/tcp   some-zookeeper
Running the example I now get:
❯ clj -A:run
[]

manuel 2018-11-15T11:53:14.031Z

these are the relevant changes I made in core.clj:

(def env-config
  {:zookeeper/address "127.0.0.1:2181"
   :zookeeper/server? true
   :zookeeper.server/port 2181
   :onyx/tenancy-id id})

(def peer-config
  {:zookeeper/address "127.0.0.1:2181"
   :onyx/tenancy-id id
   :onyx.peer/job-scheduler :onyx.job-scheduler/balanced
   :onyx.messaging/impl :aeron
   :onyx.messaging/peer-port 40200
   :onyx.messaging/bind-addr "localhost"})