scala - 沉降片类有大量物体吗？

Question

在这种情况下，它创建了大约 30000 个下沉类实例，有什么原因吗？沉降片的平行度为 16。

代码为：

val env = StreamExecutionEnvironment.getExecutionEnvironment
env.addSource(new Source).addSink(new Sinker)
env.execute()



class Sinker extends RichSinkFunction[String]{
    lazy val connection = ...

    override def invoke(value: String, context:SinkFunction.Context[_]): Unit = {
        connection.get
        ....
    }
}

标签： scalaapache-flinkflink-streaming