1.6.1 stderr log page for app-20180810192843-2349/6

Back to Master

Bytes 3064529 - 3166929 of 3166929

ss is not valid
18/08/11 15:25:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:25:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:25:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:25:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:25:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:25:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:25:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:25:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:25:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:26:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:26:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:26:00 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 15:26:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:26:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:26:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:26:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:26:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:26:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:27:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:27:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:27:00 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 15:27:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:27:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:27:20 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 15:27:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:27:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:27:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:28:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:28:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:28:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:28:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:28:20 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 15:28:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:28:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:28:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:29:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:29:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:29:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:29:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:29:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:29:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:29:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:29:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:29:40 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 15:30:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:30:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:30:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:30:21 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:30:21 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:30:21 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:30:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:30:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:30:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:31:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:31:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:31:00 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 15:31:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:31:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:31:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:31:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:31:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:31:40 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 15:32:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:32:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:32:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:32:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:32:41 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:32:41 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:32:41 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:32:41 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:32:41 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 15:33:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:33:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:33:00 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 15:33:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:33:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:33:20 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 15:33:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:33:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:33:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:34:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:34:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:34:00 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 15:34:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:34:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:34:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:34:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:34:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:34:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:35:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:35:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:35:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:35:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:35:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:35:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:35:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:35:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:35:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:36:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:36:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:36:00 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 15:36:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:36:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:36:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:36:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:36:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:36:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:37:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:37:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:37:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:37:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:37:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:37:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:37:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:37:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:37:40 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 15:38:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:38:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:38:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:38:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:38:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:38:20 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 15:38:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:38:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:38:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:38:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:39:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:39:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:39:00 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 15:39:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:39:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:39:20 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 15:39:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:39:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:39:40 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 15:40:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:40:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:40:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:40:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:40:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:40:20 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 15:40:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:40:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:40:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:41:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:41:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:41:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:41:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:41:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:41:20 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 15:41:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:41:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:41:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:42:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:42:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:42:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:42:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:42:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:42:20 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 15:42:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:42:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:42:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:43:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:43:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:43:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:43:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:43:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:43:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:43:43 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:44:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:44:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:44:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:44:00 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 15:44:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:44:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:44:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:44:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:44:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:44:40 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 15:45:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:45:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:45:00 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 15:45:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:45:20 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 15:45:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:45:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:45:40 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 15:46:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:46:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:46:00 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 15:46:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:46:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:46:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:46:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:46:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:46:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:47:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:47:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:47:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:47:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:47:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:47:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:47:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:47:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:47:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:48:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:48:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:48:00 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 15:48:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:48:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:48:20 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 15:48:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:48:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:48:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:49:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:49:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:49:20 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 15:49:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:49:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:49:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:50:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:50:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:50:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:50:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:50:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:50:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:50:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:50:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:50:40 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 15:51:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:51:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:51:00 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 15:51:22 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:51:22 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:51:22 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:51:22 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:51:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:51:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:51:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:52:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:52:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:52:00 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 15:52:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:52:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:52:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:52:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:52:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:52:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:53:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:53:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:53:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:53:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:53:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:53:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:53:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:53:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:53:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:54:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:54:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:54:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:54:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:54:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:54:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:54:40 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 15:55:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:55:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:55:00 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 15:55:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:55:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:55:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:55:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:55:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:55:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:55:40 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 15:56:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:56:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:56:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:56:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:56:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:56:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:56:20 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 15:56:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:56:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:56:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:57:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:57:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:57:00 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 15:57:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:57:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:57:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:57:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:57:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:58:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:58:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:58:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:58:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:58:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:58:20 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 15:58:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:58:40 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 15:59:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:59:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:59:00 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 15:59:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:59:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:59:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:59:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:59:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 15:59:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 16:00:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 16:00:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 16:00:00 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 16:00:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 16:00:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 16:00:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 16:00:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 16:00:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 16:00:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 16:00:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 16:01:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 16:01:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 16:01:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 16:01:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 16:01:20 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 16:01:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 16:01:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 16:01:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 16:02:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 16:02:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 16:02:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 16:02:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 16:02:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 16:02:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 16:02:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 16:02:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 16:02:40 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 16:03:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 16:03:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 16:03:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 16:03:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 16:03:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 16:03:20 WARN VerifiableProperties: Property serializer.class is not valid
java.lang.NullPointerException
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:757)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20$$anonfun$apply$21.apply(SdkToLiveDataHandle.scala:754)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:754)
	at com.yunmei.sdk.spark.streamming.SdkToLiveDataHandle$$anonfun$42$$anonfun$apply$20.apply(SdkToLiveDataHandle.scala:741)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.rdd.RDD$$anonfun$foreachPartition$1$$anonfun$apply$33.apply(RDD.scala:920)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1858)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
	at org.apache.spark.scheduler.Task.run(Task.scala:89)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
	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)
18/08/11 16:03:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 16:03:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 16:03:40 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 16:04:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 16:04:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 16:04:00 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 16:04:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 16:04:20 WARN VerifiableProperties: Property serializer.class is not valid
18/08/11 16:04:20 WARN VerifiableProperties: Property serializer.class is not valid