JAR 超过 512 MB - Amazon Kinesis Data Analytics
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅中国的 Amazon Web Services 服务入门

本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。

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.