在这个例子中，它创建了大约30000个sinker类示例，有什么原因吗？沉子的平行度为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
        ....
    }
}