stephenh

[info] BlockManagerSuite:
[info] - master + 2 managers interaction *** FAILED ***
[info]   java.lang.IllegalArgumentException: Unable to create serializer "com.esotericsoftware.kryo.serializers.FieldSerializer" for class: scala.Tuple2$mcII$sp
[info]   at com.esotericsoftware.kryo.Kryo.newSerializer(Kryo.java:347)
[info]   at com.esotericsoftware.kryo.Kryo.newDefaultSerializer(Kryo.java:326)
[info]   at com.esotericsoftware.kryo.Kryo.getDefaultSerializer(Kryo.java:319)
[info]   at de.javakaffee.kryoserializers.KryoReflectionFactorySupport.getDefaultSerializer(KryoReflectionFactorySupport.java:45)
[info]   at com.esotericsoftware.kryo.Kryo.register(Kryo.java:363)
[info]   at spark.KryoSerializer$$anonfun$createKryo$1.apply(KryoSerializer.scala:140)
[info]   at spark.KryoSerializer$$anonfun$createKryo$1.apply(KryoSerializer.scala:139)

stephenh

object foo {
  var comparisons = 0                             //> comparisons  : Int = 0
  class Foo {
    override def equals(other: Any) = { comparisons += 1; super.equals(other) }
  }
  class Bar extends Foo
  class Baz extends Foo
  val s1: Set[Foo] = Seq.fill(10)(new Bar).toSet  //> s1  : Set[foo.Foo] = Set(foo$$anonfun$main$1$Bar$1@1529d183, foo$$anonfun$ma
                                                  //| in$1$Bar$1@7d1f0c98, foo$$anonfun$main$1$Bar$1@1740f55, foo$$anonfun$main$1$
                                                  //| Bar$1@c8a3c71, foo$$anonfun$main$1$Bar$1@6a9a9631, foo$$anonfun$main$1$Bar$1

stephenh

SLF4J: This version of SLF4J requires log4j version 1.2.12 or later. See also http://www.slf4j.org/codes.html#log4j_version
13/03/26 20:19:54 INFO slf4j.Slf4jEventHandler: Slf4jEventHandler started
13/03/26 20:19:54 INFO actor.ActorSystemImpl: RemoteServerStarted@akka://[email protected]:52400
13/03/26 20:19:54 INFO spark.SparkEnv: Registering BlockManagerMaster
13/03/26 20:19:54 INFO storage.MemoryStore: MemoryStore started with capacity 323.9 MB.
13/03/26 20:19:54 INFO storage.DiskStore: Created local directory at /mnt/spark/local/spark-local-20130326201954-696e
13/03/26 20:19:55 INFO network.ConnectionManager: Bound socket to port 41101 with id = ConnectionManagerId(ip-10-224-6-227.ec2.internal,41101)
13/03/26 20:19:55 INFO storage.BlockManagerMaster: Trying to register BlockManager
13/03/26 20:19:55 INFO storage.BlockManagerMaster: Registered BlockManager
13/03/26 20:19:55 INFO server.Server: jetty-7.5.3.v20111011

stephenh

    public synchronized int read() throws IOException {
      int result = in.read();
      if (result != -1) {
        pos++;
      }
      return result;
    }

stephenh

13/08/24 14:38:52 INFO cluster.TaskSetManager: Loss was due to java.lang.IllegalStateException: Shutdown in progress 
    at java.lang.ApplicationShutdownHooks.add(ApplicationShutdownHooks.java:66) 
    at java.lang.Runtime.addShutdownHook(Runtime.java:211) 
    at org.apache.hadoop.fs.FileSystem$Cache.get(FileSystem.java:1441) 
    at org.apache.hadoop.fs.FileSystem.get(FileSystem.java:256) 
    at org.apache.hadoop.fs.Path.getFileSystem(Path.java:187) 
    at org.apache.hadoop.mapred.LineRecordReader.<init>(LineRecordReader.java:77) 
    at org.apache.hadoop.mapred.TextInputFormat.getRecordReader(TextInputFormat.java:51) 
    at spark.rdd.HadoopRDD$$anon$1.<init>(HadoopRDD.scala:79) 
    at spark.rdd.HadoopRDD.compute(HadoopRDD.scala:70) 

stephenh

package temp;

import java.math.BigDecimal;
import java.math.BigInteger;

public class Test {
  public static void main(String[] args) {
    System.out.println(toSeventeenDigits(1000));
    System.out.println(toSeventeenDigits(100));
    System.out.println(toSeventeenDigits(10));

stephenh

// with 2.6.0

function com_google_gwt_dom_client_StyleInjector_StyleInjectorImpl(){
  switch (permutationId) {
    case 0:
    case 4:
      return new StyleInjector$StyleInjectorImpl_0;
  }
  return new StyleInjector$StyleInjectorImplIE_0;
}

stephenh

import scala.collection.mutable.Buffer

/**
 * An object into a process under to test to, at test time, purposefully cause it to fail.
 *
 * A typical usage might be:
 * 
 * class SomeProcess(..., testBaton = NoopBaton() {
 *   def run() {
 *     val items = findSomeWorkItems()

stephenh

 @external *;

.fa {}
.fa-2x {}
.fa-3x {}
.fa-4x {}
.fa-5x {}
.fa-adjust {}
.fa-adn {}
.fa-align-center {}

stephenh

and here is the same request from 208.43.121.200 (and it fails validation because request chain is terminated with content-type  text/html ):

curl -i -c poker_cookies.txt -L -H'User-Agent: Mozilla/4.0 (compatible; MSIE 8.0; Windows NT 6.0; Trident/4.0; SLCC1; .NET CLR 2.0.50727; .NET CLR 3.5.30729; OfficeLiveConnector.1.3; OfficeLivePatch.0.0; .NET CLR 3.0.30729)' 'http://api.bizographics.com/v2/getuid?api_key=3d2e5d0fe63241629dab1e775752758a&redirect_url=http%3A%2F%2Ftags.bluekai.com%2Fsite%2F23060%3Fid%3D%24UID%26kid%3D0'
HTTP/1.1 302 Found
Date: Thu, 09 Jul 2015 01:02:31 GMT
Location: http://api.bizographics.com/v2/getuid?api_key=3d2e5d0fe63241629dab1e775752758a&redirect_url=http%3A%2F%2Ftags.bluekai.com%2Fsite%2F23060%3Fid%3D%24UID%26kid%3D0&3pc=true
Server: nginx
Set-Cookie: BizoID=9993950c-83c6-4b58-bf74-b7315e663a2f; Domain=.bizographics.com; Expires=Thu, 07-Jan-2016 13:02:31 GMT; Path=/
Content-Length: 0
Connection: keep-alive