scala.util.parsing.json.json.parsefull线程安全吗?

5sxhfpxr  于 2021-05-26  发布在  Spark
关注(0)|答案(0)|浏览(220)

我正在运行一些scalaspark应用程序,它使用scalajson解析api。
但有时,它很少能坚持下来。当时的线程转储如下:
scala.collection.mutable.hashtable$class.resize(哈希表。scala:257)scala.collection.mutable.hashtable$class.scala$collection$mutable$hashtable$$addentry0(哈希表)。scala:154)scala.collection.mutable.hashtable$class.findoraddentry(哈希表。scala:166)scala.collection.mutable.hashmap.findoradentry(hashmap。scala:40) scala.collection.mutable.hashmap.put(hashmap。scala:76)scala.collection.mutable.hashmap.update(hashmap。scala:81)scala.collection.mutable.maplike$class.getorelseupdate(maplike。scala:194)scala.collection.mutable.abstractmap.getorelseupdate(Map。scala:80) scala.util.parsing.combinator.syntactic.stdtokenparsers$class.keyword(stdtokenparsers。scala:37)scala.util.parsing.json.parser.keyword(解析器。scala:113)scala.util.parsing.json.parser$$anonfun$jsonobj$1$$anonfun$apply$4.apply(解析器。scala:135)scala.util.parsing.json.parser$$anonfun$jsonobj$1$$anonfun$apply$4.apply(解析器。scala:135) scala.util.parsing.combinator.parsers$$anonfun$rep1sep$1$$anonfun$apply$9.apply(解析器。scala:771) ...
根据我的调查,‘json’是一个对象,它扩展了stdtokenparsers特性,该特性具有可变的哈希表。据我所知,spark任务在一个执行器中运行多线程,因此似乎有可能发生一些并发问题。
我的假设正确吗?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题