Created
August 25, 2017 08:25
-
-
Save jeesim2/efb52f12d6cd4c1b255fd0c917411370 to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
%spark | |
import java.io.File | |
import org.apache.spark.{SparkConf, SparkContext} | |
import org.apache.spark.sql.functions._ | |
import org.apache.spark.sql._ | |
import org.apache.spark.sql.hive.HiveContext | |
import org.apache.spark.mllib.linalg.Vectors | |
import org.apache.spark.mllib.linalg.Vector | |
import scala.collection.mutable.WrappedArray | |
import org.apache.spark.sql.expressions.Window | |
import org.apache.spark.sql.functions._ | |
import org.apache.spark.sql.types.TimestampType | |
import org.apache.spark.sql.functions.{concat, lit} | |
import org.elasticsearch.spark.sql._ | |
import org.apache.spark.SparkConf | |
import org.apache.spark._ | |
import org.apache.spark.SparkContext._ | |
import org.apache.spark.sql.types.IntegerType | |
val sparkConf = new SparkConf().setAppName("HiveFromSpark").set("spark.driver.allowMultipleContexts","true") | |
val sc = new SparkContext(sparkConf) | |
val hive = new org.apache.spark.sql.hive.HiveContext(sc) | |
///////////// UDFS | |
def toDoubleArrayFun(vec:Any) : scala.Array[Double] = { | |
return vec.asInstanceOf[WrappedArray[Double]].toArray | |
} | |
def toDoubleArray=udf((vec:Any) => toDoubleArrayFun(vec)) | |
//////////// PROCESS | |
var df = hive.sql("select vec from mst_wordvector_tapi_128dim where word='축구'") | |
println("==== test get value then transform") | |
println(df.head().get(0)) | |
println(toDoubleArrayFun(df.head().get(0))) | |
println("==== test transform by udf") | |
df.withColumn("word_v", toDoubleArray(col("vec"))) | |
.show(10); | |
///////////// OUTPUT | |
import java.io.File | |
import org.apache.spark.{SparkConf, SparkContext} | |
import org.apache.spark.sql.functions._ | |
import org.apache.spark.sql._ | |
import org.apache.spark.sql.hive.HiveContext | |
import org.apache.spark.mllib.linalg.Vectors | |
import org.apache.spark.mllib.linalg.Vector | |
import scala.collection.mutable.WrappedArray | |
import org.apache.spark.sql.expressions.Window | |
import org.apache.spark.sql.functions._ | |
import org.apache.spark.sql.types.TimestampType | |
import org.apache.spark.sql.functions.{concat, lit} | |
import org.elasticsearch.spark.sql._ | |
import org.apache.spark.SparkConf | |
import org.apache.spark._ | |
import org.apache.spark.SparkContext._ | |
import org.apache.spark.sql.types.IntegerType | |
sparkConf: org.apache.spark.SparkConf = org.apache.spark.SparkConf@59e5c9e5 | |
spark.yarn.driver.memoryOverhead is set but does not apply in client mode. | |
spark.driver.cores is set but does not apply in client mode. | |
sc: org.apache.spark.SparkContext = org.apache.spark.SparkContext@6e9484ad | |
hive: org.apache.spark.sql.hive.HiveContext = org.apache.spark.sql.hive.HiveContext@285cfb70 | |
toDoubleArrayFun: (vec: Any)Array[Double] | |
toDoubleArray: org.apache.spark.sql.UserDefinedFunction | |
df: org.apache.spark.sql.DataFrame = [vec: array<double>] | |
==== test get value then transform | |
WrappedArray(-0.88675, 0.192395, 0.550291, 0.0866308, -0.156407, 0.768545, -1.0259, -0.498562, -0.786566, 0.0177031, -0.269489, 1.49483, 0.00962146, 0.133342, -0.39825, 2.09301, 0.394862, 0.794089, 0.864039, 0.464775, -1.49571, 0.882516, 0.0456218, -0.0420346, -0.792837, 0.623938, 0.806078, -0.285054, 0.229021, 1.10352, -1.32154, 1.13582, 0.186694, -0.149243, 0.0576537, 1.38572, -0.129053, -1.48695, 0.944584, 0.303393, 1.32083, 0.298781, -0.255202, -0.341888, -0.385325, 0.832063, -0.437644, 0.595798, 1.00888, -0.453279, -0.432543, 0.51471, -0.77004, -0.0501599, -0.14097, -0.756373, -0.55234, -0.5336, -0.22405, 0.169302, -0.836179, 1.73104, -0.525839, 0.536459, 0.721927, -0.509973, 0.429644, 0.584154, -0.386394, -0.55287, -0.298126, -0.41801, 0.540932, 0.39985, 1.15184, 1.1327, -1.99555, 0.357264, -0.417249, 0.315966, -0.955217, 0.290192, 0.0588666, -0.436262, -0.826908, 0.458694, 0.122786, -0.330842, 0.427237, 0.590247, -0.523079, 0.104329, 1.59748, -0.361678, -0.716198, 0.0168899, -0.291957, -0.604991, -1.15653, 0.149166, 0.527366, -1.32951, -0.076306, -0.189854, 0.554494, 0.591894, 1.06329, 0.331706, 1.17316, 0.579613, -0.309746, 0.444965, 0.925952, -0.500562, 1.51997, 1.19666, 1.48261, 0.655993, 0.851923, -1.28164, -0.00153659, 0.857241, 0.908664, 0.885073, -0.545786, 0.441418, 0.0586106, 0.0216657) | |
[D@4afcc447 | |
==== test transform by udf | |
org.apache.spark.SparkException: Job aborted due to stage failure: Task 0 in stage 2.0 failed 4 times, most recent failure: Lost task 0.3 in stage 2.0 (TID 5, xdad008.band.nhnsystem.com): java.lang.ClassNotFoundException: $iwC$$iwC$$iwC$$iwC$$iwC$$$$5ba2a895f25683dd48fe725fd825a71$$$$$$iwC$$anonfun$toDoubleArray$1 | |
at java.net.URLClassLoader.findClass(URLClassLoader.java:381) | |
at java.lang.ClassLoader.loadClass(ClassLoader.java:424) | |
at java.lang.ClassLoader.loadClass(ClassLoader.java:357) | |
at java.lang.Class.forName0(Native Method) | |
at java.lang.Class.forName(Class.java:348) | |
at org.apache.spark.serializer.JavaDeserializationStream$$anon$1.resolveClass(JavaSerializer.scala:68) | |
at java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:1613) | |
at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1518) | |
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1774) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) | |
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000) | |
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924) | |
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) | |
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000) | |
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924) | |
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) | |
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000) | |
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924) | |
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) | |
at java.io.ObjectInputStream.readArray(ObjectInputStream.java:1707) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1345) | |
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000) | |
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924) | |
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) | |
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000) | |
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924) | |
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) | |
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000) | |
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924) | |
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) | |
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000) | |
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924) | |
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) | |
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000) | |
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924) | |
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) | |
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000) | |
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924) | |
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) | |
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000) | |
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924) | |
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) | |
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:371) | |
at scala.collection.immutable.$colon$colon.readObject(List.scala:362) | |
at sun.reflect.GeneratedMethodAccessor3.invoke(Unknown Source) | |
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) | |
at java.lang.reflect.Method.invoke(Method.java:497) | |
at java.io.ObjectStreamClass.invokeReadObject(ObjectStreamClass.java:1017) | |
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1900) | |
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) | |
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000) | |
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924) | |
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) | |
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000) | |
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924) | |
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) | |
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:371) | |
at scala.collection.immutable.$colon$colon.readObject(List.scala:362) | |
at sun.reflect.GeneratedMethodAccessor3.invoke(Unknown Source) | |
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) | |
at java.lang.reflect.Method.invoke(Method.java:497) | |
at java.io.ObjectStreamClass.invokeReadObject(ObjectStreamClass.java:1017) | |
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1900) | |
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) | |
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000) | |
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924) | |
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) | |
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000) | |
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924) | |
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) | |
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:371) | |
at org.apache.spark.serializer.JavaDeserializationStream.readObject(JavaSerializer.scala:76) | |
at org.apache.spark.serializer.JavaSerializerInstance.deserialize(JavaSerializer.scala:115) | |
at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:61) | |
at org.apache.spark.scheduler.Task.run(Task.scala:89) | |
at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:227) | |
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) | |
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) | |
at java.lang.Thread.run(Thread.java:745) | |
Driver stacktrace: | |
at org.apache.spark.scheduler.DAGScheduler.org$apache$spark$scheduler$DAGScheduler$$failJobAndIndependentStages(DAGScheduler.scala:1433) | |
at org.apache.spark.scheduler.DAGScheduler$$anonfun$abortStage$1.apply(DAGScheduler.scala:1421) | |
at org.apache.spark.scheduler.DAGScheduler$$anonfun$abortStage$1.apply(DAGScheduler.scala:1420) | |
at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59) | |
at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47) | |
at org.apache.spark.scheduler.DAGScheduler.abortStage(DAGScheduler.scala:1420) | |
at org.apache.spark.scheduler.DAGScheduler$$anonfun$handleTaskSetFailed$1.apply(DAGScheduler.scala:801) | |
at org.apache.spark.scheduler.DAGScheduler$$anonfun$handleTaskSetFailed$1.apply(DAGScheduler.scala:801) | |
at scala.Option.foreach(Option.scala:236) | |
at org.apache.spark.scheduler.DAGScheduler.handleTaskSetFailed(DAGSch | |
eduler.scala:801) | |
at org.apache.spark.scheduler.DAGSchedulerEventProcessLoop.doOnReceive(DAGScheduler.scala:1642) | |
at org.apache.spark.scheduler.DAGSchedulerEventProcessLoop.onReceive(DAGScheduler.scala:1601) | |
at org.apache.spark.scheduler.DAGSchedulerEventProcessLoop.onReceive(DAGScheduler.scala:1590) | |
at org.apache.spark.util.EventLoop$$anon$1.run(EventLoop.scala:48) | |
at org.apache.spark.scheduler.DAGScheduler.runJob(DAGScheduler.scala:622) | |
at org.apache.spark.SparkContext.runJob(SparkContext.scala:1856) | |
at org.apache.spark.SparkContext.runJob(SparkContext.scala:1869) | |
at org.apache.spark.SparkContext.runJob(SparkContext.scala:1882) | |
at org.apache.spark.sql.execution.SparkPlan.executeTake(SparkPlan.scala:212) | |
at org.apache.spark.sql.execution.Limit.executeCollect(basicOperators.scala:165) | |
at org.apache.spark.sql.execution.SparkPlan.executeCollectPublic(SparkPlan.scala:174) | |
at org.apache.spark.sql.DataFrame$$anonfun$org$apache$spark$sql$DataFrame$$execute$1$1.apply(DataFrame.scala:1499) | |
at org.apache.spark.sql.DataFrame$$anonfun$org$apache$spark$sql$DataFrame$$execute$1$1.apply(DataFrame.scala:1499) | |
at org.apache.spark.sql.execution.SQLExecution$.withNewExecutionId(SQLExecution.scala:56) | |
at org.apache.spark.sql.DataFrame.withNewExecutionId(DataFrame.scala:2086) | |
at org.apache.spark.sql.DataFrame.org$apache$spark$sql$DataFrame$$execute$1(DataFrame.scala:1498) | |
at org.apache.spark.sql.DataFrame.org$apache$spark$sql$DataFrame$$collect(DataFrame.scala:1505) | |
at org.apache.spark.sql.DataFrame$$anonfun$head$1.apply(DataFrame.scala:1375) | |
at org.apache.spark.sql.DataFrame$$anonfun$head$1.apply(DataFrame.scala:1374) | |
at org.apache.spark.sql.DataFrame.withCallback(DataFrame.scala:2099) | |
at org.apache.spark.sql.DataFrame.head(DataFrame.scala:1374) | |
at org.apache.spark.sql.DataFrame.take(DataFrame.scala:1456) | |
at org.apache.spark.sql.DataFrame.showString(DataFrame.scala:170) | |
at org.apache.spark.sql.DataFrame.show(DataFrame.scala:350) | |
at org.apache.spark.sql.DataFrame.show(DataFrame.scala:311) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$bec1ee5c9e2e4d5af247761bdfbc3b3$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:175) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$bec1ee5c9e2e4d5af247761bdfbc3b3$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:196) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$bec1ee5c9e2e4d5af247761bdfbc3b3$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:198) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$bec1ee5c9e2e4d5af247761bdfbc3b3$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:200) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$bec1ee5c9e2e4d5af247761bdfbc3b3$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:202) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$5acc5a6ce0af8ab20753597dcc84fc0$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:204) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$5acc5a6ce0af8ab20753597dcc84fc0$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:206) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$5acc5a6ce0af8ab20753597dcc84fc0$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:208) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$5acc5a6ce0af8ab20753597dcc84fc0$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:210) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$5acc5a6ce0af8ab20753597dcc84fc0$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:212) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$33d793dde4292884a4720419646f1$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:214) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$33d793dde4292884a4720419646f1$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:216) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$33d793dde4292884a4720419646f1$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:218) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$33d793dde4292884a4720419646f1$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:220) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$33d793dde4292884a4720419646f1$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:222) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$33d793dde4292884a4720419646f1$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:224) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$725d9ae18728ec9520b65ad133e3b55$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:226) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$725d9ae18728ec9520b65ad133e3b55$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:228) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$725d9ae18728ec9520b65ad133e3b55$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:230) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$725d9ae18728ec9520b65ad133e3b55$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:232) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$725d9ae18728ec9520b65ad133e3b55$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:234) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$3d99ae6e19b65c7f617b22f29b431fb$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:236) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$3d99ae6e19b65c7f617b22f29b431fb$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:238) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$3d99ae6e19b65c7f617b22f29b431fb$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:240) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$3d99ae6e19b65c7f617b22f29b431fb$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:242) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$3d99ae6e19b65c7f617b22f29b431fb$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:244) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$ad149dbdbd963d0c9dc9b1d6f07f5e$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:246) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$ad149dbdbd963d0c9dc9b1d6f07f5e$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:248) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$ad149dbdbd963d0c9dc9b1d6f07f5e$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:250) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$ad149dbdbd963d0c9dc9b1d6f07f5e$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:252) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$ad149dbdbd963d0c9dc9b1d6f07f5e$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:254) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$6e49527b15a75f3b188beeb1837a4f1$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:256) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$6e49527b15a75f3b188beeb1837a4f1$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:258) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$6e49527b15a75f3b188beeb1837a4f1$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:260) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$6e49527b15a75f3b188beeb1837a4f1$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:262) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$6e49527b15a75f3b188beeb1837a4f1$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:264) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$93297bcd59dca476dd569cf51abed168$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:266) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$93297bcd59dca476dd569cf51abed168$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:268) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$93297bcd59dca476dd569cf51abed168$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:270) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$93297bcd59dca476dd569cf51abed168$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:272) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$$$93297bcd59dca476dd569cf51abed168$$$$$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:274) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:276) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:278) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:280) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:282) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:284) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:286) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$ | |
$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:288) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:290) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:292) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:294) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:296) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:298) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:300) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:302) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:304) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:306) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:308) | |
at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:310) | |
at $iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:312) | |
at $iwC$$iwC$$iwC$$iwC.<init>(<console>:314) | |
at $iwC$$iwC$$iwC.<init>(<console>:316) | |
at $iwC$$iwC.<init>(<console>:318) | |
at $iwC.<init>(<console>:320) | |
at <init>(<console>:322) | |
at .<init>(<console>:326) | |
at .<clinit>(<console>) | |
at .<init>(<console>:7) | |
at .<clinit>(<console>) | |
at $print(<console>) | |
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:497) | |
at org.apache.spark.repl.SparkIMain$ReadEvalPrint.call(SparkIMain.scala:1065) | |
at org.apache.spark.repl.SparkIMain$Request.loadAndRun(SparkIMain.scala:1346) | |
at org.apache.spark.repl.SparkIMain.loadAndRunReq$1(SparkIMain.scala:840) | |
at org.apache.spark.repl.SparkIMain.interpret(SparkIMain.scala:871) | |
at org.apache.spark.repl.SparkIMain.interpret(SparkIMain.scala:819) | |
at sun.reflect.GeneratedMethodAccessor15.invoke(Unknown Source) | |
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) | |
at java.lang.reflect.Method.invoke(Method.java:497) | |
at org.apache.zeppelin.spark.Utils.invokeMethod(Utils.java:38) | |
at org.apache.zeppelin.spark.SparkInterpreter.interpret(SparkInterpreter.java:953) | |
at org.apache.zeppelin.spark.SparkInterpreter.interpretInput(SparkInterpreter.java:1168) | |
at org.apache.zeppelin.spark.SparkInterpreter.interpret(SparkInterpreter.java:1111) | |
at org.apache.zeppelin.spark.SparkInterpreter.interpret(SparkInterpreter.java:1104) | |
at org.apache.zeppelin.interpreter.LazyOpenInterpreter.interpret(LazyOpenInterpreter.java:94) | |
at org.apache.zeppelin.interpreter.remote.RemoteInterpreterServer$InterpretJob.jobRun(RemoteInterpreterServer.java:341) | |
at org.apache.zeppelin.scheduler.Job.run(Job.java:176) | |
at org.apache.zeppelin.scheduler.FIFOScheduler$1.run(FIFOScheduler.java:139) | |
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) | |
at java.util.concurrent.FutureTask.run(FutureTask.java:266) | |
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180) | |
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) | |
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) | |
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) | |
at java.lang.Thread.run(Thread.java:745) | |
Caused by: java.lang.ClassNotFoundException: $iwC$$iwC$$iwC$$iwC$$iwC$$$$5ba2a895f25683dd48fe725fd825a71$$$$$$iwC$$anonfun$toDoubleArray$1 | |
at java.net.URLClassLoader.findClass(URLClassLoader.java:381) | |
at java.lang.ClassLoader.loadClass(ClassLoader.java:424) | |
at java.lang.ClassLoader.loadClass(ClassLoader.java:357) | |
at java.lang.Class.forName0(Native Method) | |
at java.lang.Class.forName(Class.java:348) | |
at org.apache.spark.serializer.JavaDeserializationStream$$anon$1.resolveClass(JavaSerializer.scala:68) | |
at java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:1613) | |
at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1518) | |
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1774) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) | |
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000) | |
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924) | |
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) | |
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000) | |
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924) | |
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) | |
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000) | |
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924) | |
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) | |
at java.io.ObjectInputStream.readArray(ObjectInputStream.java:1707) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1345) | |
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000) | |
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924) | |
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) | |
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000) | |
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924) | |
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) | |
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000) | |
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924) | |
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) | |
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000) | |
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924) | |
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) | |
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000) | |
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924) | |
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) | |
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000) | |
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924) | |
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) | |
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000) | |
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924) | |
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) | |
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:371) | |
at scala.collection.immutable.$colon$colon.readObject(List.scala:362) | |
at sun.reflect.GeneratedMethodAccessor3.invoke(Unknown Source) | |
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) | |
at java.lang.reflect.Method.invoke(Method.java:497) | |
at java.io.ObjectStreamClass.invokeReadObject(ObjectStreamClass.java:1017) | |
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1900) | |
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) | |
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000) | |
at java.io.O | |
bjectInputStream.readSerialData(ObjectInputStream.java:1924) | |
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) | |
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000) | |
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924) | |
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) | |
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:371) | |
at scala.collection.immutable.$colon$colon.readObject(List.scala:362) | |
at sun.reflect.GeneratedMethodAccessor3.invoke(Unknown Source) | |
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) | |
at java.lang.reflect.Method.invoke(Method.java:497) | |
at java.io.ObjectStreamClass.invokeReadObject(ObjectStreamClass.java:1017) | |
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1900) | |
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) | |
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000) | |
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924) | |
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) | |
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000) | |
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924) | |
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) | |
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:371) | |
at org.apache.spark.serializer.JavaDeserializationStream.readObject(JavaSerializer.scala:76) | |
at org.apache.spark.serializer.JavaSerializerInstance.deserialize(JavaSerializer.scala:115) | |
at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:61) | |
at org.apache.spark.scheduler.Task.run(Task.scala:89) | |
at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:227) | |
... 3 more |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment