livy-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Alex Rodrigues <arodrig...@actificent.com>
Subject Session becomes in weird state
Date Thu, 21 Sep 2017 20:35:27 GMT
Hi Livyers,

I'm hitting a rather odd error. After sending a few bursts of requests to
Livy,

I get this error:

[image: Inline image 1]


    {
            "code": "queryExecutor.printResults(job1506025111065, 20
milliseconds)",
            "id": 22,
            "output": {
                "ename": "Internal Error: java.lang.AssertionError",
                "evalue": "assertion failed: parser: AnyRef {\n  def
<init>(): LowPriorityImplicits\n  implicit def byteWrapper(x: Byte):
scala.runtime.RichByte\n  implicit def shortWrapper(x: Short):
scala.runtime.RichShort\n  implicit def intWrapper(x: Int):
scala.runtime.RichInt\n  implicit def charWrapper(c: Char):
scala.runtime.RichChar\n  implicit def longWrapper(x: Long):
scala.runtime.RichLong\n  implicit def floatWrapper(x: Float):
scala.runtime.RichFloat\n  implicit def doubleWrapper(x: Double):
scala.runtime.RichDouble\n  implicit def booleanWrapper(x: Boolean):
scala.runtime.RichBoolean\n  implicit def genericWrapArray[T](xs:
Array[T]): scala.collection.mutable.WrappedArray[T]\n  implicit def
wrapRefArray[T <: Object](xs: Array[T]):
scala.collection.mutable.WrappedArray[T]\n  implicit def wrapIntArray(xs:
Array[Int]): scala.collection.mutable.WrappedArray[Int]\n  implicit def
wrapDoubleArray(xs: Array[Double]):
scala.collection.mutable.WrappedArray[Double]\n  implicit def
wrapLongArray(xs: Array[Long]):
scala.collection.mutable.WrappedArray[Long]\n  implicit def
wrapFloatArray(xs: Array[Float]):
scala.collection.mutable.WrappedArray[Float]\n  implicit def
wrapCharArray(xs: Array[Char]):
scala.collection.mutable.WrappedArray[Char]\n  implicit def
wrapByteArray(xs: Array[Byte]):
scala.collection.mutable.WrappedArray[Byte]\n  implicit def
wrapShortArray(xs: Array[Short]):
scala.collection.mutable.WrappedArray[Short]\n  implicit def
wrapBooleanArray(xs: Array[Boolean]):
scala.collection.mutable.WrappedArray[Boolean]\n  implicit def
wrapUnitArray(xs: Array[Unit]):
scala.collection.mutable.WrappedArray[Unit]\n  implicit def wrapString(s:
String): scala.collection.immutable.WrappedString\n  implicit def
unwrapString(ws: scala.collection.immutable.WrappedString): String\n
 implicit def fallbackStringCanBuildFrom[T]():
scala.collection.generic.CanBuildFrom[String,T,scala.collection.immutable.IndexedSeq[T]]\n},
tailcalls: Object {\n  def <init>(): LowPriorityImplicits\n  implicit def
byteWrapper(x: Byte): scala.runtime.RichByte\n  implicit def
shortWrapper(x: Short): scala.runtime.RichShort\n  implicit def
intWrapper(x: Int): scala.runtime.RichInt\n  implicit def charWrapper(c:
Char): scala.runtime.RichChar\n  implicit def longWrapper(x: Long):
scala.runtime.RichLong\n  implicit def floatWrapper(x: Float):
scala.runtime.RichFloat\n  implicit def doubleWrapper(x: Double):
scala.runtime.RichDouble\n  implicit def booleanWrapper(x: Boolean):
scala.runtime.RichBoolean\n  implicit def genericWrapArray[T](xs:
Array[T]): scala.collection.mutable.WrappedArray[T]\n  implicit def
wrapRefArray[T <: Object](xs: Array[T]):
scala.collection.mutable.WrappedArray[T]\n  implicit def wrapIntArray(xs:
Array[Int]): scala.collection.mutable.WrappedArray[Int]\n  implicit def
wrapDoubleArray(xs: Array[Double]):
scala.collection.mutable.WrappedArray[Double]\n  implicit def
wrapLongArray(xs: Array[Long]):
scala.collection.mutable.WrappedArray[Long]\n  implicit def
wrapFloatArray(xs: Array[Float]):
scala.collection.mutable.WrappedArray[Float]\n  implicit def
wrapCharArray(xs: Array[Char]):
scala.collection.mutable.WrappedArray[Char]\n  implicit def
wrapByteArray(xs: Array[Byte]):
scala.collection.mutable.WrappedArray[Byte]\n  implicit def
wrapShortArray(xs: Array[Short]):
scala.collection.mutable.WrappedArray[Short]\n  implicit def
wrapBooleanArray(xs: Array[Boolean]):
scala.collection.mutable.WrappedArray[Boolean]\n  implicit def
wrapUnitArray(xs: Array[Unit]):
scala.collection.mutable.WrappedArray[Unit]\n  implicit def wrapString(s:
String): scala.collection.immutable.WrappedString\n  implicit def
unwrapString(ws: scala.collection.immutable.WrappedString): String\n
 implicit def fallbackStringCanBuildFrom[T]():
scala.collection.generic.CanBuildFrom[String,T,scala.collection.immutable.IndexedSeq[T]]\n},
repl: Object {\n  def <init>(): LowPriorityImplicits\n  implicit def
byteWrapper(x: Byte): scala.runtime.RichByte\n  implicit def
shortWrapper(x: Short): scala.runtime.RichShort\n  implicit def
intWrapper(x: Int): scala.runtime.RichInt\n  implicit def charWrapper(c:
Char): scala.runtime.RichChar\n  implicit def longWrapper(x: Long):
scala.runtime.RichLong\n  implicit def floatWrapper(x: Float):
scala.runtime.RichFloat\n  implicit def doubleWrapper(x: Double):
scala.runtime.RichDouble\n  implicit def booleanWrapper(x: Boolean):
scala.runtime.RichBoolean\n  implicit def genericWrapArray[T](xs:
Array[T]): scala.collection.mutable.WrappedArray[T]\n  implicit def
wrapRefArray[T <: Object](xs: Array[T]):
scala.collection.mutable.WrappedArray[T]\n  implicit def wrapIntArray(xs:
Array[Int]): scala.collection.mutable.WrappedArray[Int]\n  implicit def
wrapDoubleArray(xs: Array[Double]):
scala.collection.mutable.WrappedArray[Double]\n  implicit def
wrapLongArray(xs: Array[Long]):
scala.collection.mutable.WrappedArray[Long]\n  implicit def
wrapFloatArray(xs: Array[Float]):
scala.collection.mutable.WrappedArray[Float]\n  implicit def
wrapCharArray(xs: Array[Char]):
scala.collection.mutable.WrappedArray[Char]\n  implicit def
wrapByteArray(xs: Array[Byte]):
scala.collection.mutable.WrappedArray[Byte]\n  implicit def
wrapShortArray(xs: Array[Short]):
scala.collection.mutable.WrappedArray[Short]\n  implicit def
wrapBooleanArray(xs: Array[Boolean]):
scala.collection.mutable.WrappedArray[Boolean]\n  implicit def
wrapUnitArray(xs: Array[Unit]):
scala.collection.mutable.WrappedArray[Unit]\n  implicit def wrapString(s:
String): scala.collection.immutable.WrappedString\n  implicit def
unwrapString(ws: scala.collection.immutable.WrappedString): String\n
 implicit def fallbackStringCanBuildFrom[T]():
scala.collection.generic.CanBuildFrom[String,T,scala.collection.immutable.IndexedSeq[T]]\n}",
                "execution_count": 22,
                "status": "error",
                "traceback": []
            },
            "progress": 1.0,
            "state": "available"
        },

After that, it seems that all statements I send become internal errors:

        {
            "code": "2+2",
            "id": 23,
            "output": {
                "ename": "Internal Error: java.lang.AssertionError",
                "evalue": "assertion failed: (15,13)",
                "execution_count": 23,
                "status": "error",
                "traceback": []
            },
            "progress": 1.0,
            "state": "available"
        },


Any hints?

The code "queryExecutor.printResults(job1506025111065, 20 milliseconds)"
that seems to have put the session in the weird state has executed multiple
times successfully. It accepts a Future (job....) and runs a
Await.result(future, duration).



Thanks in advance

Mime
View raw message