Simple example code doesn't work

46 views

Skip to first unread message

Keisuke Fukuda

unread,

Nov 29, 2015, 12:32:02 AM11/29/15

to Onyx

Hello,

I'm learning Onyx.

I've written a very small sample code but it doesn't work.

The code is here:

https://github.com/keisukefukuda/onyx-samples/blob/master/src/onyx_samples/sample1.clj

It is almost identical the "flat-workflow" example code in onyx-example repository.

https://github.com/onyx-platform/onyx-examples/tree/0.8.x/flat-workflow

The "flat-workflow" works fine in my environment and I have no idea why mine doesn't.

Not only the output channel is empty, but even "inject-input-ch" function is not invoked.

Could someone give me advice on this?

Log of the cider-repl session is shown below.

Thanks in advance.

Keisuke

; CIDER 0.10.0snapshot (package: 20150929.1314) (Java 1.8.0_60, Clojure 1.7.0, nREPL 0.2.10)

onyx-samples.sample1> (init)

#onyx_samples.sample1.OnyxDevEnv{:n-peers 1}

onyx-samples.sample1> (start)

Starting Onyx development environment

#onyx_samples.sample1.OnyxDevEnv{:n-peers 1, :env #onyx.system.OnyxDevelopmentEnv{:monitoring #onyx.monitoring.no_op_monitoring.NoOpMonitoringAgent{}, :logging-config #onyx.static.logging_configuration.LoggingConfiguration{:file "onyx.log", :config nil}, :bookkeeper #onyx.state.bookkeeper.BookieServers{:env-config {:zookeeper/address "127.0.0.1:2190", :zookeeper/server? true, :zookeeper.server/port 2190, :onyx/id #uuid "2c08f1c6-1354-4201-8f95-465d7df60d55"}, :log #onyx.log.zookeeper.ZooKeeper{:config {:zookeeper/address "127.0.0.1:2190", :zookeeper/server? true, :zookeeper.server/port 2190, :onyx/id #uuid "2c08f1c6-1354-4201-8f95-465d7df60d55"}, :monitoring #onyx.monitoring.no_op_monitoring.NoOpMonitoringAgent{}, :logging-config #onyx.static.logging_configuration.LoggingConfiguration{:file "onyx.log", :config nil}, :server #object[org.apache.curator.test.TestingServer 0x60d773e7 "org.apache.curator.test.TestingServer@60d773e7"], :conn #object[org.apache.curator.framework.imps.CuratorFrameworkImpl 0x150436d3 "org.apache.curator.framework.imps.CuratorFrameworkImpl@150436d3"], :prefix #uuid "2c08f1c6-1354-4201-8f95-465d7df60d55"}}, :log #onyx.log.zookeeper.ZooKeeper{:config {:zookeeper/address "127.0.0.1:2190", :zookeeper/server? true, :zookeeper.server/port 2190, :onyx/id #uuid "2c08f1c6-1354-4201-8f95-465d7df60d55"}, :monitoring #onyx.monitoring.no_op_monitoring.NoOpMonitoringAgent{}, :logging-config #onyx.static.logging_configuration.LoggingConfiguration{:file "onyx.log", :config nil}, :server #object[org.apache.curator.test.TestingServer 0x60d773e7 "org.apache.curator.test.TestingServer@60d773e7"], :conn #object[org.apache.curator.framework.imps.CuratorFrameworkImpl 0x150436d3 "org.apache.curator.framework.imps.CuratorFrameworkImpl@150436d3"], :prefix #uuid "2c08f1c6-1354-4201-8f95-465d7df60d55"}}, :peer-group #onyx.system.OnyxPeerGroup{:config {:zookeeper/address "127.0.0.1:2190", :onyx.peer/job-scheduler :onyx.job-scheduler/balanced, :onyx.messaging/impl :aeron, :onyx.messaging/peer-port 40201, :onyx.messaging/bind-addr "localhost", :onyx/id #uuid "2c08f1c6-1354-4201-8f95-465d7df60d55"}, :logging-config #onyx.static.logging_configuration.LoggingConfiguration{:file "onyx.log", :config nil}, :messaging-require :loaded, :messaging-group #onyx.messaging.aeron.AeronPeerGroup{:opts {:zookeeper/address "127.0.0.1:2190", :onyx.peer/job-scheduler :onyx.job-scheduler/balanced, :onyx.messaging/impl :aeron, :onyx.messaging/peer-port 40201, :onyx.messaging/bind-addr "localhost", :onyx/id #uuid "2c08f1c6-1354-4201-8f95-465d7df60d55"}, :publication-group #onyx.messaging.aeron.publication_group.PublicationGroup{:opts {:zookeeper/address "127.0.0.1:2190", :onyx.peer/job-scheduler :onyx.job-scheduler/balanced, :onyx.messaging/impl :aeron, :onyx.messaging/peer-port 40201, :onyx.messaging/bind-addr "localhost", :onyx/id #uuid "2c08f1c6-1354-4201-8f95-465d7df60d55"}, :send-idle-strategy #object[uk.co.real_logic.agrona.concurrent.BackoffIdleStrategy 0x4b9d8337 "uk.co.real_logic.agrona.concurrent.BackoffIdleStrategy@4b9d8337"], :publications #object[clojure.lang.Atom 0x43775df8 {:status :ready, :val {}}], :manager-thread #object[clojure.core.async.impl.channels.ManyToManyChannel 0x6454fa9a "clojure.core.async.impl.channels.ManyToManyChannel@6454fa9a"], :command-ch #object[clojure.core.async.impl.channels.ManyToManyChannel 0xf4a74ba "clojure.core.async.impl.channels.ManyToManyChannel@f4a74ba"], :shutdown-ch #object[clojure.core.async.impl.channels.ManyToManyChannel 0x60267f8b "clojure.core.async.impl.channels.ManyToManyChannel@60267f8b"]}, :subscribers [{:conn #object[uk.co.real_logic.aeron.Aeron 0x19c766ea "uk.co.real_logic.aeron.Aeron@19c766ea"], :subscription #object[uk.co.real_logic.aeron.Subscription 0x5a84df62 "uk.co.real_logic.aeron.Subscription@5a84df62"], :subscriber-fut #object[clojure.core$future_call$reify__6736 0x776cbe3d {:status :pending, :val nil}]} {:conn #object[uk.co.real_logic.aeron.Aeron 0xb6f007d "uk.co.real_logic.aeron.Aeron@b6f007d"], :subscription #object[uk.co.real_logic.aeron.Subscription 0x311b30c3 "uk.co.real_logic.aeron.Subscription@311b30c3"], :subscriber-fut #object[clojure.core$future_call$reify__6736 0x171158f4 {:status :pending, :val nil}]}], :subscriber-count 2, :compress-f #object[onyx.compression.nippy$messaging_compress 0x7681155b "onyx.compression.nippy$messaging_compress@7681155b"], :decompress-f #object[onyx.compression.nippy$messaging_decompress 0x3bf83a2 "onyx.compression.nippy$messaging_decompress@3bf83a2"], :send-idle-strategy #object[uk.co.real_logic.agrona.concurrent.BackoffIdleStrategy 0x4b9d8337 "uk.co.real_logic.agrona.concurrent.BackoffIdleStrategy@4b9d8337"], :messaging-require :loaded, :logging-config #onyx.static.logging_configuration.LoggingConfiguration{:file "onyx.log", :config nil}, :bind-addr "localhost", :external-addr "localhost", :external-channel "udp://localhost:40201", :media-driver-context #object[uk.co.real_logic.aeron.driver.MediaDriver$Context 0x725b6fc1 "uk.co.real_logic.aeron.driver.MediaDriver$Context@725b6fc1"], :media-driver #object[uk.co.real_logic.aeron.driver.MediaDriver 0xc8e971c "uk.co.real_logic.aeron.driver.MediaDriver@c8e971c"], :virtual-peers #object[clojure.lang.Atom 0x3732af53 {:status :ready, :val #object[onyx.messaging.aeron.peer_manager.VPeerManager 0x48ef9884 "onyx.messaging.aeron.peer_manager.VPeerManager@48ef9884"]}], :port 40201}}, :peers ({:peer-lifecycle #object[clojure.core$future_call$reify__6736 0x61e3d33f {:status :pending, :val nil}], :started-peer #object[clojure.lang.Atom 0x19ad9e68 {:status :ready, :val #onyx.system.OnyxPeer{:monitoring #onyx.monitoring.no_op_monitoring.NoOpMonitoringAgent{}, :messaging-require :loaded, :log #onyx.log.zookeeper.ZooKeeper{:config {:zookeeper/address "127.0.0.1:2190", :onyx.peer/job-scheduler :onyx.job-scheduler/balanced, :onyx.messaging/impl :aeron, :onyx.messaging/peer-port 40201, :onyx.messaging/bind-addr "localhost", :onyx/id #uuid "2c08f1c6-1354-4201-8f95-465d7df60d55"}, :monitoring #onyx.monitoring.no_op_monitoring.NoOpMonitoringAgent{}, :server nil, :conn #object[org.apache.curator.framework.imps.CuratorFrameworkImpl 0x3b47e239 "org.apache.curator.framework.imps.CuratorFrameworkImpl@3b47e239"], :prefix #uuid "2c08f1c6-1354-4201-8f95-465d7df60d55"}, :acking-daemon #onyx.messaging.acking_daemon.AckingDaemon{:opts {:zookeeper/address "127.0.0.1:2190", :onyx.peer/job-scheduler :onyx.job-scheduler/balanced, :onyx.messaging/impl :aeron, :onyx.messaging/peer-port 40201, :onyx.messaging/bind-addr "localhost", :onyx/id #uuid "2c08f1c6-1354-4201-8f95-465d7df60d55"}, :ack-state #object[clojure.lang.Atom 0xf58666d {:status :ready, :val #onyx.messaging.acking_daemon.AckState{:state {}, :completed? false}}], :acking-ch #object[clojure.core.async.impl.channels.ManyToManyChannel 0x705d2692 "clojure.core.async.impl.channels.ManyToManyChannel@705d2692"], :completion-ch #object[clojure.core.async.impl.channels.ManyToManyChannel 0x576b82f "clojure.core.async.impl.channels.ManyToManyChannel@576b82f"], :timeout-ch nil, :monitoring #onyx.monitoring.no_op_monitoring.NoOpMonitoringAgent{}, :log #onyx.log.zookeeper.ZooKeeper{:config {:zookeeper/address "127.0.0.1:2190", :onyx.peer/job-scheduler :onyx.job-scheduler/balanced, :onyx.messaging/impl :aeron, :onyx.messaging/peer-port 40201, :onyx.messaging/bind-addr "localhost", :onyx/id #uuid "2c08f1c6-1354-4201-8f95-465d7df60d55"}, :monitoring #onyx.monitoring.no_op_monitoring.NoOpMonitoringAgent{}, :server nil, :conn #object[org.apache.curator.framework.imps.CuratorFrameworkImpl 0x3b47e239 "org.apache.curator.framework.imps.CuratorFrameworkImpl@3b47e239"], :prefix #uuid "2c08f1c6-1354-4201-8f95-465d7df60d55"}, :ack-segments-fut #object[clojure.core$future_call$reify__6736 0x1a4d492 {:status :pending, :val nil}], :timeout-fut #object[clojure.core$future_call$reify__6736 0x4d83b1c5 {:status :pending, :val nil}]}, :messenger #onyx.messaging.aeron.AeronConnection{:peer-group #onyx.system.OnyxPeerGroup{:config {:zookeeper/address "127.0.0.1:2190", :onyx.peer/job-scheduler :onyx.job-scheduler/balanced, :onyx.messaging/impl :aeron, :onyx.messaging/peer-port 40201, :onyx.messaging/bind-addr "localhost", :onyx/id #uuid "2c08f1c6-1354-4201-8f95-465d7df60d55"}, :logging-config #onyx.static.logging_configuration.LoggingConfiguration{:file "onyx.log", :config nil}, :messaging-require :loaded, :messaging-group #onyx.messaging.aeron.AeronPeerGroup{:opts {:zookeeper/address "127.0.0.1:2190", :onyx.peer/job-scheduler :onyx.job-scheduler/balanced, :onyx.messaging/impl :aeron, :onyx.messaging/peer-port 40201, :onyx.messaging/bind-addr "localhost", :onyx/id #uuid "2c08f1c6-1354-4201-8f95-465d7df60d55"}, :publication-group #onyx.messaging.aeron.publication_group.PublicationGroup{:opts {:zookeeper/address "127.0.0.1:2190", :onyx.peer/job-scheduler :onyx.job-scheduler/balanced, :onyx.messaging/impl :aeron, :onyx.messaging/peer-port 40201, :onyx.messaging/bind-addr "localhost", :onyx/id #uuid "2c08f1c6-1354-4201-8f95-465d7df60d55"}, :send-idle-strategy #object[uk.co.real_logic.agrona.concurrent.BackoffIdleStrategy 0x4b9d8337 "uk.co.real_logic.agrona.concurrent.BackoffIdleStrategy@4b9d8337"], :publications #object[clojure.lang.Atom 0x43775df8 {:status :ready, :val {}}], :manager-thread #object[clojure.core.async.impl.channels.ManyToManyChannel 0x6454fa9a "clojure.core.async.impl.channels.ManyToManyChannel@6454fa9a"], :command-ch #object[clojure.core.async.impl.channels.ManyToManyChannel 0xf4a74ba "clojure.core.async.impl.channels.ManyToManyChannel@f4a74ba"], :shutdown-ch #object[clojure.core.async.impl.channels.ManyToManyChannel 0x60267f8b "clojure.core.async.impl.channels.ManyToManyChannel@60267f8b"]}, :subscribers [{:conn #object[uk.co.real_logic.aeron.Aeron 0x19c766ea "uk.co.real_logic.aeron.Aeron@19c766ea"], :subscription #object[uk.co.real_logic.aeron.Subscription 0x5a84df62 "uk.co.real_logic.aeron.Subscription@5a84df62"], :subscriber-fut #object[clojure.core$future_call$reify__6736 0x776cbe3d {:status :pending, :val nil}]} {:conn #object[uk.co.real_logic.aeron.Aeron 0xb6f007d "uk.co.real_logic.aeron.Aeron@b6f007d"], :subscription #object[uk.co.real_logic.aeron.Subscription 0x311b30c3 "uk.co.real_logic.aeron.Subscription@311b30c3"], :subscriber-fut #object[clojure.core$future_call$reify__6736 0x171158f4 {:status :pending, :val nil}]}], :subscriber-count 2, :compress-f #object[onyx.compression.nippy$messaging_compress 0x7681155b "onyx.compression.nippy$messaging_compress@7681155b"], :decompress-f #object[onyx.compression.nippy$messaging_decompress 0x3bf83a2 "onyx.compression.nippy$messaging_decompress@3bf83a2"], :send-idle-strategy #object[uk.co.real_logic.agrona.concurrent.BackoffIdleStrategy 0x4b9d8337 "uk.co.real_logic.agrona.concurrent.BackoffIdleStrategy@4b9d8337"], :messaging-require :loaded, :logging-config #onyx.static.logging_configuration.LoggingConfiguration{:file "onyx.log", :config nil}, :bind-addr "localhost", :external-addr "localhost", :external-channel "udp://localhost:40201", :media-driver-context #object[uk.co.real_logic.aeron.driver.MediaDriver$Context 0x725b6fc1 "uk.co.real_logic.aeron.driver.MediaDriver$Context@725b6fc1"], :media-driver #object[uk.co.real_logic.aeron.driver.MediaDriver 0xc8e971c "uk.co.real_logic.aeron.driver.MediaDriver@c8e971c"], :virtual-peers #object[clojure.lang.Atom 0x3732af53 {:status :ready, :val #object[onyx.messaging.aeron.peer_manager.VPeerManager 0x48ef9884 "onyx.messaging.aeron.peer_manager.VPeerManager@48ef9884"]}], :port 40201}}, :messaging-group #onyx.messaging.aeron.AeronPeerGroup{:opts {:zookeeper/address "127.0.0.1:2190", :onyx.peer/job-scheduler :onyx.job-scheduler/balanced, :onyx.messaging/impl :aeron, :onyx.messaging/peer-port 40201, :onyx.messaging/bind-addr "localhost", :onyx/id #uuid "2c08f1c6-1354-4201-8f95-465d7df60d55"}, :publication-group #onyx.messaging.aeron.publication_group.PublicationGroup{:opts {:zookeeper/address "127.0.0.1:2190", :onyx.peer/job-scheduler :onyx.job-scheduler/balanced, :onyx.messaging/impl :aeron, :onyx.messaging/peer-port 40201, :onyx.messaging/bind-addr "localhost", :onyx/id #uuid "2c08f1c6-1354-4201-8f95-465d7df60d55"}, :send-idle-strategy #object[uk.co.real_logic.agrona.concurrent.BackoffIdleStrategy 0x4b9d8337 "uk.co.real_logic.agrona.concurrent.BackoffIdleStrategy@4b9d8337"], :publications #object[clojure.lang.Atom 0x43775df8 {:status :ready, :val {}}], :manager-thread #object[clojure.core.async.impl.channels.ManyToManyChannel 0x6454fa9a "clojure.core.async.impl.channels.ManyToManyChannel@6454fa9a"], :command-ch #object[clojure.core.async.impl.channels.ManyToManyChannel 0xf4a74ba "clojure.core.async.impl.channels.ManyToManyChannel@f4a74ba"], :shutdown-ch #object[clojure.core.async.impl.channels.ManyToManyChannel 0x60267f8b "clojure.core.async.impl.channels.ManyToManyChannel@60267f8b"]}, :subscribers [{:conn #object[uk.co.real_logic.aeron.Aeron 0x19c766ea "uk.co.real_logic.aeron.Aeron@19c766ea"], :subscription #object[uk.co.real_logic.aeron.Subscription 0x5a84df62 "uk.co.real_logic.aeron.Subscription@5a84df62"], :subscriber-fut #object[clojure.core$future_call$reify__6736 0x776cbe3d {:status :pending, :val nil}]} {:conn #object[uk.co.real_logic.aeron.Aeron 0xb6f007d "uk.co.real_logic.aeron.Aeron@b6f007d"], :subscription #object[uk.co.real_logic.aeron.Subscription 0x311b30c3 "uk.co.real_logic.aeron.Subscription@311b30c3"], :subscriber-fut #object[clojure.core$future_call$reify__6736 0x171158f4 {:status :pending, :val nil}]}], :subscriber-count 2, :compress-f #object[onyx.compression.nippy$messaging_compress 0x7681155b "onyx.compression.nippy$messaging_compress@7681155b"], :decompress-f #object[onyx.compression.nippy$messaging_decompress 0x3bf83a2 "onyx.compression.nippy$messaging_decompress@3bf83a2"], :send-idle-strategy #object[uk.co.real_logic.agrona.concurrent.BackoffIdleStrategy 0x4b9d8337 "uk.co.real_logic.agrona.concurrent.BackoffIdleStrategy@4b9d8337"], :messaging-require :loaded, :logging-config #onyx.static.logging_configuration.LoggingConfiguration{:file "onyx.log", :config nil}, :bind-addr "localhost", :external-addr "localhost", :external-channel "udp://localhost:40201", :media-driver-context #object[uk.co.real_logic.aeron.driver.MediaDriver$Context 0x725b6fc1 "uk.co.real_logic.aeron.driver.MediaDriver$Context@725b6fc1"], :media-driver #object[uk.co.real_logic.aeron.driver.MediaDriver 0xc8e971c "uk.co.real_logic.aeron.driver.MediaDriver@c8e971c"], :virtual-peers #object[clojure.lang.Atom 0x3732af53 {:status :ready, :val #object[onyx.messaging.aeron.peer_manager.VPeerManager 0x48ef9884 "onyx.messaging.aeron.peer_manager.VPeerManager@48ef9884"]}], :port 40201}, :publication-group #onyx.messaging.aeron.publication_group.PublicationGroup{:opts {:zookeeper/address "127.0.0.1:2190", :onyx.peer/job-scheduler :onyx.job-scheduler/balanced, :onyx.messaging/impl :aeron, :onyx.messaging/peer-port 40201, :onyx.messaging/bind-addr "localhost", :onyx/id #uuid "2c08f1c6-1354-4201-8f95-465d7df60d55"}, :send-idle-strategy #object[uk.co.real_logic.agrona.concurrent.BackoffIdleStrategy 0x4b9d8337 "uk.co.real_logic.agrona.concurrent.BackoffIdleStrategy@4b9d8337"], :publications #object[clojure.lang.Atom 0x43775df8 {:status :ready, :val {}}], :manager-thread #object[clojure.core.async.impl.channels.ManyToManyChannel 0x6454fa9a "clojure.core.async.impl.channels.ManyToManyChannel@6454fa9a"], :command-ch #object[clojure.core.async.impl.channels.ManyToManyChannel 0xf4a74ba "clojure.core.async.impl.channels.ManyToManyChannel@f4a74ba"], :shutdown-ch #object[clojure.core.async.impl.channels.ManyToManyChannel 0x60267f8b "clojure.core.async.impl.channels.ManyToManyChannel@60267f8b"]}, :short-circuitable? #object[onyx.messaging.aeron.AeronConnection$fn__26947 0x64741a20 "onyx.messaging.aeron.AeronConnection$fn__26947@64741a20"], :publications nil, :virtual-peers #object[clojure.lang.Atom 0x3732af53 {:status :ready, :val #object[onyx.messaging.aeron.peer_manager.VPeerManager 0x48ef9884 "onyx.messaging.aeron.peer_manager.VPeerManager@48ef9884"]}], :acking-daemon #onyx.messaging.acking_daemon.AckingDaemon{:opts {:zookeeper/address "127.0.0.1:2190", :onyx.peer/job-scheduler :onyx.job-scheduler/balanced, :onyx.messaging/impl :aeron, :onyx.messaging/peer-port 40201, :onyx.messaging/bind-addr "localhost", :onyx/id #uuid "2c08f1c6-1354-4201-8f95-465d7df60d55"}, :ack-state #object[clojure.lang.Atom 0xf58666d {:status :ready, :val #onyx.messaging.acking_daemon.AckState{:state {}, :completed? false}}], :acking-ch #object[clojure.core.async.impl.channels.ManyToManyChannel 0x705d2692 "clojure.core.async.impl.channels.ManyToManyChannel@705d2692"], :completion-ch #object[clojure.core.async.impl.channels.ManyToManyChannel 0x576b82f "clojure.core.async.impl.channels.ManyToManyChannel@576b82f"], :timeout-ch nil, :monitoring #onyx.monitoring.no_op_monitoring.NoOpMonitoringAgent{}, :log #onyx.log.zookeeper.ZooKeeper{:config {:zookeeper/address "127.0.0.1:2190", :onyx.peer/job-scheduler :onyx.job-scheduler/balanced, :onyx.messaging/impl :aeron, :onyx.messaging/peer-port 40201, :onyx.messaging/bind-addr "localhost", :onyx/id #uuid "2c08f1c6-1354-4201-8f95-465d7df60d55"}, :monitoring #onyx.monitoring.no_op_monitoring.NoOpMonitoringAgent{}, :server nil, :conn #object[org.apache.curator.framework.imps.CuratorFrameworkImpl 0x3b47e239 "org.apache.curator.framework.imps.CuratorFrameworkImpl@3b47e239"], :prefix #uuid "2c08f1c6-1354-4201-8f95-465d7df60d55"}, :ack-segments-fut #object[clojure.core$future_call$reify__6736 0x1a4d492 {:status :pending, :val nil}], :timeout-fut #object[clojure.core$future_call$reify__6736 0x4d83b1c5 {:status :pending, :val nil}]}, :acking-ch #object[clojure.core.async.impl.channels.ManyToManyChannel 0x705d2692 "clojure.core.async.impl.channels.ManyToManyChannel@705d2692"], :send-idle-strategy #object[uk.co.real_logic.agrona.concurrent.BackoffIdleStrategy 0x4b9d8337 "uk.co.real_logic.agrona.concurrent.BackoffIdleStrategy@4b9d8337"], :compress-f #object[onyx.compression.nippy$messaging_compress 0x7681155b "onyx.compression.nippy$messaging_compress@7681155b"], :monitoring #onyx.monitoring.no_op_monitoring.NoOpMonitoringAgent{}, :messaging-require :loaded, :peer-task-short-id #object[clojure.lang.Atom 0x43535278 {:status :ready, :val nil}], :acker-short-id #object[clojure.lang.Atom 0x130ece4e {:status :ready, :val -6162}]}, :virtual-peer #onyx.peer.virtual_peer.VirtualPeer{:opts {:zookeeper/address "127.0.0.1:2190", :onyx.peer/job-scheduler :onyx.job-scheduler/balanced, :onyx.messaging/impl :aeron, :onyx.messaging/peer-port 40201, :onyx.messaging/bind-addr "localhost", :onyx/id #uuid "2c08f1c6-1354-4201-8f95-465d7df60d55"}, :task-component-fn #object[onyx.system$onyx_task 0x18694e2a "onyx.system$onyx_task@18694e2a"], :monitoring #onyx.monitoring.no_op_monitoring.NoOpMonitoringAgent{}, :restart-ch #object[clojure.core.async.impl.channels.ManyToManyChannel 0x41701fcd "clojure.core.async.impl.channels.ManyToManyChannel@41701fcd"], :messenger #onyx.messaging.aeron.AeronConnection{:peer-group #onyx.system.OnyxPeerGroup{:config {:zookeeper/address "127.0.0.1:2190", :onyx.peer/job-scheduler :onyx.job-scheduler/balanced, :onyx.messaging/impl :aeron, :onyx.messaging/peer-port 40201, :onyx.messaging/bind-addr "localhost", :onyx/id #uuid "2c08f1c6-1354-4201-8f95-465d7df60d55"}, :logging-config #onyx.static.logging_configuration.LoggingConfiguration{:file "onyx.log", :config nil}, :messaging-require :loaded, :messaging-group #onyx.messaging.aeron.AeronPeerGroup{:opts {:zookeeper/address "127.0.0.1:2190", :onyx.peer/job-scheduler :onyx.job-scheduler/balanced, :onyx.messaging/impl :aeron, :onyx.messaging/peer-port 40201, :onyx.messaging/bind-addr "localhost", :onyx/id #uuid "2c08f1c6-1354-4201-8f95-465d7df60d55"}, :publication-group #onyx.messaging.aeron.publication_group.PublicationGroup{:opts {:zookeeper/address "127.0.0.1:2190", :onyx.peer/job-scheduler :onyx.job-scheduler/balanced, :onyx.messaging/impl :aeron, :onyx.messaging/peer-port 40201, :onyx.messaging/bind-addr "localhost", :onyx/id #uuid "2c08f1c6-1354-4201-8f95-465d7df60d55"}, :send-idle-strategy #object[uk.co.real_logic.agrona.concurrent.BackoffIdleStrategy 0x4b9d8337 "uk.co.real_logic.agrona.concurrent.BackoffIdleStrategy@4b9d8337"], :publications #object[clojure.lang.Atom 0x43775df8 {:status :ready, :val {}}], :manager-thread #object[clojure.core.async.impl.channels.ManyToManyChannel 0x6454fa9a "clojure.core.async.impl.channels.ManyToManyChannel@6454fa9a"], :command-ch #object[clojure.core.async.impl.channels.ManyToManyChannel 0xf4a74ba "clojure.core.async.impl.channels.ManyToManyChannel@f4a74ba"], :shutdown-ch #object[clojure.core.async.impl.channels.ManyToManyChannel 0x60267f8b "clojure.core.async.impl.channels.ManyToManyChannel@60267f8b"]}, :subscribers [{:conn #object[uk.co.real_logic.aeron.Aeron 0x19c766ea "uk.co.real_logic.aeron.Aeron@19c766ea"], :subscription #object[uk.co.real_logic.aeron.Subscription 0x5a84df62 "uk.co.real_logic.aeron.Subscription@5a84df62"], :subscriber-fut #object[clojure.core$future_call$reify__6736 0x776cbe3d {:status :pending, :val nil}]} {:conn #object[uk.co.real_logic.aeron.Aeron 0xb6f007d "uk.co.real_logic.aeron.Aeron@b6f007d"], :subscription #object[uk.co.real_logic.aeron.Subscription 0x311b30c3 "uk.co.real_logic.aeron.Subscription@311b30c3"], :subscriber-fut #object[clojure.core$future_call$reify__6736 0x171158f4 {:status :pending, :val nil}]}], :subscriber-count 2, :compress-f #object[onyx.compression.nippy$messaging_compress 0x7681155b "onyx.compression.nippy$messaging_compress@7681155b"], :decompress-f #object[onyx.compression.nippy$messaging_decompress 0x3bf83a2 "onyx.compression.nippy$messaging_decompress@3bf83a2"], :send-idle-strategy #object[uk.co.real_logic.agrona.concurrent.BackoffIdleStrategy 0x4b9d8337 "uk.co.real_logic.agrona.concurrent.BackoffIdleStrategy@4b9d8337"], :messaging-require :loaded, :logging-config #onyx.static.logging_configuration.LoggingConfiguration{:file "onyx.log", :config nil}, :bind-addr "localhost", :external-addr "localhost", :external-channel "udp://localhost:40201", :media-driver-context #object[uk.co.real_logic.aeron.driver.MediaDriver$Context 0x725b6fc1 "uk.co.real_logic.aeron.driver.MediaDriver$Context@725b6fc1"], :media-driver #object[uk.co.real_logic.aeron.driver.MediaDriver 0xc8e971c "uk.co.real_logic.aeron.driver.MediaDriver@c8e971c"], :virtual-peers #object[clojure.lang.Atom 0x3732af53 {:status :ready, :val #object[onyx.messaging.aeron.peer_manager.VPeerManager 0x48ef9884 "onyx.messaging.aeron.peer_manager.VPeerManager@48ef9884"]}], :port 40201}}, :messaging-group #onyx.messaging.aeron.AeronPeerGroup{:opts {:zookeeper/address "127.0.0.1:2190", :onyx.peer/job-scheduler :onyx.job-scheduler/balanced, :onyx.messaging/impl :aeron, :onyx.messaging/peer-port 40201, :onyx.messaging/bind-addr "localhost", :onyx/id #uuid "2c08f1c6-1354-4201-8f95-465d7df60d55"}, :publication-group #onyx.messaging.aeron.publication_group.PublicationGroup{:opts {:zookeeper/address "127.0.0.1:2190", :onyx.peer/job-scheduler :onyx.job-scheduler/balanced, :onyx.messaging/impl :aeron, :onyx.messaging/peer-port 40201, :onyx.messaging/bind-addr "localhost", :onyx/id #uuid "2c08f1c6-1354-4201-8f95-465d7df60d55"}, :send-idle-strategy #object[uk.co.real_logic.agrona.concurrent.BackoffIdleStrategy 0x4b9d8337 "uk.co.real_logic.agrona.concurrent.BackoffIdleStrategy@4b9d8337"], :publications #object[clojure.lang.Atom 0x43775df8 {:status :ready, :val {}}], :manager-thread #object[clojure.core.async.impl.channels.ManyToManyChannel 0x6454fa9a "clojure.core.async.impl.channels.ManyToManyChannel@6454fa9a"], :command-ch #object[clojure.core.async.impl.channels.ManyToManyChannel 0xf4a74ba "clojure.core.async.impl.channels.ManyToManyChannel@f4a74ba"], :shutdown-ch #object[clojure.core.async.impl.channels.ManyToManyChannel 0x60267f8b "clojure.core.async.impl.channels.ManyToManyChannel@60267f8b"]}, :subscribers [{:conn #object[uk.co.real_logic.aeron.Aeron 0x19c766ea "uk.co.real_logic.aeron.Aeron@19c766ea"], :subscription #object[uk.co.real_logic.aeron.Subscription 0x5a84df62 "uk.co.real_logic.aeron.Subscription@5a84df62"], :subscriber-fut #object[clojure.core$future_call$reify__6736 0x776cbe3d {:status :pending, :val nil}]} {:conn #object[uk.co.real_logic.aeron.Aeron 0xb6f007d "uk.co.real_logic.aeron.Aeron@b6f007d"], :subscription #object[uk.co.real_logic.aeron.Subscription 0x311b30c3 "uk.co.real_logic.aeron.Subscription@311b30c3"], :subscriber-fut #object[clojure.core$future_call$reify__6736 0x171158f4 {:status :pending, :val nil}]}], :subscriber-count 2, :compress-f #object[onyx.compression.nippy$messaging_compress 0x7681155b "onyx.compression.nippy$messaging_compress@7681155b"], :decompress-f #object[onyx.compression.nippy$messaging_decompress 0x3bf83a2 "onyx.compression.nippy$messaging_decompress@3bf83a2"], :send-idle-strategy #object[uk.co.real_logic.agrona.concurrent.BackoffIdleStrategy 0x4b9d8337 "uk.co.real_logic.agrona.concurrent.BackoffIdleStrategy@4b9d8337"], :messaging-require :loaded, :logging-config #onyx.static.logging_configuration.LoggingConfiguration{:file "onyx.log", :config nil}, :bind-addr "localhost", :external-addr "localhost", :external-channel "udp://localhost:40201", :media-driver-context #object[uk.co.real_logic.aeron.driver.MediaDriver$Context 0x725b6fc1 "uk.co.real_logic.aeron.driver.MediaDriver$Context@725b6fc1"], :media-driver #object[uk.co.real_logic.aeron.driver.MediaDriver 0xc8e971c "uk.co.real_logic.aeron.driver.MediaDriver@c8e971c"], :virtual-peers #object[clojure.lang.Atom 0x3732af53 {:status :ready, :val #object[onyx.messaging.aeron.peer_manager.VPeerManager 0x48ef9884 "onyx.messaging.aeron.peer_manager.VPeerManager@48ef9884"]}], :port 40201}, :publication-group #onyx.messaging.aeron.publication_group.PublicationGroup{:opts {:zookeeper/address "127.0.0.1:2190", :onyx.peer/job-scheduler :onyx.job-scheduler/balanced, :onyx.messaging/impl :aeron, :onyx.messaging/peer-port 40201, :onyx.messaging/bind-addr "localhost", :onyx/id #uuid "2c08f1c6-1354-4201-8f95-465d7df60d55"}, :send-idle-strategy #object[uk.co.real_logic.agrona.concurrent.BackoffIdleStrategy 0x4b9d8337 "uk.co.real_logic.agrona.concurrent.BackoffIdleStrategy@4b9d8337"], :publications #object[clojure.lang.Atom 0x43775df8 {:status :ready, :val {}}], :manager-thread #object[clojure.core.async.impl.channels.ManyToManyChannel 0x6454fa9a "clojure.core.async.impl.channels.ManyToManyChannel@6454fa9a"], :command-ch #object[clojure.core.async.impl.channels.ManyToManyChannel 0xf4a74ba "clojure.core.async.impl.channels.ManyToManyChannel@f4a74ba"], :shutdown-ch #object[clojure.core.async.impl.channels.ManyToManyChannel 0x60267f8b "clojure.core.async.impl.channels.ManyToManyChannel@60267f8b"]}, :short-circuitable? #object[onyx.messaging.aeron.AeronConnection$fn__26947 0x64741a20 "onyx.messaging.aeron.AeronConnection$fn__26947@64741a20"], :publications nil, :virtual-peers #object[clojure.lang.Atom 0x3732af53 {:status :ready, :val #object[onyx.messaging.aeron.peer_manager.VPeerManager 0x48ef9884 "onyx.messaging.aeron.peer_manager.VPeerManager@48ef9884"]}], :acking-daemon #onyx.messaging.acking_daemon.AckingDaemon{:opts {:zookeeper/address "127.0.0.1:2190", :onyx.peer/job-scheduler :onyx.job-scheduler/balanced, :onyx.messaging/impl :aeron, :onyx.messaging/peer-port 40201, :onyx.messaging/bind-addr "localhost", :onyx/id #uuid "2c08f1c6-1354-4201-8f95-465d7df60d55"}, :ack-state #object[clojure.lang.Atom 0xf58666d {:status :ready, :val #onyx.messaging.acking_daemon.AckState{:state {}, :completed? false}}], :acking-ch #object[clojure.core.async.impl.channels.ManyToManyChannel 0x705d2692 "clojure.core.async.impl.channels.ManyToManyChannel@705d2692"], :completion-ch #object[clojure.core.async.impl.channels.ManyToManyChannel 0x576b82f "clojure.core.async.impl.channels.ManyToManyChannel@576b82f"], :timeout-ch nil, :monitoring #onyx.monitoring.no_op_monitoring.NoOpMonitoringAgent{}, :log #onyx.log.zookeeper.ZooKeeper{:config {:zookeeper/address "127.0.0.1:2190", :onyx.peer/job-scheduler :onyx.job-scheduler/balanced, :onyx.messaging/impl :aeron, :onyx.messaging/peer-port 40201, :onyx.messaging/bind-addr "localhost", :onyx/id #uuid "2c08f1c6-1354-4201-8f95-465d7df60d55"}, :monitoring #onyx.monitoring.no_op_monitoring.NoOpMonitoringAgent{}, :server nil, :conn #object[org.apache.curator.framework.imps.CuratorFrameworkImpl 0x3b47e239 "org.apache.curator.framework.imps.CuratorFrameworkImpl@3b47e239"], :prefix #uuid "2c08f1c6-1354-4201-8f95-465d7df60d55"}, :ack-segments-fut #object[clojure.core$future_call$reify__6736 0x1a4d492 {:status :pending, :val nil}], :timeout-fut #object[clojure.core$future_call$reify__6736 0x4d83b1c5 {:status :pending, :val nil}]}, :acking-ch #object[clojure.core.async.impl.channels.ManyToManyChannel 0x705d2692 "clojure.core.async.impl.channels.ManyToManyChannel@705d2692"], :send-idle-strategy #object[uk.co.real_logic.agrona.concurrent.BackoffIdleStrategy 0x4b9d8337 "uk.co.real_logic.agrona.concurrent.BackoffIdleStrategy@4b9d8337"], :compress-f #object[onyx.compression.nippy$messaging_compress 0x7681155b "onyx.compression.nippy$messaging_compress@7681155b"], :monitoring #onyx.monitoring.no_op_monitoring.NoOpMonitoringAgent{}, :messaging-require :loaded, :peer-task-short-id #object[clojure.lang.Atom 0x43535278 {:status :ready, :val nil}], :acker-short-id #object[clojure.lang.Atom 0x130ece4e {:status :ready, :val -6162}]}, :acking-daemon #onyx.messaging.acking_daemon.AckingDaemon{:opts {:zookeeper/address "127.0.0.1:2190", :onyx.peer/job-scheduler :onyx.job-scheduler/balanced, :onyx.messaging/impl :aeron, :onyx.messaging/peer-port 40201, :onyx.messaging/bind-addr "localhost", :onyx/id #uuid "2c08f1c6-1354-4201-8f95-465d7df60d55"}, :ack-state #object[clojure.lang.Atom 0xf58666d {:status :ready, :val #onyx.messaging.acking_daemon.AckState{:state {}, :completed? false}}], :acking-ch #object[clojure.core.async.impl.channels.ManyToManyChannel 0x705d2692 "clojure.core.async.impl.channels.ManyToManyChannel@705d2692"], :completion-ch #object[clojure.core.async.impl.channels.ManyToManyChannel 0x576b82f "clojure.core.async.impl.channels.ManyToManyChannel@576b82f"], :timeout-ch nil, :monitoring #onyx.monitoring.no_op_monitoring.NoOpMonitoringAgent{}, :log #onyx.log.zookeeper.ZooKeeper{:config {:zookeeper/address "127.0.0.1:2190", :onyx.peer/job-scheduler :onyx.job-scheduler/balanced, :onyx.messaging/impl :aeron, :onyx.messaging/peer-port 40201, :onyx.messaging/bind-addr "localhost", :onyx/id #uuid "2c08f1c6-1354-4201-8f95-465d7df60d55"}, :monitoring #onyx.monitoring.no_op_monitoring.NoOpMonitoringAgent{}, :server nil, :conn #object[org.apache.curator.framework.imps.CuratorFrameworkImpl 0x3b47e239 "org.apache.curator.framework.imps.CuratorFrameworkImpl@3b47e239"], :prefix #uuid "2c08f1c6-1354-4201-8f95-465d7df60d55"}, :ack-segments-fut #object[clojure.core$future_call$reify__6736 0x1a4d492 {:status :pending, :val nil}], :timeout-fut #object[clojure.core$future_call$reify__6736 0x4d83b1c5 {:status :pending, :val nil}]}, :outbox-ch #object[clojure.core.async.impl.channels.ManyToManyChannel 0x2469c513 "clojure.core.async.impl.channels.ManyToManyChannel@2469c513"], :kill-ch #object[clojure.core.async.impl.channels.ManyToManyChannel 0x3faeef6d "clojure.core.async.impl.channels.ManyToManyChannel@3faeef6d"], :id #uuid "6d6abdfb-9703-428e-92e7-0baed9e1991d", :outbox-loop-ch #object[clojure.core.async.impl.channels.ManyToManyChannel 0x6de4eeac "clojure.core.async.impl.channels.ManyToManyChannel@6de4eeac"], :inbox-ch #object[clojure.core.async.impl.channels.ManyToManyChannel 0x2c2b1aaa "clojure.core.async.impl.channels.ManyToManyChannel@2c2b1aaa"], :processing-loop-ch #object[clojure.core.async.impl.channels.ManyToManyChannel 0x46800361 "clojure.core.async.impl.channels.ManyToManyChannel@46800361"], :log #onyx.log.zookeeper.ZooKeeper{:config {:zookeeper/address "127.0.0.1:2190", :onyx.peer/job-scheduler :onyx.job-scheduler/balanced, :onyx.messaging/impl :aeron, :onyx.messaging/peer-port 40201, :onyx.messaging/bind-addr "localhost", :onyx/id #uuid "2c08f1c6-1354-4201-8f95-465d7df60d55"}, :monitoring #onyx.monitoring.no_op_monitoring.NoOpMonitoringAgent{}, :server nil, :conn #object[org.apache.curator.framework.imps.CuratorFrameworkImpl 0x3b47e239 "org.apache.curator.framework.imps.CuratorFrameworkImpl@3b47e239"], :prefix #uuid "2c08f1c6-1354-4201-8f95-465d7df60d55"}}}}], :shutdown-ch #object[clojure.core.async.impl.channels.ManyToManyChannel 0xe1d495b "clojure.core.async.impl.channels.ManyToManyChannel@e1d495b"], :ack-ch #object[clojure.core.async.impl.channels.ManyToManyChannel 0x44c647ba "clojure.core.async.impl.channels.ManyToManyChannel@44c647ba"]}), :onyx-id #uuid "3343c706-ee2b-47e3-89be-8b3614966735"}

onyx-samples.sample1> (run)

Submitting

{:job-id #uuid "f62eee6e-52fe-4e0d-87fd-f0ff2d9b5c03", :task-ids {:in {:id #uuid "4630896c-8bea-4131-908e-06ba59ca961a", :name :in, :egress-ids {:inc #uuid "1ae795ad-938b-45f9-813f-850625113c6f"}}, :inc {:id #uuid "1ae795ad-938b-45f9-813f-850625113c6f", :name :inc, :egress-ids {:out #uuid "0c46db26-ace3-45e9-87fd-84e6df9b49cb"}}, :out {:id #uuid "0c46db26-ace3-45e9-87fd-84e6df9b49cb", :name :out}}}

onyx-samples.sample1> (take-segments! out-ch)

Mike Drogalis

unread,

Nov 29, 2015, 9:38:38 AM11/29/15

to Keisuke Fukuda, Onyx

Hi Keisuke,

See: https://github.com/onyx-platform/onyx/blob/0.8.x/doc/user-guide/faq.md#why-does-my-job-hang-at-the-repl

--
You received this message because you are subscribed to the Google Groups "Onyx" group.
To unsubscribe from this group and stop receiving emails from it, send an email to onyx-user+...@googlegroups.com.
To post to this group, send email to onyx...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/onyx-user/feb78b30-5bc0-49e8-bda2-b61aabaf6f23%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.

Keisuke Fukuda

unread,

Nov 29, 2015, 6:05:09 PM11/29/15

to Mike Drogalis, Onyx

Thanks, Mike.

I'll read it.

Keisuke

FUKUDA, Keisuke <福田圭祐>
Tokyo, Japan
Email: keisuk...@gmail.com

Reply all

Reply to author

Forward

0 new messages