本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
JAR 超过 512 MB
有时候,您可能需要将在 Kinesis Analytics 上运行的 Flink 应用程序打包到多个 JAR 文件中,而不是单个 JAR 文件中。如果以下是我们通过客户上报注意到的这些用例的几个示例:512MB 硬限制会限制您在 Kinesis Analytics 上运行应用程序的能力,请考虑以下解决方法:
总会有一个 Flink 客户端在运行。它采用 Flink 应用程序的代码,将其转换为 JobGraph 并将其提交给 JobManager. 这些区域有: JobManager 将作品分发到 TaskManagers,其中运行实际的运算符(例如源、变换和汇点)。
你可以在 Flink 客户端上运行 Java 代码,它会下载其他 JAR 并通过创建另一个 JAR 将它们添加到类路径中 ClassLoader,或者将其保存到 Flink Cache blob 存储区并将其传递给 TaskManagers 每个任务管理器都可以在其中创建这些对象的实例open()的方法 ProcessFunction.
有关示例,请参阅 。在运行时添加下载 flink jar