eBay / parallec-samples

Single file examples and ready-to-use servers show how to use parallec.io library. Examples to aggregate APIs and publish to Elastic Search and Kafka, and many more. www.parallec.io
92 stars 36 forks source link

Getting run-time error as below java.lang.NoSuchMethodError: scala.collection.immutable.HashSet$.empty()Lscala/collection/immutable/HashSet; #6

Closed psuryawanshi closed 8 years ago

psuryawanshi commented 8 years ago

Getting below error when creating object -

    ParallelClient pc = new ParallelClient();

/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/bin/java -Didea.launcher.port=7532 "-Didea.launcher.bin.path=/Applications/IntelliJ IDEA.app/Contents/bin" -Dfile.encoding=UTF-8 -classpath "/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/charsets.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/deploy.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/ext/cldrdata.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/ext/dnsns.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/ext/jaccess.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/ext/jfxrt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/ext/localedata.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/ext/nashorn.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/ext/sunec.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/ext/sunjce_provider.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/ext/sunpkcs11.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/ext/zipfs.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/javaws.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/jce.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/jfr.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/jfxswt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/jsse.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/management-agent.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/plugin.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/resources.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/rt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/lib/ant-javafx.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/lib/dt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/lib/javafx-mx.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/lib/jconsole.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/lib/packager.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/lib/sa-jdi.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/lib/tools.jar:/Users/psuryawanshi/CodeBase_Destination/competitive-intel/airdna-import/target/classes:/Users/psuryawanshi/.m2/repository/com/homeaway/commons/hacommons-logging/2.1/hacommons-logging-2.1.jar:/Users/psuryawanshi/.m2/repository/com/google/guava/guava/19.0/guava-19.0.jar:/Users/psuryawanshi/.m2/repository/org/slf4j/log4j-over-slf4j/1.7.16/log4j-over-slf4j-1.7.16.jar:/Users/psuryawanshi/.m2/repository/org/slf4j/jcl-over-slf4j/1.7.16/jcl-over-slf4j-1.7.16.jar:/Users/psuryawanshi/.m2/repository/com/homeaway/commons/hacommons-jmx/1.9/hacommons-jmx-1.9.jar:/Users/psuryawanshi/.m2/repository/mx4j/mx4j-tools/3.0.2/mx4j-tools-3.0.2.jar:/Users/psuryawanshi/.m2/repository/io/confluent/monitoring-interceptors/3.0.0/monitoring-interceptors-3.0.0.jar:/Users/psuryawanshi/.m2/repository/joda-time/joda-time/2.9.1/joda-time-2.9.1.jar:/Users/psuryawanshi/.m2/repository/org/apache/kafka/kafka-clients/0.10.0.0-cp1/kafka-clients-0.10.0.0-cp1.jar:/Users/psuryawanshi/.m2/repository/net/jpountz/lz4/lz4/1.3.0/lz4-1.3.0.jar:/Users/psuryawanshi/.m2/repository/org/scala-lang/scala-library/2.11.0/scala-library-2.11.0.jar:/Users/psuryawanshi/.m2/repository/io/confluent/kafka-avro-serializer/3.0.0/kafka-avro-serializer-3.0.0.jar:/Users/psuryawanshi/.m2/repository/io/confluent/common-config/3.0.0/common-config-3.0.0.jar:/Users/psuryawanshi/.m2/repository/io/confluent/common-utils/3.0.0/common-utils-3.0.0.jar:/Users/psuryawanshi/.m2/repository/com/101tec/zkclient/0.5/zkclient-0.5.jar:/Users/psuryawanshi/.m2/repository/io/confluent/kafka-schema-registry-client/3.0.0/kafka-schema-registry-client-3.0.0.jar:/Users/psuryawanshi/.m2/repository/com/googlecode/json-simple/json-simple/1.1/json-simple-1.1.jar:/Users/psuryawanshi/.m2/repository/commons-cli/commons-cli/1.2/commons-cli-1.2.jar:/Users/psuryawanshi/.m2/repository/org/slf4j/slf4j-api/1.7.8/slf4j-api-1.7.8.jar:/Users/psuryawanshi/.m2/repository/commons-net/commons-net/3.3/commons-net-3.3.jar:/Users/psuryawanshi/.m2/repository/xmlenc/xmlenc/0.52/xmlenc-0.52.jar:/Users/psuryawanshi/.m2/repository/commons-httpclient/commons-httpclient/3.1/commons-httpclient-3.1.jar:/Users/psuryawanshi/.m2/repository/commons-codec/commons-codec/1.4/commons-codec-1.4.jar:/Users/psuryawanshi/.m2/repository/commons-collections/commons-collections/3.2.2/commons-collections-3.2.2.jar:/Users/psuryawanshi/.m2/repository/javax/servlet/servlet-api/2.5/servlet-api-2.5.jar:/Users/psuryawanshi/.m2/repository/org/mortbay/jetty/jetty/6.1.26.hwx/jetty-6.1.26.hwx.jar:/Users/psuryawanshi/.m2/repository/org/mortbay/jetty/jetty-util/6.1.26.hwx/jetty-util-6.1.26.hwx.jar:/Users/psuryawanshi/.m2/repository/asm/asm/3.1/asm-3.1.jar:/Users/psuryawanshi/.m2/repository/commons-lang/commons-lang/2.6/commons-lang-2.6.jar:/Users/psuryawanshi/.m2/repository/org/codehaus/jackson/jackson-core-asl/1.9.13/jackson-core-asl-1.9.13.jar:/Users/psuryawanshi/.m2/repository/org/codehaus/jackson/jackson-mapper-asl/1.9.13/jackson-mapper-asl-1.9.13.jar:/Users/psuryawanshi/.m2/repository/com/google/protobuf/protobuf-java/2.5.0/protobuf-java-2.5.0.jar:/Users/psuryawanshi/.m2/repository/com/google/code/gson/gson/2.2.4/gson-2.2.4.jar:/Users/psuryawanshi/.m2/repository/com/jcraft/jsch/0.1.42/jsch-0.1.42.jar:/Users/psuryawanshi/.m2/repository/com/google/code/findbugs/jsr305/3.0.0/jsr305-3.0.0.jar:/Users/psuryawanshi/.m2/repository/org/apache/zookeeper/zookeeper/3.4.6.2.3.4.0-3485/zookeeper-3.4.6.2.3.4.0-3485.jar:/Users/psuryawanshi/.m2/repository/org/apache/commons/commons-compress/1.4.1/commons-compress-1.4.1.jar:/Users/psuryawanshi/.m2/repository/org/tukaani/xz/1.0/xz-1.0.jar:/Users/psuryawanshi/.m2/repository/log4j/log4j/1.2.17/log4j-1.2.17.jar:/Users/psuryawanshi/.m2/repository/io/netty/netty/3.6.2.Final/netty-3.6.2.Final.jar:/Users/psuryawanshi/.m2/repository/com/fasterxml/jackson/core/jackson-databind/2.7.4/jackson-databind-2.7.4.jar:/Users/psuryawanshi/.m2/repository/com/fasterxml/jackson/core/jackson-annotations/2.7.0/jackson-annotations-2.7.0.jar:/Users/psuryawanshi/.m2/repository/com/fasterxml/jackson/core/jackson-core/2.7.4/jackson-core-2.7.4.jar:/Users/psuryawanshi/.m2/repository/org/apache/avro/avro/1.7.7/avro-1.7.7.jar:/Users/psuryawanshi/.m2/repository/com/thoughtworks/paranamer/paranamer/2.3/paranamer-2.3.jar:/Users/psuryawanshi/.m2/repository/org/xerial/snappy/snappy-java/1.0.5/snappy-java-1.0.5.jar:/Users/psuryawanshi/.m2/repository/com/homeaway/commons/hacommons-logging-events/2.1/hacommons-logging-events-2.1.jar:/Users/psuryawanshi/.m2/repository/org/apache/avro/avro-ipc/1.8.1/avro-ipc-1.8.1.jar:/Users/psuryawanshi/.m2/repository/org/apache/velocity/velocity/1.7/velocity-1.7.jar:/Users/psuryawanshi/.m2/repository/cascading/cascading-core/3.0.4/cascading-core-3.0.4.jar:/Users/psuryawanshi/.m2/repository/riffle/riffle/1.0.0/riffle-1.0.0.jar:/Users/psuryawanshi/.m2/repository/org/jgrapht/jgrapht-core/0.9.1/jgrapht-core-0.9.1.jar:/Users/psuryawanshi/.m2/repository/org/codehaus/janino/janino/2.7.6/janino-2.7.6.jar:/Users/psuryawanshi/.m2/repository/org/codehaus/janino/commons-compiler/2.7.6/commons-compiler-2.7.6.jar:/Users/psuryawanshi/.m2/repository/cascading/cascading-local/3.0.4/cascading-local-3.0.4.jar:/Users/psuryawanshi/.m2/repository/cascading/cascading-hadoop2-mr1/3.0.4/cascading-hadoop2-mr1-3.0.4.jar:/Users/psuryawanshi/.m2/repository/com/homeaway/bigdata/cascading-kafka-tap/2.0-SNAPSHOT/cascading-kafka-tap-2.0-20160621.172039-2.jar:/Users/psuryawanshi/.m2/repository/org/apache/hadoop/hadoop-core/0.20.2/hadoop-core-0.20.2.jar:/Users/psuryawanshi/.m2/repository/tomcat/jasper-runtime/5.5.12/jasper-runtime-5.5.12.jar:/Users/psuryawanshi/.m2/repository/tomcat/jasper-compiler/5.5.12/jasper-compiler-5.5.12.jar:/Users/psuryawanshi/.m2/repository/org/mortbay/jetty/jsp-api-2.1/6.1.14/jsp-api-2.1-6.1.14.jar:/Users/psuryawanshi/.m2/repository/org/mortbay/jetty/jsp-2.1/6.1.14/jsp-2.1-6.1.14.jar:/Users/psuryawanshi/.m2/repository/ant/ant/1.6.5/ant-1.6.5.jar:/Users/psuryawanshi/.m2/repository/commons-el/commons-el/1.0/commons-el-1.0.jar:/Users/psuryawanshi/.m2/repository/org/mortbay/jetty/servlet-api-2.5/6.1.14/servlet-api-2.5-6.1.14.jar:/Users/psuryawanshi/.m2/repository/net/sf/kosmosfs/kfs/0.3/kfs-0.3.jar:/Users/psuryawanshi/.m2/repository/hsqldb/hsqldb/1.8.0.10/hsqldb-1.8.0.10.jar:/Users/psuryawanshi/.m2/repository/oro/oro/2.0.8/oro-2.0.8.jar:/Users/psuryawanshi/.m2/repository/org/eclipse/jdt/core/3.1.1/core-3.1.1.jar:/Users/psuryawanshi/.m2/repository/org/springframework/boot/spring-boot-autoconfigure/1.3.5.RELEASE/spring-boot-autoconfigure-1.3.5.RELEASE.jar:/Users/psuryawanshi/.m2/repository/org/springframework/spring-context/4.3.0.RELEASE/spring-context-4.3.0.RELEASE.jar:/Users/psuryawanshi/.m2/repository/org/springframework/spring-aop/4.3.0.RELEASE/spring-aop-4.3.0.RELEASE.jar:/Users/psuryawanshi/.m2/repository/org/springframework/spring-expression/4.3.0.RELEASE/spring-expression-4.3.0.RELEASE.jar:/Users/psuryawanshi/.m2/repository/org/springframework/spring-core/4.3.0.RELEASE/spring-core-4.3.0.RELEASE.jar:/Users/psuryawanshi/.m2/repository/org/springframework/spring-beans/4.3.0.RELEASE/spring-beans-4.3.0.RELEASE.jar:/Users/psuryawanshi/.m2/repository/org/springframework/boot/spring-boot/1.3.5.RELEASE/spring-boot-1.3.5.RELEASE.jar:/Users/psuryawanshi/.m2/repository/commons-io/commons-io/2.4/commons-io-2.4.jar:/Users/psuryawanshi/.m2/repository/cascading/avro/avro-scheme/2.5.0/avro-scheme-2.5.0.jar:/Users/psuryawanshi/.m2/repository/org/apache/avro/avro-mapred/1.7.6/avro-mapred-1.7.6-hadoop2.jar:/Users/psuryawanshi/.m2/repository/cascading/cascading-hadoop/2.5.5/cascading-hadoop-2.5.5.jar:/Users/psuryawanshi/.m2/repository/org/apache/avro/trevni-avro/1.7.6/trevni-avro-1.7.6.jar:/Users/psuryawanshi/.m2/repository/org/apache/avro/avro-mapred/1.7.6/avro-mapred-1.7.6-hadoop1.jar:/Users/psuryawanshi/.m2/repository/org/apache/avro/avro-ipc/1.7.6/avro-ipc-1.7.6-tests.jar:/Users/psuryawanshi/.m2/repository/org/mortbay/jetty/servlet-api/2.5-20081211/servlet-api-2.5-20081211.jar:/Users/psuryawanshi/.m2/repository/org/apache/avro/trevni-core/1.7.6/trevni-core-1.7.6.jar:/Users/psuryawanshi/.m2/repository/com/tresata/cascading-opencsv/0.2.0/cascading-opencsv-0.2.0.jar:/Users/psuryawanshi/.m2/repository/net/sf/opencsv/opencsv/2.3/opencsv-2.3.jar:/Users/psuryawanshi/.m2/repository/com/amazonaws/aws-java-sdk/1.2.0/aws-java-sdk-1.2.0.jar:/Users/psuryawanshi/.m2/repository/commons-logging/commons-logging/1.2.1-SNAPSHOT/commons-logging-1.2.1-20161017.224056-14.jar:/Users/psuryawanshi/.m2/repository/org/apache/httpcomponents/httpclient/4.5.3-SNAPSHOT/httpclient-4.5.3-20161004.193839-2.jar:/Users/psuryawanshi/.m2/repository/javax/mail/mail/1.5.0-b01/mail-1.5.0-b01.jar:/Users/psuryawanshi/.m2/repository/stax/stax-api/1.0.1/stax-api-1.0.1.jar:/Users/psuryawanshi/.m2/repository/org/apache/httpcomponents/httpcore/4.4/httpcore-4.4.jar:/Users/psuryawanshi/.m2/repository/com/univocity/univocity-parsers/2.2.2/univocity-parsers-2.2.2.jar:/Users/psuryawanshi/.m2/repository/net/java/dev/jets3t/jets3t/0.7.4/jets3t-0.7.4.jar:/Users/psuryawanshi/.m2/repository/com/jamesmurty/utils/java-xmlbuilder/0.3/java-xmlbuilder-0.3.jar:/Users/psuryawanshi/.m2/repository/org/apache/commons/commons-email/1.4/commons-email-1.4.jar:/Users/psuryawanshi/.m2/repository/com/sun/mail/javax.mail/1.5.2/javax.mail-1.5.2.jar:/Users/psuryawanshi/.m2/repository/javax/activation/activation/1.1.1/activation-1.1.1.jar:/Users/psuryawanshi/.m2/repository/io/parallec/parallec-core/0.10.1/parallec-core-0.10.1.jar:/Users/psuryawanshi/.m2/repository/com/nanohttpd/nanohttpd/2.1.1/nanohttpd-2.1.1.jar:/Users/psuryawanshi/.m2/repository/ch/qos/logback/logback-classic/1.1.3/logback-classic-1.1.3.jar:/Users/psuryawanshi/.m2/repository/ch/qos/logback/logback-core/1.1.3/logback-core-1.1.3.jar:/Users/psuryawanshi/.m2/repository/org/apache/commons/commons-lang3/3.0/commons-lang3-3.0.jar:/Users/psuryawanshi/.m2/repository/com/ning/async-http-client/1.6.5/async-http-client-1.6.5.jar:/Users/psuryawanshi/.m2/repository/org/jboss/netty/netty/3.2.5.Final/netty-3.2.5.Final.jar:/Users/psuryawanshi/.m2/repository/com/typesafe/akka/akka-actor_2.10/2.3.3/akka-actor_2.10-2.3.3.jar:/Users/psuryawanshi/.m2/repository/com/typesafe/config/1.2.1/config-1.2.1.jar:/Users/psuryawanshi/.m2/repository/com/typesafe/akka/akka-cluster_2.10/2.3.3/akka-cluster_2.10-2.3.3.jar:/Users/psuryawanshi/.m2/repository/com/typesafe/akka/akka-remote_2.10/2.3.3/akka-remote_2.10-2.3.3.jar:/Users/psuryawanshi/.m2/repository/org/uncommons/maths/uncommons-maths/1.2.2a/uncommons-maths-1.2.2a.jar:/Users/psuryawanshi/.m2/repository/org/codehaus/jettison/jettison/1.3.7/jettison-1.3.7.jar:/Users/psuryawanshi/.m2/repository/com/openpojo/openpojo/0.8.0/openpojo-0.8.0.jar:/Users/psuryawanshi/.m2/repository/com/jayway/jsonpath/json-path/2.0.0/json-path-2.0.0.jar:/Users/psuryawanshi/.m2/repository/net/minidev/json-smart/2.1.1/json-smart-2.1.1.jar:/Users/psuryawanshi/.m2/repository/net/minidev/asm/1.0.2/asm-1.0.2.jar:/Users/psuryawanshi/.m2/repository/org/asynchttpclient/async-http-client/2.0.18/async-http-client-2.0.18.jar:/Users/psuryawanshi/.m2/repository/org/asynchttpclient/async-http-client-netty-utils/2.0.18/async-http-client-netty-utils-2.0.18.jar:/Users/psuryawanshi/.m2/repository/io/netty/netty-buffer/4.0.42.Final/netty-buffer-4.0.42.Final.jar:/Users/psuryawanshi/.m2/repository/io/netty/netty-codec-http/4.0.42.Final/netty-codec-http-4.0.42.Final.jar:/Users/psuryawanshi/.m2/repository/io/netty/netty-codec/4.0.42.Final/netty-codec-4.0.42.Final.jar:/Users/psuryawanshi/.m2/repository/io/netty/netty-handler/4.0.42.Final/netty-handler-4.0.42.Final.jar:/Users/psuryawanshi/.m2/repository/io/netty/netty-transport-native-epoll/4.0.42.Final/netty-transport-native-epoll-4.0.42.Final-linux-x86_64.jar:/Users/psuryawanshi/.m2/repository/io/netty/netty-common/4.0.42.Final/netty-common-4.0.42.Final.jar:/Users/psuryawanshi/.m2/repository/io/netty/netty-transport/4.0.42.Final/netty-transport-4.0.42.Final.jar:/Users/psuryawanshi/.m2/repository/org/asynchttpclient/netty-resolver-dns/2.0.18/netty-resolver-dns-2.0.18.jar:/Users/psuryawanshi/.m2/repository/org/asynchttpclient/netty-resolver/2.0.18/netty-resolver-2.0.18.jar:/Users/psuryawanshi/.m2/repository/org/asynchttpclient/netty-codec-dns/2.0.18/netty-codec-dns-2.0.18.jar:/Users/psuryawanshi/.m2/repository/org/reactivestreams/reactive-streams/1.0.0/reactive-streams-1.0.0.jar:/Users/psuryawanshi/.m2/repository/com/typesafe/netty/netty-reactive-streams/1.0.8/netty-reactive-streams-1.0.8.jar:/Users/psuryawanshi/.m2/repository/org/javassist/javassist/3.20.0-GA/javassist-3.20.0-GA.jar:/Applications/IntelliJ IDEA.app/Contents/lib/idea_rt.jar" com.intellij.rt.execution.application.AppMain com.homeaway.geo.HttpDiffRequestsSameServerApp 12:55:16.760 [main] INFO i.p.core.task.ParallelTaskManager - Initialized ParallelTaskManager... 12:55:16.773 [main] INFO i.p.c.r.AsyncHttpClientFactoryEmbed - FastClient: ningFastClientConnectionTimeoutMillis: 4000 12:55:16.774 [main] INFO i.p.c.r.AsyncHttpClientFactoryEmbed - FastClient: ningFastClientRequestTimeoutMillis: 14000 12:55:16.824 [main] INFO c.n.h.c.p.n.NettyAsyncHttpProvider - Number of application's worked threads is 0 12:55:16.829 [main] INFO c.n.h.c.p.n.NettyAsyncHttpProvider - Number of application's worked threads is 0 12:55:16.829 [main] DEBUG com.ning.http.client.AsyncHttpClient - Default provider not found com.ning.http.client.providers.netty.NettyAsyncHttpProvider. Using the com.ning.http.client.providers.jdk.JDKAsyncHttpProvider 12:55:16.832 [main] INFO c.n.h.c.p.n.NettyAsyncHttpProvider - Number of application's worked threads is 0 12:55:16.832 [main] INFO c.n.h.c.p.n.NettyAsyncHttpProvider - Number of application's worked threads is 0 12:55:16.832 [main] DEBUG com.ning.http.client.AsyncHttpClient - Default provider not found com.ning.http.client.providers.netty.NettyAsyncHttpProvider. Using the com.ning.http.client.providers.jdk.JDKAsyncHttpProvider 12:55:16.957 [main] INFO io.parallec.core.ParallelClient - Initialing Parallel Client Resources: actor system, HttpClientStore, Task Manager .... 12:55:17.048 [main] DEBUG io.parallec.core.actor.ActorConfig - Load Actor config Config(SimpleConfigObject({"akka":{"actor":{"creation-timeout":"20s","debug":{"autoreceive":"off","event-stream":"off","fsm":"off","lifecycle":"off","receive":"off","router-misconfiguration":"off","unhandled":"off"},"default-dispatcher":{"attempt-teamwork":"on","default-executor":{"fallback":"fork-join-executor"},"executor":"default-executor","fork-join-executor":{"parallelism-factor":3,"parallelism-max":64,"parallelism-min":8},"mailbox-requirement":"","shutdown-timeout":"1s","thread-pool-executor":{"allow-core-timeout":"on","core-pool-size-factor":3,"core-pool-size-max":64,"core-pool-size-min":8,"keep-alive-time":"60s","max-pool-size-factor":3,"max-pool-size-max":64,"max-pool-size-min":8,"task-queue-size":-1,"task-queue-type":"linked"},"throughput":5,"throughput-deadline-time":"0ms","type":"Dispatcher"},"default-mailbox":{"mailbox-capacity":1000,"mailbox-push-timeout-time":"10s","mailbox-type":"akka.dispatch.UnboundedMailbox","stash-capacity":-1},"deployment":{"default":{"cluster":{"allow-local-routees":"on","enabled":"off","max-nr-of-instances-per-node":1,"routees-path":"","use-role":""},"dispatcher":"","mailbox":"","metrics-selector":"mix","nr-of-instances":1,"remote":"","resizer":{"backoff-rate":0.1,"backoff-threshold":0.3,"enabled":"off","lower-bound":1,"messages-per-resize":10,"pressure-threshold":1,"rampup-rate":0.2,"upper-bound":10},"routees":{"paths":[]},"router":"from-code","target":{"nodes":[]},"virtual-nodes-factor":10,"within":"5 seconds"}},"dsl":{"default-timeout":"5s","inbox-size":1000},"guardian-supervisor-strategy":"akka.actor.DefaultSupervisorStrategy","mailbox":{"bounded-deque-based":{"mailbox-type":"akka.dispatch.BoundedDequeBasedMailbox"},"bounded-queue-based":{"mailbox-type":"akka.dispatch.BoundedMailbox"},"requirements":{"akka.dispatch.BoundedDequeBasedMessageQueueSemantics":"akka.actor.mailbox.bounded-deque-based","akka.dispatch.BoundedMessageQueueSemantics":"akka.actor.mailbox.bounded-queue-based","akka.dispatch.DequeBasedMessageQueueSemantics":"akka.actor.mailbox.unbounded-deque-based","akka.dispatch.MultipleConsumerSemantics":"akka.actor.mailbox.unbounded-queue-based","akka.dispatch.UnboundedDequeBasedMessageQueueSemantics":"akka.actor.mailbox.unbounded-deque-based","akka.dispatch.UnboundedMessageQueueSemantics":"akka.actor.mailbox.unbounded-queue-based"},"unbounded-deque-based":{"mailbox-type":"akka.dispatch.UnboundedDequeBasedMailbox"},"unbounded-queue-based":{"mailbox-type":"akka.dispatch.UnboundedMailbox"}},"provider":"akka.actor.LocalActorRefProvider","reaper-interval":"5s","router":{"type-mapping":{"adaptive-group":"akka.cluster.routing.AdaptiveLoadBalancingGroup","adaptive-pool":"akka.cluster.routing.AdaptiveLoadBalancingPool","balancing-pool":"akka.routing.BalancingPool","broadcast-group":"akka.routing.BroadcastGroup","broadcast-pool":"akka.routing.BroadcastPool","consistent-hashing-group":"akka.routing.ConsistentHashingGroup","consistent-hashing-pool":"akka.routing.ConsistentHashingPool","from-code":"akka.routing.NoRouter","random-group":"akka.routing.RandomGroup","random-pool":"akka.routing.RandomPool","round-robin-group":"akka.routing.RoundRobinGroup","round-robin-pool":"akka.routing.RoundRobinPool","scatter-gather-group":"akka.routing.ScatterGatherFirstCompletedGroup","scatter-gather-pool":"akka.routing.ScatterGatherFirstCompletedPool","smallest-mailbox-pool":"akka.routing.SmallestMailboxPool"}},"serialization-bindings":{"[B":"bytes","akka.actor.ActorSelectionMessage":"akka-containers","akka.cluster.ClusterMessage":"akka-cluster","akka.remote.DaemonMsgCreate":"daemon-create","com.google.protobuf.GeneratedMessage":"proto","java.io.Serializable":"java"},"serialize-creators":"off","serialize-messages":"off","serializers":{"akka-cluster":"akka.cluster.protobuf.ClusterMessageSerializer","akka-containers":"akka.remote.serialization.MessageContainerSerializer","bytes":"akka.serialization.ByteArraySerializer","daemon-create":"akka.remote.serialization.DaemonMsgCreateSerializer","java":"akka.serialization.JavaSerializer","proto":"akka.remote.serialization.ProtobufSerializer"},"typed":{"timeout":"5s"},"unstarted-push-timeout":"10s"},"cluster":{"auto-down":"off","auto-down-unreachable-after":"off","failure-detector":{"acceptable-heartbeat-pause":"3 s","expected-response-after":"5 s","heartbeat-interval":"1 s","implementation-class":"akka.remote.PhiAccrualFailureDetector","max-sample-size":1000,"min-std-deviation":"100 ms","monitored-by-nr-of-members":5,"threshold":8},"gossip-different-view-probability":0.8,"gossip-interval":"1s","gossip-time-to-live":"2s","jmx":{"enabled":"on"},"leader-actions-interval":"1s","log-info":"on","metrics":{"collect-interval":"3s","collector-class":"akka.cluster.SigarMetricsCollector","enabled":"on","gossip-interval":"3s","moving-average-half-life":"12s"},"min-nr-of-members":1,"periodic-tasks-initial-delay":"1s","publish-stats-interval":"off","reduce-gossip-different-view-probability":400,"retry-unsuccessful-join-after":"10s","role":{},"roles":[],"scheduler":{"tick-duration":"33ms","ticks-per-wheel":512},"seed-node-timeout":"5s","seed-nodes":[],"unreachable-nodes-reaper-interval":"1s","use-dispatcher":""},"daemonic":"off","extensions":[],"home":"","io":{"pinned-dispatcher":{"executor":"thread-pool-executor","thread-pool-executor":{"allow-core-pool-timeout":"off"},"type":"PinnedDispatcher"},"tcp":{"batch-accept-limit":10,"direct-buffer-pool-limit":1000,"direct-buffer-size":"128 KiB","file-io-dispatcher":"akka.actor.default-dispatcher","file-io-transferTo-limit":"512 KiB","finish-connect-retries":5,"management-dispatcher":"akka.actor.default-dispatcher","max-channels":256000,"max-received-message-size":"unlimited","nr-of-selectors":1,"register-timeout":"5s","selector-association-retries":10,"selector-dispatcher":"akka.io.pinned-dispatcher","trace-logging":"off","worker-dispatcher":"akka.actor.default-dispatcher"},"udp":{"direct-buffer-pool-limit":1000,"direct-buffer-size":"128 KiB","management-dispatcher":"akka.actor.default-dispatcher","max-channels":4096,"nr-of-selectors":1,"receive-throughput":3,"received-message-size-limit":"unlimited","select-timeout":"infinite","selector-association-retries":10,"selector-dispatcher":"akka.io.pinned-dispatcher","trace-logging":"off","worker-dispatcher":"akka.actor.default-dispatcher"},"udp-connected":{"direct-buffer-pool-limit":1000,"direct-buffer-size":"128 KiB","management-dispatcher":"akka.actor.default-dispatcher","max-channels":4096,"nr-of-selectors":1,"receive-throughput":3,"received-message-size-limit":"unlimited","select-timeout":"infinite","selector-association-retries":10,"selector-dispatcher":"akka.io.pinned-dispatcher","trace-logging":"off","worker-dispatcher":"akka.actor.default-dispatcher"}},"jvm-exit-on-fatal-error":"on","log-config-on-start":"off","log-dead-letters":0,"log-dead-letters-during-shutdown":"off","logger-startup-timeout":"5s","loggers":["akka.event.Logging$DefaultLogger"],"loglevel":"INFO","remote":{"adapters":{"gremlin":"akka.remote.transport.FailureInjectorProvider","trttl":"akka.remote.transport.ThrottlerProvider"},"backoff-interval":"5 ms","backoff-remote-dispatcher":{"executor":"fork-join-executor","fork-join-executor":{"parallelism-max":2,"parallelism-min":2},"type":"Dispatcher"},"command-ack-timeout":"30 s","default-remote-dispatcher":{"executor":"fork-join-executor","fork-join-executor":{"parallelism-max":2,"parallelism-min":2},"type":"Dispatcher"},"enabled-transports":["akka.remote.netty.tcp"],"flush-wait-on-shutdown":"2 s","gremlin":{"debug":"off"},"initial-system-message-delivery-timeout":"3 m","log-buffer-size-exceeding":50000,"log-frame-size-exceeding":"off","log-received-messages":"off","log-remote-lifecycle-events":"on","log-sent-messages":"off","netty":{"ssl":{"applied-adapters":[],"backlog":4096,"client-socket-worker-pool":{"pool-size-factor":1,"pool-size-max":2,"pool-size-min":2},"connection-timeout":"15 s","enable-ssl":true,"hostname":"","maximum-frame-size":"128000b","port":2552,"receive-buffer-size":"256000b","security":{"enabled-algorithms":["TLS_RSA_WITH_AES_128_CBC_SHA"],"key-password":"changeme","key-store":"keystore","key-store-password":"changeme","protocol":"TLSv1","random-number-generator":"","trust-store":"truststore","trust-store-password":"changeme"},"send-buffer-size":"256000b","server-socket-worker-pool":{"pool-size-factor":1,"pool-size-max":2,"pool-size-min":2},"tcp-keepalive":"on","tcp-nodelay":"on","tcp-reuse-addr":"off-for-windows","transport-class":"akka.remote.transport.netty.NettyTransport","transport-protocol":"tcp","use-dispatcher-for-io":"","write-buffer-high-water-mark":"0b","write-buffer-low-water-mark":"0b"},"tcp":{"applied-adapters":[],"backlog":4096,"client-socket-worker-pool":{"pool-size-factor":1,"pool-size-max":2,"pool-size-min":2},"connection-timeout":"15 s","enable-ssl":false,"hostname":"","maximum-frame-size":"128000b","port":2552,"receive-buffer-size":"256000b","send-buffer-size":"256000b","server-socket-worker-pool":{"pool-size-factor":1,"pool-size-max":2,"pool-size-min":2},"tcp-keepalive":"on","tcp-nodelay":"on","tcp-reuse-addr":"off-for-windows","transport-class":"akka.remote.transport.netty.NettyTransport","transport-protocol":"tcp","use-dispatcher-for-io":"","write-buffer-high-water-mark":"0b","write-buffer-low-water-mark":"0b"},"udp":{"applied-adapters":[],"backlog":4096,"client-socket-worker-pool":{"pool-size-factor":1,"pool-size-max":2,"pool-size-min":2},"connection-timeout":"15 s","enable-ssl":false,"hostname":"","maximum-frame-size":"128000b","port":2552,"receive-buffer-size":"256000b","send-buffer-size":"256000b","server-socket-worker-pool":{"pool-size-factor":1,"pool-size-max":2,"pool-size-min":2},"tcp-keepalive":"on","tcp-nodelay":"on","tcp-reuse-addr":"off-for-windows","transport-class":"akka.remote.transport.netty.NettyTransport","transport-protocol":"udp","use-dispatcher-for-io":"","write-buffer-high-water-mark":"0b","write-buffer-low-water-mark":"0b"}},"prune-quarantine-marker-after":"5 d","require-cookie":"off","resend-interval":"2 s","retry-gate-closed-for":"5 s","secure-cookie":"","shutdown-timeout":"10 s","startup-timeout":"10 s","system-message-ack-piggyback-timeout":"0.3 s","system-message-buffer-size":1000,"transport-failure-detector":{"acceptable-heartbeat-pause":"20 s","heartbeat-interval":"4 s","implementation-class":"akka.remote.DeadlineFailureDetector"},"trusted-selection-paths":[],"untrusted-mode":"off","use-dispatcher":"akka.remote.default-remote-dispatcher","use-passive-connections":"on","watch-failure-detector":{"acceptable-heartbeat-pause":"10 s","expected-response-after":"3 s","heartbeat-interval":"1 s","implementation-class":"akka.remote.PhiAccrualFailureDetector","max-sample-size":200,"min-std-deviation":"100 ms","threshold":10,"unreachable-nodes-reaper-interval":"1s"}},"scheduler":{"implementation":"akka.actor.LightArrayRevolverScheduler","shutdown-timeout":"5s","tick-duration":"10ms","ticks-per-wheel":512},"stdout-loglevel":"WARNING","version":"2.3.3"},"awt":{"toolkit":"sun.lwawt.macosx.LWCToolkit"},"file":{"encoding":{"pkg":"sun.io"},"separator":"/"},"gopherProxySet":"false","idea":{"launcher":{"bin":{"path":"/Applications/IntelliJ IDEA.app/Contents/bin"},"port":"7532"}},"java":{"awt":{"graphicsenv":"sun.awt.CGraphicsEnvironment","printerjob":"sun.lwawt.macosx.CPrinterJob"},"class":{"path":"/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/charsets.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/deploy.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/ext/cldrdata.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/ext/dnsns.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/ext/jaccess.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/ext/jfxrt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/ext/localedata.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/ext/nashorn.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/ext/sunec.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/ext/sunjce_provider.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/ext/sunpkcs11.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/ext/zipfs.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/javaws.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/jce.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/jfr.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/jfxswt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/jsse.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/management-agent.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/plugin.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/resources.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/rt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/lib/ant-javafx.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/lib/dt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/lib/javafx-mx.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/lib/jconsole.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/lib/packager.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/lib/sa-jdi.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/lib/tools.jar:/Users/psuryawanshi/CodeBase_Destination/competitive-intel/airdna-import/target/classes:/Users/psuryawanshi/.m2/repository/com/homeaway/commons/hacommons-logging/2.1/hacommons-logging-2.1.jar:/Users/psuryawanshi/.m2/repository/com/google/guava/guava/19.0/guava-19.0.jar:/Users/psuryawanshi/.m2/repository/org/slf4j/log4j-over-slf4j/1.7.16/log4j-over-slf4j-1.7.16.jar:/Users/psuryawanshi/.m2/repository/org/slf4j/jcl-over-slf4j/1.7.16/jcl-over-slf4j-1.7.16.jar:/Users/psuryawanshi/.m2/repository/com/homeaway/commons/hacommons-jmx/1.9/hacommons-jmx-1.9.jar:/Users/psuryawanshi/.m2/repository/mx4j/mx4j-tools/3.0.2/mx4j-tools-3.0.2.jar:/Users/psuryawanshi/.m2/repository/io/confluent/monitoring-interceptors/3.0.0/monitoring-interceptors-3.0.0.jar:/Users/psuryawanshi/.m2/repository/joda-time/joda-time/2.9.1/joda-time-2.9.1.jar:/Users/psuryawanshi/.m2/repository/org/apache/kafka/kafka-clients/0.10.0.0-cp1/kafka-clients-0.10.0.0-cp1.jar:/Users/psuryawanshi/.m2/repository/net/jpountz/lz4/lz4/1.3.0/lz4-1.3.0.jar:/Users/psuryawanshi/.m2/repository/org/scala-lang/scala-library/2.11.0/scala-library-2.11.0.jar:/Users/psuryawanshi/.m2/repository/io/confluent/kafka-avro-serializer/3.0.0/kafka-avro-serializer-3.0.0.jar:/Users/psuryawanshi/.m2/repository/io/confluent/common-config/3.0.0/common-config-3.0.0.jar:/Users/psuryawanshi/.m2/repository/io/confluent/common-utils/3.0.0/common-utils-3.0.0.jar:/Users/psuryawanshi/.m2/repository/com/101tec/zkclient/0.5/zkclient-0.5.jar:/Users/psuryawanshi/.m2/repository/io/confluent/kafka-schema-registry-client/3.0.0/kafka-schema-registry-client-3.0.0.jar:/Users/psuryawanshi/.m2/repository/com/googlecode/json-simple/json-simple/1.1/json-simple-1.1.jar:/Users/psuryawanshi/.m2/repository/commons-cli/commons-cli/1.2/commons-cli-1.2.jar:/Users/psuryawanshi/.m2/repository/org/slf4j/slf4j-api/1.7.8/slf4j-api-1.7.8.jar:/Users/psuryawanshi/.m2/repository/commons-net/commons-net/3.3/commons-net-3.3.jar:/Users/psuryawanshi/.m2/repository/xmlenc/xmlenc/0.52/xmlenc-0.52.jar:/Users/psuryawanshi/.m2/repository/commons-httpclient/commons-httpclient/3.1/commons-httpclient-3.1.jar:/Users/psuryawanshi/.m2/repository/commons-codec/commons-codec/1.4/commons-codec-1.4.jar:/Users/psuryawanshi/.m2/repository/commons-collections/commons-collections/3.2.2/commons-collections-3.2.2.jar:/Users/psuryawanshi/.m2/repository/javax/servlet/servlet-api/2.5/servlet-api-2.5.jar:/Users/psuryawanshi/.m2/repository/org/mortbay/jetty/jetty/6.1.26.hwx/jetty-6.1.26.hwx.jar:/Users/psuryawanshi/.m2/repository/org/mortbay/jetty/jetty-util/6.1.26.hwx/jetty-util-6.1.26.hwx.jar:/Users/psuryawanshi/.m2/repository/asm/asm/3.1/asm-3.1.jar:/Users/psuryawanshi/.m2/repository/commons-lang/commons-lang/2.6/commons-lang-2.6.jar:/Users/psuryawanshi/.m2/repository/org/codehaus/jackson/jackson-core-asl/1.9.13/jackson-core-asl-1.9.13.jar:/Users/psuryawanshi/.m2/repository/org/codehaus/jackson/jackson-mapper-asl/1.9.13/jackson-mapper-asl-1.9.13.jar:/Users/psuryawanshi/.m2/repository/com/google/protobuf/protobuf-java/2.5.0/protobuf-java-2.5.0.jar:/Users/psuryawanshi/.m2/repository/com/google/code/gson/gson/2.2.4/gson-2.2.4.jar:/Users/psuryawanshi/.m2/repository/com/jcraft/jsch/0.1.42/jsch-0.1.42.jar:/Users/psuryawanshi/.m2/repository/com/google/code/findbugs/jsr305/3.0.0/jsr305-3.0.0.jar:/Users/psuryawanshi/.m2/repository/org/apache/zookeeper/zookeeper/3.4.6.2.3.4.0-3485/zookeeper-3.4.6.2.3.4.0-3485.jar:/Users/psuryawanshi/.m2/repository/org/apache/commons/commons-compress/1.4.1/commons-compress-1.4.1.jar:/Users/psuryawanshi/.m2/repository/org/tukaani/xz/1.0/xz-1.0.jar:/Users/psuryawanshi/.m2/repository/log4j/log4j/1.2.17/log4j-1.2.17.jar:/Users/psuryawanshi/.m2/repository/io/netty/netty/3.6.2.Final/netty-3.6.2.Final.jar:/Users/psuryawanshi/.m2/repository/com/fasterxml/jackson/core/jackson-databind/2.7.4/jackson-databind-2.7.4.jar:/Users/psuryawanshi/.m2/repository/com/fasterxml/jackson/core/jackson-annotations/2.7.0/jackson-annotations-2.7.0.jar:/Users/psuryawanshi/.m2/repository/com/fasterxml/jackson/core/jackson-core/2.7.4/jackson-core-2.7.4.jar:/Users/psuryawanshi/.m2/repository/org/apache/avro/avro/1.7.7/avro-1.7.7.jar:/Users/psuryawanshi/.m2/repository/com/thoughtworks/paranamer/paranamer/2.3/paranamer-2.3.jar:/Users/psuryawanshi/.m2/repository/org/xerial/snappy/snappy-java/1.0.5/snappy-java-1.0.5.jar:/Users/psuryawanshi/.m2/repository/com/homeaway/commons/hacommons-logging-events/2.1/hacommons-logging-events-2.1.jar:/Users/psuryawanshi/.m2/repository/org/apache/avro/avro-ipc/1.8.1/avro-ipc-1.8.1.jar:/Users/psuryawanshi/.m2/repository/org/apache/velocity/velocity/1.7/velocity-1.7.jar:/Users/psuryawanshi/.m2/repository/cascading/cascading-core/3.0.4/cascading-core-3.0.4.jar:/Users/psuryawanshi/.m2/repository/riffle/riffle/1.0.0/riffle-1.0.0.jar:/Users/psuryawanshi/.m2/repository/org/jgrapht/jgrapht-core/0.9.1/jgrapht-core-0.9.1.jar:/Users/psuryawanshi/.m2/repository/org/codehaus/janino/janino/2.7.6/janino-2.7.6.jar:/Users/psuryawanshi/.m2/repository/org/codehaus/janino/commons-compiler/2.7.6/commons-compiler-2.7.6.jar:/Users/psuryawanshi/.m2/repository/cascading/cascading-local/3.0.4/cascading-local-3.0.4.jar:/Users/psuryawanshi/.m2/repository/cascading/cascading-hadoop2-mr1/3.0.4/cascading-hadoop2-mr1-3.0.4.jar:/Users/psuryawanshi/.m2/repository/com/homeaway/bigdata/cascading-kafka-tap/2.0-SNAPSHOT/cascading-kafka-tap-2.0-20160621.172039-2.jar:/Users/psuryawanshi/.m2/repository/org/apache/hadoop/hadoop-core/0.20.2/hadoop-core-0.20.2.jar:/Users/psuryawanshi/.m2/repository/tomcat/jasper-runtime/5.5.12/jasper-runtime-5.5.12.jar:/Users/psuryawanshi/.m2/repository/tomcat/jasper-compiler/5.5.12/jasper-compiler-5.5.12.jar:/Users/psuryawanshi/.m2/repository/org/mortbay/jetty/jsp-api-2.1/6.1.14/jsp-api-2.1-6.1.14.jar:/Users/psuryawanshi/.m2/repository/org/mortbay/jetty/jsp-2.1/6.1.14/jsp-2.1-6.1.14.jar:/Users/psuryawanshi/.m2/repository/ant/ant/1.6.5/ant-1.6.5.jar:/Users/psuryawanshi/.m2/repository/commons-el/commons-el/1.0/commons-el-1.0.jar:/Users/psuryawanshi/.m2/repository/org/mortbay/jetty/servlet-api-2.5/6.1.14/servlet-api-2.5-6.1.14.jar:/Users/psuryawanshi/.m2/repository/net/sf/kosmosfs/kfs/0.3/kfs-0.3.jar:/Users/psuryawanshi/.m2/repository/hsqldb/hsqldb/1.8.0.10/hsqldb-1.8.0.10.jar:/Users/psuryawanshi/.m2/repository/oro/oro/2.0.8/oro-2.0.8.jar:/Users/psuryawanshi/.m2/repository/org/eclipse/jdt/core/3.1.1/core-3.1.1.jar:/Users/psuryawanshi/.m2/repository/org/springframework/boot/spring-boot-autoconfigure/1.3.5.RELEASE/spring-boot-autoconfigure-1.3.5.RELEASE.jar:/Users/psuryawanshi/.m2/repository/org/springframework/spring-context/4.3.0.RELEASE/spring-context-4.3.0.RELEASE.jar:/Users/psuryawanshi/.m2/repository/org/springframework/spring-aop/4.3.0.RELEASE/spring-aop-4.3.0.RELEASE.jar:/Users/psuryawanshi/.m2/repository/org/springframework/spring-expression/4.3.0.RELEASE/spring-expression-4.3.0.RELEASE.jar:/Users/psuryawanshi/.m2/repository/org/springframework/spring-core/4.3.0.RELEASE/spring-core-4.3.0.RELEASE.jar:/Users/psuryawanshi/.m2/repository/org/springframework/spring-beans/4.3.0.RELEASE/spring-beans-4.3.0.RELEASE.jar:/Users/psuryawanshi/.m2/repository/org/springframework/boot/spring-boot/1.3.5.RELEASE/spring-boot-1.3.5.RELEASE.jar:/Users/psuryawanshi/.m2/repository/commons-io/commons-io/2.4/commons-io-2.4.jar:/Users/psuryawanshi/.m2/repository/cascading/avro/avro-scheme/2.5.0/avro-scheme-2.5.0.jar:/Users/psuryawanshi/.m2/repository/org/apache/avro/avro-mapred/1.7.6/avro-mapred-1.7.6-hadoop2.jar:/Users/psuryawanshi/.m2/repository/cascading/cascading-hadoop/2.5.5/cascading-hadoop-2.5.5.jar:/Users/psuryawanshi/.m2/repository/org/apache/avro/trevni-avro/1.7.6/trevni-avro-1.7.6.jar:/Users/psuryawanshi/.m2/repository/org/apache/avro/avro-mapred/1.7.6/avro-mapred-1.7.6-hadoop1.jar:/Users/psuryawanshi/.m2/repository/org/apache/avro/avro-ipc/1.7.6/avro-ipc-1.7.6-tests.jar:/Users/psuryawanshi/.m2/repository/org/mortbay/jetty/servlet-api/2.5-20081211/servlet-api-2.5-20081211.jar:/Users/psuryawanshi/.m2/repository/org/apache/avro/trevni-core/1.7.6/trevni-core-1.7.6.jar:/Users/psuryawanshi/.m2/repository/com/tresata/cascading-opencsv/0.2.0/cascading-opencsv-0.2.0.jar:/Users/psuryawanshi/.m2/repository/net/sf/opencsv/opencsv/2.3/opencsv-2.3.jar:/Users/psuryawanshi/.m2/repository/com/amazonaws/aws-java-sdk/1.2.0/aws-java-sdk-1.2.0.jar:/Users/psuryawanshi/.m2/repository/commons-logging/commons-logging/1.2.1-SNAPSHOT/commons-logging-1.2.1-20161017.224056-14.jar:/Users/psuryawanshi/.m2/repository/org/apache/httpcomponents/httpclient/4.5.3-SNAPSHOT/httpclient-4.5.3-20161004.193839-2.jar:/Users/psuryawanshi/.m2/repository/javax/mail/mail/1.5.0-b01/mail-1.5.0-b01.jar:/Users/psuryawanshi/.m2/repository/stax/stax-api/1.0.1/stax-api-1.0.1.jar:/Users/psuryawanshi/.m2/repository/org/apache/httpcomponents/httpcore/4.4/httpcore-4.4.jar:/Users/psuryawanshi/.m2/repository/com/univocity/univocity-parsers/2.2.2/univocity-parsers-2.2.2.jar:/Users/psuryawanshi/.m2/repository/net/java/dev/jets3t/jets3t/0.7.4/jets3t-0.7.4.jar:/Users/psuryawanshi/.m2/repository/com/jamesmurty/utils/java-xmlbuilder/0.3/java-xmlbuilder-0.3.jar:/Users/psuryawanshi/.m2/repository/org/apache/commons/commons-email/1.4/commons-email-1.4.jar:/Users/psuryawanshi/.m2/repository/com/sun/mail/javax.mail/1.5.2/javax.mail-1.5.2.jar:/Users/psuryawanshi/.m2/repository/javax/activation/activation/1.1.1/activation-1.1.1.jar:/Users/psuryawanshi/.m2/repository/io/parallec/parallec-core/0.10.1/parallec-core-0.10.1.jar:/Users/psuryawanshi/.m2/repository/com/nanohttpd/nanohttpd/2.1.1/nanohttpd-2.1.1.jar:/Users/psuryawanshi/.m2/repository/ch/qos/logback/logback-classic/1.1.3/logback-classic-1.1.3.jar:/Users/psuryawanshi/.m2/repository/ch/qos/logback/logback-core/1.1.3/logback-core-1.1.3.jar:/Users/psuryawanshi/.m2/repository/org/apache/commons/commons-lang3/3.0/commons-lang3-3.0.jar:/Users/psuryawanshi/.m2/repository/com/ning/async-http-client/1.6.5/async-http-client-1.6.5.jar:/Users/psuryawanshi/.m2/repository/org/jboss/netty/netty/3.2.5.Final/netty-3.2.5.Final.jar:/Users/psuryawanshi/.m2/repository/com/typesafe/akka/akka-actor_2.10/2.3.3/akka-actor_2.10-2.3.3.jar:/Users/psuryawanshi/.m2/repository/com/typesafe/config/1.2.1/config-1.2.1.jar:/Users/psuryawanshi/.m2/repository/com/typesafe/akka/akka-cluster_2.10/2.3.3/akka-cluster_2.10-2.3.3.jar:/Users/psuryawanshi/.m2/repository/com/typesafe/akka/akka-remote_2.10/2.3.3/akka-remote_2.10-2.3.3.jar:/Users/psuryawanshi/.m2/repository/org/uncommons/maths/uncommons-maths/1.2.2a/uncommons-maths-1.2.2a.jar:/Users/psuryawanshi/.m2/repository/org/codehaus/jettison/jettison/1.3.7/jettison-1.3.7.jar:/Users/psuryawanshi/.m2/repository/com/openpojo/openpojo/0.8.0/openpojo-0.8.0.jar:/Users/psuryawanshi/.m2/repository/com/jayway/jsonpath/json-path/2.0.0/json-path-2.0.0.jar:/Users/psuryawanshi/.m2/repository/net/minidev/json-smart/2.1.1/json-smart-2.1.1.jar:/Users/psuryawanshi/.m2/repository/net/minidev/asm/1.0.2/asm-1.0.2.jar:/Users/psuryawanshi/.m2/repository/org/asynchttpclient/async-http-client/2.0.18/async-http-client-2.0.18.jar:/Users/psuryawanshi/.m2/repository/org/asynchttpclient/async-http-client-netty-utils/2.0.18/async-http-client-netty-utils-2.0.18.jar:/Users/psuryawanshi/.m2/repository/io/netty/netty-buffer/4.0.42.Final/netty-buffer-4.0.42.Final.jar:/Users/psuryawanshi/.m2/repository/io/netty/netty-codec-http/4.0.42.Final/netty-codec-http-4.0.42.Final.jar:/Users/psuryawanshi/.m2/repository/io/netty/netty-codec/4.0.42.Final/netty-codec-4.0.42.Final.jar:/Users/psuryawanshi/.m2/repository/io/netty/netty-handler/4.0.42.Final/netty-handler-4.0.42.Final.jar:/Users/psuryawanshi/.m2/repository/io/netty/netty-transport-native-epoll/4.0.42.Final/netty-transport-native-epoll-4.0.42.Final-linux-x86_64.jar:/Users/psuryawanshi/.m2/repository/io/netty/netty-common/4.0.42.Final/netty-common-4.0.42.Final.jar:/Users/psuryawanshi/.m2/repository/io/netty/netty-transport/4.0.42.Final/netty-transport-4.0.42.Final.jar:/Users/psuryawanshi/.m2/repository/org/asynchttpclient/netty-resolver-dns/2.0.18/netty-resolver-dns-2.0.18.jar:/Users/psuryawanshi/.m2/repository/org/asynchttpclient/netty-resolver/2.0.18/netty-resolver-2.0.18.jar:/Users/psuryawanshi/.m2/repository/org/asynchttpclient/netty-codec-dns/2.0.18/netty-codec-dns-2.0.18.jar:/Users/psuryawanshi/.m2/repository/org/reactivestreams/reactive-streams/1.0.0/reactive-streams-1.0.0.jar:/Users/psuryawanshi/.m2/repository/com/typesafe/netty/netty-reactive-streams/1.0.8/netty-reactive-streams-1.0.8.jar:/Users/psuryawanshi/.m2/repository/org/javassist/javassist/3.20.0-GA/javassist-3.20.0-GA.jar:/Applications/IntelliJ IDEA.app/Contents/lib/idea_rt.jar","version":"52.0"},"endorsed":{"dirs":"/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/endorsed"},"ext":{"dirs":"/Users/psuryawanshi/Library/Java/Extensions:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/ext:/Library/Java/Extensions:/Network/Library/Java/Extensions:/System/Library/Java/Extensions:/usr/lib/java"},"home":"/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre","io":{"tmpdir":"/var/folders/hz/v1rj7jpj6t7c34m73s0vbkhh0000gp/T/"},"library":{"path":"/Users/psuryawanshi/Library/Java/Extensions:/Library/Java/Extensions:/Network/Library/Java/Extensions:/System/Library/Java/Extensions:/usr/lib/java:."},"runtime":{"name":"Java(TM) SE Runtime Environment","version":"1.8.0_101-b13"},"specification":{"name":"Java Platform API Specification","vendor":"Oracle Corporation","version":"1.8"},"vendor":{"url":{"bug":"http://bugreport.sun.com/bugreport/"}},"version":"1.8.0_101","vm":{"info":"mixed mode","name":"Java HotSpot(TM) 64-Bit Server VM","specification":{"name":"Java Virtual Machine Specification","vendor":"Oracle Corporation","version":"1.8"},"vendor":"Oracle Corporation","version":"25.101-b13"}},"line":{"separator":"\n"},"os":{"arch":"x86_64","name":"Mac OS X","version":"10.12"},"path":{"separator":":"},"sun":{"arch":{"data":{"model":"64"}},"boot":{"class":{"path":"/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/resources.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/rt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/sunrsasign.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/jsse.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/jce.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/charsets.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib/jfr.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/classes"},"library":{"path":"/Library/Java/JavaVirtualMachines/jdk1.8.0_101.jdk/Contents/Home/jre/lib"}},"cpu":{"endian":"little","isalist":""},"io":{"unicode":{"encoding":"UnicodeBig"}},"java":{"command":"com.intellij.rt.execution.application.AppMain com.homeaway.geo.HttpDiffRequestsSameServerApp","launcher":"SUN_STANDARD"},"jnu":{"encoding":"UTF-8"},"management":{"compiler":"HotSpot 64-Bit Tiered Compilers"},"nio":{"ch":{"bugLevel":""}},"os":{"patch":{"level":"unknown"}}},"user":{"country":"US","dir":"/Users/psuryawanshi/CodeBase_Destination/competitive-intel","home":"/Users/psuryawanshi","language":"en","name":"psuryawanshi","timezone":"America/Chicago"}})) Exception in thread "main" java.lang.NoSuchMethodError: scala.collection.immutable.HashSet$.empty()Lscala/collection/immutable/HashSet; at akka.actor.ActorCell$.(ActorCell.scala:336) at akka.actor.ActorCell$.(ActorCell.scala) at akka.actor.RootActorPath.$div(ActorPath.scala:159) at akka.actor.LocalActorRefProvider.(ActorRefProvider.scala:464) at akka.actor.LocalActorRefProvider.(ActorRefProvider.scala:452) at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) at java.lang.reflect.Constructor.newInstance(Constructor.java:423) at akka.actor.ReflectiveDynamicAccess$$anonfun$createInstanceFor$2.apply(DynamicAccess.scala:78) at scala.util.Try$.apply(Try.scala:191) at akka.actor.ReflectiveDynamicAccess.createInstanceFor(DynamicAccess.scala:73) at akka.actor.ReflectiveDynamicAccess$$anonfun$createInstanceFor$3.apply(DynamicAccess.scala:84) at akka.actor.ReflectiveDynamicAccess$$anonfun$createInstanceFor$3.apply(DynamicAccess.scala:84) at scala.util.Success.flatMap(Try.scala:230) at akka.actor.ReflectiveDynamicAccess.createInstanceFor(DynamicAccess.scala:84) at akka.actor.ActorSystemImpl.liftedTree1$1(ActorSystem.scala:584) at akka.actor.ActorSystemImpl.(ActorSystem.scala:577) at akka.actor.ActorSystem$.apply(ActorSystem.scala:141) at akka.actor.ActorSystem$.apply(ActorSystem.scala:118) at akka.actor.ActorSystem$.create(ActorSystem.scala:66) at akka.actor.ActorSystem.create(ActorSystem.scala) at io.parallec.core.actor.ActorConfig.(ActorConfig.java:48) at io.parallec.core.ParallelClient.initialize(ParallelClient.java:116) at io.parallec.core.ParallelClient.(ParallelClient.java:107) at com.homeaway.geo.HttpDiffRequestsSameServerApp.main(HttpDiffRequestsSameServerApp.java:47) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at com.intellij.rt.execution.application.AppMain.main(AppMain.java:147)

jeffpeiyt commented 8 years ago

@psuryawanshi thanks so much for trying Parallec

Could you please check the following and if it could help?

http://stackoverflow.com/questions/26390219/intellij-idea-java-lang-nosuchmethoderror-scala-collection-immutable-coloncol

http://stackoverflow.com/questions/27453552/nosuchmethoderror-while-running-scalatest

jeffpeiyt commented 8 years ago

Close the issue as there is no activity. Please reopen if needed