Skip to content

Instantly share code, notes, and snippets.

@Jaretbinford
Created March 10, 2017 19:07
Show Gist options
  • Save Jaretbinford/1f538c049c79e46706b64248545d8818 to your computer and use it in GitHub Desktop.
Save Jaretbinford/1f538c049c79e46706b64248545d8818 to your computer and use it in GitHub Desktop.
Using 5561 transactor local dev
Starting nREPL server...
/Library/Java/JavaVirtualMachines/jdk1.8.0_91.jdk/Contents/Home/bin/java -Dfile.encoding=UTF-8 -Dpython.cachedir.skip=true -XX:MaxPermSize=500M -verbose:gc -XX:+PrintGCDetails -Xloggc:gclog -XX:+UseGCLogFileRotation -XX:NumberOfGCLogFiles=20 -XX:GCLogFileSize=128M -XX:+PrintGCDateStamps -XX:+HeapDumpOnOutOfMemoryError -Xms2G -XX:-OmitStackTraceInFastThrow -Xmx2G -Dcom.sun.management.jmxremote.authenticate=false -Dcom.sun.management.jmxremote.ssl=false -Dclojure.compile.path=/Users/jbin/Desktop/Jaret/Projects/workproof/pullperf/Cook/scheduler/target/classes -Dcook.version=1.0.1-SNAPSHOT -Dclojure.debug=false -Didea.launcher.port=7537 "-Didea.launcher.bin.path=/Applications/IntelliJ IDEA CE.app/Contents/bin" -classpath "/Users/jbin/Desktop/Jaret/Projects/workproof/pullperf/Cook/scheduler/test:/Users/jbin/Desktop/Jaret/Projects/workproof/pullperf/Cook/scheduler/src:/Users/jbin/Desktop/Jaret/Projects/workproof/pullperf/Cook/scheduler/test-resources:/Users/jbin/Desktop/Jaret/Projects/workproof/pullperf/Cook/scheduler/dev-resources:/Users/jbin/Desktop/Jaret/Projects/workproof/pullperf/Cook/scheduler/resources:/Users/jbin/Desktop/Jaret/Projects/workproof/pullperf/Cook/scheduler/target/classes:/Users/jbin/.m2/repository/com/datomic/datomic-lucene-core/3.3.0/datomic-lucene-core-3.3.0.jar:/Users/jbin/.m2/repository/com/netflix/fenzo/fenzo-core/0.10.0/fenzo-core-0.10.0.jar:/Users/jbin/.m2/repository/org/hamcrest/hamcrest-core/1.1/hamcrest-core-1.1.jar:/Users/jbin/.m2/repository/javax/mail/mail/1.4.4/mail-1.4.4.jar:/Users/jbin/.m2/repository/org/apache/activemq/artemis-commons/1.4.0/artemis-commons-1.4.0.jar:/Users/jbin/.m2/repository/ring/ring-devel/1.4.0/ring-devel-1.4.0.jar:/Users/jbin/.m2/repository/org/tobereplaced/lettercase/1.0.0/lettercase-1.0.0.jar:/Users/jbin/.m2/repository/org/apache/curator/curator-framework/2.7.1/curator-framework-2.7.1.jar:/Users/jbin/.m2/repository/org/clojure/java.classpath/0.2.2/java.classpath-0.2.2.jar:/Users/jbin/.m2/repository/cc/qbits/jet/0.5.7/jet-0.5.7.jar:/Users/jbin/.m2/repository/org/apache/tomcat/tomcat-juli/7.0.27/tomcat-juli-7.0.27.jar:/Users/jbin/.m2/repository/org/clojure/clojure/1.8.0/clojure-1.8.0.jar:/Users/jbin/.m2/repository/com/google/guava/guava/18.0/guava-18.0.jar:/Users/jbin/.m2/repository/org/eclipse/jetty/websocket/websocket-servlet/9.2.9.v20150224/websocket-servlet-9.2.9.v20150224.jar:/Users/jbin/.m2/repository/metosin/ring-swagger/0.22.10/ring-swagger-0.22.10.jar:/Users/jbin/.m2/repository/com/h2database/h2/1.3.171/h2-1.3.171.jar:/Users/jbin/.m2/repository/org/apache/curator/curator-test/2.7.1/curator-test-2.7.1.jar:/Users/jbin/.m2/repository/listora/ring-congestion/0.1.2/ring-congestion-0.1.2.jar:/Users/jbin/.m2/repository/org/objenesis/objenesis/2.1/objenesis-2.1.jar:/Users/jbin/.m2/repository/tigris/tigris/0.1.1/tigris-0.1.1.jar:/Users/jbin/.m2/repository/org/eclipse/jetty/jetty-util/9.2.9.v20150224/jetty-util-9.2.9.v20150224.jar:/Users/jbin/.m2/repository/me/raynes/conch/0.5.2/conch-0.5.2.jar:/Users/jbin/.m2/repository/commons-codec/commons-codec/1.10/commons-codec-1.10.jar:/Users/jbin/.m2/repository/ring/ring-servlet/1.5.0/ring-servlet-1.5.0.jar:/Users/jbin/.m2/repository/prismatic/plumbing/0.5.3/plumbing-0.5.3.jar:/Users/jbin/.m2/repository/org/codehaus/jsr166-mirror/jsr166y/1.7.0/jsr166y-1.7.0.jar:/Users/jbin/.m2/repository/org/jboss/logging/jboss-logging/3.3.0.Final/jboss-logging-3.3.0.Final.jar:/Users/jbin/.m2/repository/camel-snake-kebab/camel-snake-kebab/0.4.0/camel-snake-kebab-0.4.0.jar:/Users/jbin/.m2/repository/com/datomic/datomic-pro/0.9.5561/datomic-pro-0.9.5561.jar:/Users/jbin/.m2/repository/org/clojure/tools.macro/0.1.5/tools.macro-0.1.5.jar:/Users/jbin/.m2/repository/io/netty/netty/3.10.1.Final/netty-3.10.1.Final.jar:/Users/jbin/.m2/repository/transduce/transduce/0.1.0/transduce-0.1.0.jar:/Users/jbin/.m2/repository/org/apache/commons/commons-pool2/2.2/commons-pool2-2.2.jar:/Users/jbin/.m2/repository/com/github/fge/json-schema-core/1.2.5/json-schema-core-1.2.5.jar:/Users/jbin/.m2/repository/com/duelinmarkers/ring-request-logging/0.2.0/ring-request-logging-0.2.0.jar:/Users/jbin/.m2/repository/com/fasterxml/jackson/dataformat/jackson-dataformat-smile/2.3.1/jackson-dataformat-smile-2.3.1.jar:/Users/jbin/.m2/repository/instaparse/instaparse/1.4.0/instaparse-1.4.0.jar:/Users/jbin/.m2/repository/org/clojure/data.csv/0.1.2/data.csv-0.1.2.jar:/Users/jbin/.m2/repository/riemann-clojure-client/riemann-clojure-client/0.4.1/riemann-clojure-client-0.4.1.jar:/Users/jbin/.m2/repository/org/clojure/core.memoize/0.5.8/core.memoize-0.5.8.jar:/Users/jbin/.m2/repository/com/cognitect/transit-clj/0.8.285/transit-clj-0.8.285.jar:/Users/jbin/.m2/repository/org/slf4j/slf4j-api/1.7.12/slf4j-api-1.7.12.jar:/Users/jbin/.m2/repository/ring/ring-codec/1.0.0/ring-codec-1.0.0.jar:/Users/jbin/.m2/repository/com/fasterxml/jackson/core/jackson-core/2.3.1/jackson-core-2.3.1.jar:/Users/jbin/.m2/repository/clojure-msgpack/clojure-msgpack/1.1.2/clojure-msgpack-1.1.2.jar:/Users/jbin/.m2/repository/cheshire/cheshire/5.3.1/cheshire-5.3.1.jar:/Users/jbin/.m2/repository/com/github/fge/msg-simple/1.1/msg-simple-1.1.jar:/Users/jbin/.m2/repository/org/codehaus/janino/commons-compiler/2.6.1/commons-compiler-2.6.1.jar:/Users/jbin/.m2/repository/org/eclipse/jetty/jetty-security/9.2.6.v20141205/jetty-security-9.2.6.v20141205.jar:/Users/jbin/.m2/repository/clj-time/clj-time/0.9.0/clj-time-0.9.0.jar:/Users/jbin/.m2/repository/org/apache/httpcomponents/httpclient/4.5/httpclient-4.5.jar:/Users/jbin/.m2/repository/org/clojure/data.json/0.2.2/data.json-0.2.2.jar:/Users/jbin/.m2/repository/net/jpountz/lz4/lz4/1.3/lz4-1.3.jar:/Users/jbin/.m2/repository/org/clojure/tools.analyzer/0.6.7/tools.analyzer-0.6.7.jar:/Users/jbin/.m2/repository/org/clojure/data.codec/0.1.0/data.codec-0.1.0.jar:/Users/jbin/.m2/repository/org/apache/mesos/mesos/1.0.1/mesos-1.0.1.jar:/Users/jbin/.m2/repository/clj-logging-config/clj-logging-config/1.9.10/clj-logging-config-1.9.10.jar:/Users/jbin/.m2/repository/com/taoensso/encore/1.21.0/encore-1.21.0.jar:/Users/jbin/.m2/repository/jarohen/chime/0.1.6/chime-0.1.6.jar:/Users/jbin/.m2/repository/com/fasterxml/jackson/core/jackson-annotations/2.4.0/jackson-annotations-2.4.0.jar:/Users/jbin/.m2/repository/javax/activation/activation/1.1/activation-1.1.jar:/Users/jbin/.m2/repository/org/apache/curator/curator-client/2.7.1/curator-client-2.7.1.jar:/Users/jbin/.m2/repository/com/taoensso/nippy/2.8.0/nippy-2.8.0.jar:/Users/jbin/.m2/repository/ring-edn/ring-edn/0.1.0/ring-edn-0.1.0.jar:/Users/jbin/.m2/repository/org/clojure/tools.analyzer.jvm/0.6.9/tools.analyzer.jvm-0.6.9.jar:/Users/jbin/.m2/repository/org/eclipse/jetty/jetty-http/9.2.6.v20141205/jetty-http-9.2.6.v20141205.jar:/Users/jbin/.m2/repository/org/flatland/useful/0.9.0/useful-0.9.0.jar:/Users/jbin/.m2/repository/org/clojure/tools.reader/0.9.1/tools.reader-0.9.1.jar:/Users/jbin/.m2/repository/com/github/fge/jackson-coreutils/1.8/jackson-coreutils-1.8.jar:/Users/jbin/.m2/repository/commons-io/commons-io/2.4/commons-io-2.4.jar:/Users/jbin/.m2/repository/clojure-complete/clojure-complete/0.2.4/clojure-complete-0.2.4.jar:/Users/jbin/.m2/repository/org/clojure/data.priority-map/0.0.5/data.priority-map-0.0.5.jar:/Users/jbin/.m2/repository/org/apache/johnzon/johnzon-core/0.9.4/johnzon-core-0.9.4.jar:/Users/jbin/.m2/repository/metosin/schema-tools/0.9.0/schema-tools-0.9.0.jar:/Users/jbin/.m2/repository/commons-beanutils/commons-beanutils/1.9.2/commons-beanutils-1.9.2.jar:/Users/jbin/.m2/repository/org/eclipse/jetty/jetty-server/9.2.6.v20141205/jetty-server-9.2.6.v20141205.jar:/Users/jbin/.m2/repository/org/apache/commons/commons-math/2.2/commons-math-2.2.jar:/Users/jbin/.m2/repository/lonocloud/synthread/1.0.4/synthread-1.0.4.jar:/Users/jbin/.m2/repository/org/mozilla/rhino/1.7R4/rhino-1.7R4.jar:/Users/jbin/.m2/repository/useful/useful/0.8.5-alpha2/useful-0.8.5-alpha2.jar:/Users/jbin/.m2/repository/com/github/fge/uri-template/0.9/uri-template-0.9.jar:/Users/jbin/.m2/repository/clj-pid/clj-pid/0.1.1/clj-pid-0.1.1.jar:/Users/jbin/.m2/repository/metrics-clojure-ring/metrics-clojure-ring/2.3.0/metrics-clojure-ring-2.3.0.jar:/Users/jbin/.m2/repository/org/apache/httpcomponents/httpmime/4.5/httpmime-4.5.jar:/Users/jbin/.m2/repository/twosigma/cook-jobclient/0.1.2-SNAPSHOT/cook-jobclient-0.1.2-SNAPSHOT.jar:/Users/jbin/.m2/repository/org/eclipse/jetty/jetty-io/9.2.6.v20141205/jetty-io-9.2.6.v20141205.jar:/Users/jbin/.m2/repository/crypto-equality/crypto-equality/1.0.0/crypto-equality-1.0.0.jar:/Users/jbin/.m2/repository/com/github/fge/btf/1.2/btf-1.2.jar:/Users/jbin/.m2/repository/ring/ring-json/0.2.0/ring-json-0.2.0.jar:/Users/jbin/.m2/repository/org/eclipse/jetty/websocket/websocket-server/9.2.9.v20150224/websocket-server-9.2.9.v20150224.jar:/Users/jbin/.m2/repository/commons-collections/commons-collections/3.2.1/commons-collections-3.2.1.jar:/Users/jbin/.m2/repository/com/draines/postal/1.11.0/postal-1.11.0.jar:/Users/jbin/.m2/repository/org/clojure/tools.cli/0.3.5/tools.cli-0.3.5.jar:/Users/jbin/.m2/repository/io/aviso/pretty/0.1.12/pretty-0.1.12.jar:/Users/jbin/.m2/repository/frankiesardo/linked/1.2.7/linked-1.2.7.jar:/Users/jbin/.m2/repository/org/eclipse/jetty/websocket/websocket-client/9.2.9.v20150224/websocket-client-9.2.9.v20150224.jar:/Users/jbin/.m2/repository/com/googlecode/json-simple/json-simple/1.1.1/json-simple-1.1.1.jar:/Users/jbin/.m2/repository/org/mockito/mockito-core/1.10.19/mockito-core-1.10.19.jar:/Users/jbin/.m2/repository/hiccup/hiccup/1.0.5/hiccup-1.0.5.jar:/Users/jbin/.m2/repository/org/clojure/tools.logging/0.2.6/tools.logging-0.2.6.jar:/Users/jbin/.m2/repository/clj-tuple/clj-tuple/0.2.2/clj-tuple-0.2.2.jar:/Users/jbin/.m2/repository/com/aphyr/riemann-java-client/0.4.0/riemann-java-client-0.4.0.jar:/Users/jbin/.m2/repository/com/codahale/metrics/metrics-core/3.0.1/metrics-core-3.0.1.jar:/Users/jbin/.m2/repository/org/clojure/test.check/0.6.1/test.check-0.6.1.jar:/Users/jbin/.m2/repository/org/apache/curator/curator-recipes/2.7.1/curator-recipes-2.7.1.jar:/Users/jbin/.m2/repository/org/tukaani/xz/1.5/xz-1.5.jar:/Users/jbin/.m2/repository/com/googlecode/libphonenumber/libphonenumber/6.2/libphonenumber-6.2.jar:/Users/jbin/.m2/repository/slingshot/slingshot/0.12.2/slingshot-0.12.2.jar:/Users/jbin/.m2/repository/com/taoensso/timbre/3.3.1/timbre-3.3.1.jar:/Users/jbin/.m2/repository/potemkin/potemkin/0.4.1/potemkin-0.4.1.jar:/Users/jbin/.m2/repository/org/jmockit/jmockit/1.18/jmockit-1.18.jar:/Users/jbin/.m2/repository/clojure-miniprofiler/clojure-miniprofiler/0.4.0/clojure-miniprofiler-0.4.0.jar:/Users/jbin/.m2/repository/org/clojure/tools.nrepl/0.2.3/tools.nrepl-0.2.3.jar:/Users/jbin/.m2/repository/com/ibm/icu/icu4j/56.1/icu4j-56.1.jar:/Users/jbin/.m2/repository/org/fressian/fressian/0.6.5/fressian-0.6.5.jar:/Users/jbin/.m2/repository/junit/junit/4.12/junit-4.12.jar:/Users/jbin/.m2/repository/net/spy/spymemcached/2.11.4/spymemcached-2.11.4.jar:/Users/jbin/.m2/repository/ring/ring-core/1.4.0/ring-core-1.4.0.jar:/Users/jbin/.m2/repository/liberator/liberator/0.14.1/liberator-0.14.1.jar:/Users/jbin/.m2/repository/org/apache/geronimo/specs/geronimo-json_1.0_spec/1.0-alpha-1/geronimo-json_1.0_spec-1.0-alpha-1.jar:/Users/jbin/.m2/repository/org/slf4j/slf4j-log4j12/1.7.12/slf4j-log4j12-1.7.12.jar:/Users/jbin/.m2/repository/ring/ring-jetty-adapter/1.5.0/ring-jetty-adapter-1.5.0.jar:/Users/jbin/.m2/repository/robert/hooke/1.3.0/hooke-1.3.0.jar:/Users/jbin/.m2/repository/clj-http-fake/clj-http-fake/1.0.1/clj-http-fake-1.0.1.jar:/Users/jbin/.m2/repository/org/clojure/data.finger-tree/0.0.2/data.finger-tree-0.0.2.jar:/Users/jbin/.m2/repository/de/kotka/lazymap/3.1.0/lazymap-3.1.0.jar:/Users/jbin/.m2/repository/metosin/compojure-api/1.1.8/compojure-api-1.1.8.jar:/Users/jbin/.m2/repository/org/apache/activemq/artemis-core-client/1.4.0/artemis-core-client-1.4.0.jar:/Users/jbin/.m2/repository/compojure/compojure/1.4.0/compojure-1.4.0.jar:/Users/jbin/.m2/repository/org/clojure/tools.namespace/0.2.4/tools.namespace-0.2.4.jar:/Users/jbin/.m2/repository/fipp/fipp/0.5.1/fipp-0.5.1.jar:/Users/jbin/.m2/repository/org/ow2/asm/asm-all/4.2/asm-all-4.2.jar:/Users/jbin/.m2/repository/org/clojure/core.async/0.2.374/core.async-0.2.374.jar:/Users/jbin/.m2/repository/byte-streams/byte-streams/0.1.4/byte-streams-0.1.4.jar:/Users/jbin/.m2/repository/com/google/protobuf/protobuf-java/2.6.1/protobuf-java-2.6.1.jar:/Users/jbin/.m2/repository/org/eclipse/jetty/websocket/websocket-common/9.2.9.v20150224/websocket-common-9.2.9.v20150224.jar:/Users/jbin/.m2/repository/org/clojure/math.combinatorics/0.0.7/math.combinatorics-0.0.7.jar:/Users/jbin/.m2/repository/org/eclipse/jetty/jetty-servlet/9.2.9.v20150224/jetty-servlet-9.2.9.v20150224.jar:/Users/jbin/.m2/repository/org/iq80/snappy/snappy/0.3/snappy-0.3.jar:/Users/jbin/.m2/repository/org/yaml/snakeyaml/1.13/snakeyaml-1.13.jar:/Users/jbin/.m2/repository/medley/medley/0.6.0/medley-0.6.0.jar:/Users/jbin/.m2/repository/amalloy/ring-buffer/1.1/ring-buffer-1.1.jar:/Users/jbin/.m2/repository/metosin/scjsv/0.3.0/scjsv-0.3.0.jar:/Users/jbin/.m2/repository/com/taoensso/carmine/2.8.0/carmine-2.8.0.jar:/Users/jbin/.m2/repository/less-awful-ssl/less-awful-ssl/1.0.0/less-awful-ssl-1.0.0.jar:/Users/jbin/.m2/repository/org/clojure/core.cache/0.6.4/core.cache-0.6.4.jar:/Users/jbin/.m2/repository/com/github/fge/json-schema-validator/2.2.6/json-schema-validator-2.2.6.jar:/Users/jbin/.m2/repository/crypto-random/crypto-random/1.2.0/crypto-random-1.2.0.jar:/Users/jbin/.m2/repository/javax/servlet/javax.servlet-api/3.1.0/javax.servlet-api-3.1.0.jar:/Users/jbin/.m2/repository/circleci/clj-yaml/0.5.5/clj-yaml-0.5.5.jar:/Users/jbin/.m2/repository/javax/mail/mailapi/1.4.3/mailapi-1.4.3.jar:/Users/jbin/.m2/repository/net/sf/jopt-simple/jopt-simple/4.6/jopt-simple-4.6.jar:/Users/jbin/.m2/repository/commons-logging/commons-logging/1.2/commons-logging-1.2.jar:/Users/jbin/.m2/repository/metosin/ring-http-response/0.8.0/ring-http-response-0.8.0.jar:/Users/jbin/.m2/repository/io/netty/netty-all/4.0.39.Final/netty-all-4.0.39.Final.jar:/Users/jbin/.m2/repository/com/cognitect/transit-java/0.8.311/transit-java-0.8.311.jar:/Users/jbin/.m2/repository/ns-tracker/ns-tracker/0.3.0/ns-tracker-0.3.0.jar:/Users/jbin/.m2/repository/com/fasterxml/jackson/core/jackson-databind/2.4.5/jackson-databind-2.4.5.jar:/Users/jbin/.m2/repository/metrics-clojure/metrics-clojure/2.6.1/metrics-clojure-2.6.1.jar:/Users/jbin/.m2/repository/io/dropwizard/metrics/metrics-core/3.1.2/metrics-core-3.1.2.jar:/Users/jbin/.m2/repository/riddley/riddley/0.1.10/riddley-0.1.10.jar:/Users/jbin/.m2/repository/metosin/ring-swagger-ui/2.2.2-0/ring-swagger-ui-2.2.2-0.jar:/Users/jbin/.m2/repository/org/flatland/ordered/1.5.3/ordered-1.5.3.jar:/Users/jbin/.m2/repository/ring-middleware-format/ring-middleware-format/0.7.0/ring-middleware-format-0.7.0.jar:/Users/jbin/.m2/repository/com/google/code/findbugs/jsr305/3.0.0/jsr305-3.0.0.jar:/Users/jbin/.m2/repository/org/msgpack/msgpack/0.6.10/msgpack-0.6.10.jar:/Users/jbin/.m2/repository/org/codehaus/janino/commons-compiler-jdk/2.6.1/commons-compiler-jdk-2.6.1.jar:/Users/jbin/.m2/repository/joda-time/joda-time/2.6/joda-time-2.6.jar:/Users/jbin/.m2/repository/org/apache/zookeeper/zookeeper/3.4.6/zookeeper-3.4.6.jar:/Users/jbin/.m2/repository/org/javassist/javassist/3.18.1-GA/javassist-3.18.1-GA.jar:/Users/jbin/.m2/repository/commons-fileupload/commons-fileupload/1.3.1/commons-fileupload-1.3.1.jar:/Users/jbin/.m2/repository/org/eclipse/jetty/websocket/websocket-api/9.2.9.v20150224/websocket-api-9.2.9.v20150224.jar:/Users/jbin/.m2/repository/swiss-arrows/swiss-arrows/1.0.0/swiss-arrows-1.0.0.jar:/Users/jbin/.m2/repository/prismatic/schema/1.1.3/schema-1.1.3.jar:/Users/jbin/.m2/repository/com/aphyr/metrics3-riemann-reporter/0.4.0/metrics3-riemann-reporter-0.4.0.jar:/Users/jbin/.m2/repository/io/dropwizard/metrics/metrics-graphite/3.1.2/metrics-graphite-3.1.2.jar:/Users/jbin/.m2/repository/org/eclipse/jetty/jetty-client/9.2.9.v20150224/jetty-client-9.2.9.v20150224.jar:/Users/jbin/.m2/repository/clj-http/clj-http/2.0.0/clj-http-2.0.0.jar:/Users/jbin/.m2/repository/org/apache/tomcat/tomcat-jdbc/7.0.27/tomcat-jdbc-7.0.27.jar:/Users/jbin/.m2/repository/log4j/log4j/1.2.17/log4j-1.2.17.jar:/Users/jbin/.m2/repository/jline/jline/0.9.94/jline-0.9.94.jar:/Users/jbin/.m2/repository/org/json/json/20140107/json-20140107.jar:/Users/jbin/.m2/repository/clout/clout/2.1.2/clout-2.1.2.jar:/Users/jbin/.m2/repository/wyegelwe/mesomatic/1.0.1-r0-SNAPSHOT/mesomatic-1.0.1-r0-SNAPSHOT.jar:/Users/jbin/.m2/repository/clj-stacktrace/clj-stacktrace/0.2.8/clj-stacktrace-0.2.8.jar:/Users/jbin/.m2/repository/org/apache/httpcomponents/httpcore/4.4.1/httpcore-4.4.1.jar:/Applications/IntelliJ IDEA CE.app/Contents/lib/idea_rt.jar" com.intellij.rt.execution.application.AppMain clojure.main -i /private/var/folders/yz/ty6pjvdd5s519s41j2rbn9y40000gn/T/form-init4135615908472467748.clj
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option MaxPermSize=500M; support was removed in 8.0
Connecting to local nREPL server...
Clojure 1.8.0
nREPL server started on port 58450 on host 127.0.0.1 - nrepl://127.0.0.1:58450
(ns cook.test.datomic-benchmark
(:use clojure.test)
(:require [cook.test.testutil :refer (restore-fresh-database! create-dummy-group create-dummy-job create-dummy-instance)]
[datomic.api :as d :refer (q db)]))
=> nil
(defn pull-waiting-job-entids
[db]
(d/q '[:find [?e ...]
:in $ ?state ?committed?
:where
[?e :job/state ?state]
[?e :job/commit-latch ?cl]
[?cl :commit-latch/committed? ?committed?]]
db :job.state/waiting true))
=> #'cook.test.datomic-benchmark/pull-waiting-job-entids
(d/get-database-names "datomic:dev://localhost:4334/*")
=> ("mbrainz-1968-1973" "mbrainz" "stringtemp" "benchmark")
(let [uri "datomic:dev://localhost:4334/benchmark"
conn (restore-fresh-database! uri)
samples 5]
(time (dotimes [_ 100000]
(let [commit-latch-id (d/tempid :db.part/user)
commit-latch {:commit-latch/committed? true
:db/id commit-latch-id}
job-info {:db/id (d/tempid :db.part/user)
:job/uuid (java.util.UUID/randomUUID)
:job/command "ls"
:job/user "wyegelwe"
:job/commit-latch commit-latch-id
:job/name "my-cool-job"
:job/max-retries 5
:job/max-runtime 1000
:job/priority 20
:job/state :job.state/waiting
:job/submit-time #inst "2016-01-01"
:job/resource [{:resource/type :resource.type/cpus
:resource/amount 1.0}
{:resource/type :resource.type/mem
:resource/amount 10.0}]}]
@(d/transact conn [job-info commit-latch]))))
(println "Pulling job entids timing")
(dotimes [_ samples]
(time (count (pull-waiting-job-entids (d/db conn)))))
(println "Entity: access specific fields (all value fields) without reusing entity object")
(let [db (d/db conn)
job-entids (pull-waiting-job-entids db)]
(dotimes [_ samples]
(let [jobs (map (partial d/entity db) job-entids)]
(time (doseq [job jobs]
(:job/uuid job)
(:job/command job)
(:job/user job)
(:job/name job)
(:job/max-retries job)
(:job/max-runtime job)
(:job/priority job))))))
(println "Entity: access specific fields (all value fields) with reusing entity object")
(let [db (d/db conn)
job-entids (pull-waiting-job-entids db)
jobs (map (partial d/entity db) job-entids)]
(dotimes [_ samples]
(time (doseq [job jobs]
(:job/uuid job)
(:job/command job)
(:job/user job)
(:job/name job)
(:job/max-retries job)
(:job/max-runtime job)
(:job/priority job)))))
(println "Entity: access specific fields (including refs) without reusing entity object")
(let [db (d/db conn)
job-entids (pull-waiting-job-entids db)]
(dotimes [_ samples]
(let [jobs (map (partial d/entity db) job-entids)]
(time (doseq [job jobs]
(:job/uuid job)
(:job/command job)
(:job/user job)
(:job/name job)
(:job/max-retries job)
(:job/max-runtime job)
(:job/priority job)
(:job/resource job))))))
(println "Entity: access specific fields (including) with reusing entity object")
(let [db (d/db conn)
job-entids (pull-waiting-job-entids db)
jobs (map (partial d/entity db) job-entids)]
(dotimes [_ samples]
(time (doseq [job jobs]
(:job/uuid job)
(:job/command job)
(:job/user job)
(:job/name job)
(:job/max-retries job)
(:job/max-runtime job)
(:job/priority job)
(:job/resource job)))))
(println "Access data in a map")
(let [db (d/db conn)
job-entids (pull-waiting-job-entids db)
job-maps (d/pull-many db '[*] job-entids)]
(dotimes [_ samples]
(time (doseq [job job-maps]
(:job/uuid job)
(:job/command job)
(:job/user job)
(:job/name job)
(:job/max-retries job)
(:job/max-runtime job)
(:job/priority job)
(:job/resource job))))))
"Elapsed time: 124877.638179 msecs"
Pulling job entids timing
"Elapsed time: 1088.653841 msecs"
"Elapsed time: 659.054097 msecs"
"Elapsed time: 623.330413 msecs"
"Elapsed time: 609.963596 msecs"
"Elapsed time: 562.342343 msecs"
Entity: access specific fields (all value fields) without reusing entity object
"Elapsed time: 1745.332168 msecs"
"Elapsed time: 1191.916732 msecs"
"Elapsed time: 1101.365292 msecs"
"Elapsed time: 1101.107613 msecs"
"Elapsed time: 1111.570657 msecs"
Entity: access specific fields (all value fields) with reusing entity object
"Elapsed time: 1147.349425 msecs"
"Elapsed time: 29.565384 msecs"
"Elapsed time: 23.189255 msecs"
"Elapsed time: 24.142028 msecs"
"Elapsed time: 16.835124 msecs"
Entity: access specific fields (including refs) without reusing entity object
"Elapsed time: 1518.687558 msecs"
"Elapsed time: 1404.465673 msecs"
"Elapsed time: 1371.986521 msecs"
"Elapsed time: 1367.751788 msecs"
"Elapsed time: 1362.106091 msecs"
Entity: access specific fields (including) with reusing entity object
"Elapsed time: 1448.372517 msecs"
"Elapsed time: 25.387547 msecs"
"Elapsed time: 22.056213 msecs"
"Elapsed time: 26.075414 msecs"
"Elapsed time: 24.571212 msecs"
Access data in a map
"Elapsed time: 71.015686 msecs"
"Elapsed time: 46.639799 msecs"
"Elapsed time: 38.540831 msecs"
"Elapsed time: 42.153133 msecs"
"Elapsed time: 32.991175 msecs"
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment