为什么 Apache Flink 在方法 org.apache.flink.api.java.typeutils.runtime.kryo.Serializers.getContainedGenericTypes 中停滞？
Why does Apache Flink stall in method org.apache.flink.api.java.typeutils.runtime.kryo.Serializers.getContainedGenericTypes?
在实现我的算法时，我在 Apache Flink 中使用 for 循环创建了一长串运算符。从方法中的一些长度处理停顿开始
org.apache.flink.api.java.typeutils.runtime.kryo.Serializers.getContainedGenericTypes 在实际处理之前很长一段时间。如何解释这种现象？如何解决以减少此方法时间？
Serializers.getContainedGenericTypes() 方法仅在您的 DataSet 应用程序的计划创建期间调用。
设置ExecutionConfig.disableAutoTypeRegistration()将禁用此注册。
我假设你在本地 运行 你的 Flink 应用程序没有大量数据。通常，计划创建只占用可用 CPU 时间的一小部分，而实际处理会占用大部分时间。
在实现我的算法时，我在 Apache Flink 中使用 for 循环创建了一长串运算符。从方法中的一些长度处理停顿开始 org.apache.flink.api.java.typeutils.runtime.kryo.Serializers.getContainedGenericTypes 在实际处理之前很长一段时间。如何解释这种现象？如何解决以减少此方法时间？
Serializers.getContainedGenericTypes() 方法仅在您的 DataSet 应用程序的计划创建期间调用。
设置ExecutionConfig.disableAutoTypeRegistration()将禁用此注册。
我假设你在本地 运行 你的 Flink 应用程序没有大量数据。通常，计划创建只占用可用 CPU 时间的一小部分，而实际处理会占用大部分时间。