在实现我的算法时，我用for循环在apache flink中创建了一长串操作符。从org.apache.flink.api.java.typeutils.runtime.kryo.serializers.getcontainedgenerictypes方法中的一些长度处理暂停开始，在实际处理之前很长一段时间。如何解释这种现象？如何解决这个问题以减少这种方法的时间？
在实现我的算法时，我用for循环在apache flink中创建了一长串操作符。从org.apache.flink.api.java.typeutils.runtime.kryo.serializers.getcontainedgenerictypes方法中的一些长度处理暂停开始，在实际处理之前很长一段时间。如何解释这种现象？如何解决这个问题以减少这种方法的时间？
1条答案
按热度按时间jobtbby31#
这个
Serializers.getContainedGenericTypes()方法仅在创建计划的过程中调用DataSet应用程序。设置
ExecutionConfig.disableAutoTypeRegistration()将禁用此注册。我假设您在本地运行flink应用程序时没有大量数据。通常，创建计划只占用可用cpu时间的一小部分，而实际处理占用了大部分时间。