mapPartitions里是耗时的(batch型的)模型推理
dataframe.repartition(500).rdd.mapPartitions
改为
dataframe.repartition(5000).rdd.mapPartitions

mapPartitions里是耗时的(batch型的)模型推理
dataframe.repartition(500).rdd.mapPartitions
改为
dataframe.repartition(5000).rdd.mapPartitions