java.io.NotSerializableException:com.codahale.metrics.MetricRegistry

1.美图


Logical Plan:
Project [value#23 AS page#32, count#28L AS count#33L]
+- Aggregate [value#23], [value#23, count(1) AS count#28L]+- SerializeFromObject [staticinvoke(class org.apache.spark.unsafe.types.UTF8String, StringType, fromString, input[0, java.lang.String, true], true) AS value#23]+- MapPartitions , obj#22: java.lang.String+- DeserializeToObject cast(value#15 as string).toString, obj#21: java.lang.String+- Project [cast(value#1 as string) AS value#15]+- StreamingExecutionRelation KafkaSource[Subscribe[topip-lcc]], [key#0, value#1, topic#2, partition#3, offset#4L, timestamp#5, timestampType#6]at org.apache.spark.sql.ex