stephenh

package com.bizo.usermgmt.webtest;

import java.io.File;
import java.io.IOException;

import org.apache.commons.io.FileUtils;
import org.openqa.selenium.*;
import org.openqa.selenium.firefox.FirefoxBinary;
import org.openqa.selenium.firefox.FirefoxDriver;
import org.openqa.selenium.firefox.FirefoxProfile;

stephenh

package com.bizo.usermgmt.webtest;

import java.io.File;

import org.openqa.selenium.By;
import org.openqa.selenium.Keys;
import org.openqa.selenium.WebDriver;
import org.openqa.selenium.WebElement;
import org.openqa.selenium.firefox.FirefoxBinary;
import org.openqa.selenium.firefox.FirefoxDriver;

stephenh

"pool-6-thread-1" prio=10 tid=0x00007ff46072d800 nid=0x41e2 waiting on condition [0x00007ff450737000]
   java.lang.Thread.State: WAITING (parking)
  at sun.misc.Unsafe.park(Native Method)
  - parking to wait for  <0x00000000fa78eda8> (a java.util.concurrent.CountDownLatch$Sync)
  at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
  at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronize
  at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedInterruptibly(AbstractQueuedSync
  at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireSharedInterruptibly(AbstractQueuedSynchr
  at java.util.concurrent.CountDownLatch.await(CountDownLatch.java:236)
  at akka.actor.ActorSystemImpl$TerminationCallbacks.ready(ActorSystem.scala:736)

stephenh

13/02/01 11:30:33.219 INFO StandaloneExecutorBackend: Connecting to driver: akka://[email protected]:32781/user/StandaloneScheduler
13/02/01 11:30:33.220 ERROR StandaloneExecutorBackend: Monitored actor [Actor[akka://[email protected]:32781/user/StandaloneScheduler]] terminated
akka.actor.DeathPactException:Monitored actor [Actor[akka://[email protected]:32781/user/StandaloneScheduler]] terminated

stephenh

> ./sbt/sbt test-only spark.DistributedSuite
Listening for transport dt_socket at address: 5005
[info] Loading project definition from /home/stephen/other/spark/project/project
[info] Loading project definition from /home/stephen/other/spark/project
[info] Set current project to root (in build file:/home/stephen/other/spark/)
[INFO] [02/01/2013 16:09:52.354] [spark-akka.actor.default-dispatcher-2] [ActorSystem(spark)] RemoteServerShutdown@akka://[email protected]:57697
[INFO] [02/01/2013 16:09:52.617] [spark-akka.actor.default-dispatcher-4] [ActorSystem(spark)] RemoteServerShutdown@akka://[email protected]:52063
[INFO] [02/01/2013 16:09:52.853] [spark-akka.actor.default-dispatcher-1] [ActorSystem(spark)] RemoteServerShutdown@akka://[email protected]:50396
[INFO] [02/01/2013 16:09:53.72] [spark-akka.actor.default-dispatcher-3] [ActorSystem(spark)] RemoteServerShutdown@akka://[email protected]:56448
[INFO] [02/01/2013 16:09:53.284] [spark-akka.actor.default-dispatcher-1] [ActorSystem(spark)] RemoteServe

stephenh

Listening for transport dt_socket at address: 5005
[info] Loading project definition from /home/stephen/other/spark/project/project
[info] Loading project definition from /home/stephen/other/spark/project
[info] Set current project to root (in build file:/home/stephen/other/spark/)
[INFO] [02/01/2013 16:23:07.149] [spray-io-worker-2] [IoWorker] IoWorker thread 'spray-io-worker-2' stopped
[INFO] [02/01/2013 16:23:07.152] [spray-io-worker-1] [IoWorker] IoWorker thread 'spray-io-worker-1' stopped
[INFO] [02/01/2013 16:23:07.156] [spray-io-worker-0] [IoWorker] IoWorker thread 'spray-io-worker-0' stopped
[INFO] [02/01/2013 16:23:07.158] [spark-akka.actor.default-dispatcher-5] [ActorSystem(spark)] RemoteClientShutdown@akka://[email protected]:53127
[INFO] [02/01/2013 16:23:07.158] [spark-akka.actor.default-dispatcher-1] [ActorSystem(spark)] RemoteClientShutdown@akka://[email protected]:53127
[INFO] [02/01/2013 16:23:07.161] [spark-3] [ActorSystem(spark

stephenh

./sbt/sbt "test-only spark.DistributedSuite" > distributed.txt 2>&1

stephenh

13/02/27 03:33:18 INFO cluster.TaskSetManager: Loss was due to java.io.EOFException
	at spark.KryoDeserializationStream.readObject(KryoSerializer.scala:44)
	at spark.broadcast.HttpBroadcast$.read(HttpBroadcast.scala:129)
	at spark.broadcast.HttpBroadcast.readObject(HttpBroadcast.scala:40)
	at sun.reflect.GeneratedMethodAccessor5.invoke(Unknown Source)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at java.io.ObjectStreamClass.invokeReadObject(ObjectStreamClass.java:974)
	at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1848)
	at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1752)

stephenh

import scala.collection.JavaConversions._
import java.util.Collections
import spark.KryoSerializer
import de.javakaffee.kryoserializers.KryoReflectionFactorySupport
import com.esotericsoftware.kryo.io.Output
import com.esotericsoftware.kryo.io.Input

object Testing {
  def main(args: Array[String]): Unit = {
    val list = new java.util.ArrayList[String]()

stephenh

Exception in thread "main" java.lang.IncompatibleClassChangeError: Implementing class
  at java.lang.ClassLoader.defineClass1(Native Method)
  at java.lang.ClassLoader.defineClassCond(ClassLoader.java:631)
  at java.lang.ClassLoader.defineClass(ClassLoader.java:615)
  at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:141)
  at java.net.URLClassLoader.defineClass(URLClassLoader.java:283)
  at java.net.URLClassLoader.access$000(URLClassLoader.java:58)
  at java.net.URLClassLoader$1.run(URLClassLoader.java:197)
  at java.security.AccessController.doPrivileged(Native Method)
  at java.net.URLClassLoader.findClass(URLClassLoader.java:190)