1

我正在尝试在 AWS Kinesis Data Analytics 上部署 Python Flink 应用程序。我遵循了https://docs.aws.amazon.com/kinesisanalytics/latest/java/how-python-creating.html上的官方文档

我想使用从 Confluent Kafka 读取的 TableAPI 创建一个源表，并使用 avro-confluent 格式反序列化消息。

遵循连接器文档https://nightlies.apache.org/flink/flink-docs-release-1.13/docs/connectors/table/kafka/和 https://nightlies.apache.org/flink/flink-docs-release -1.13/docs/connectors/table/formats/avro-confluent/我需要包含两个 jar 文件作为依赖项。但物业jarfile在

"ApplicationConfiguration": {
    "EnvironmentProperties": {
      "PropertyGroups": [
        {
          "PropertyGroupId": "kinesis.analytics.flink.run.options",
          "PropertyMap": {
            "python": "MyApplication/main.py",
            "jarfile": "MyApplication/lib/myJarFile.jar",
            "pyFiles": "MyApplication/lib/myDependentFile.py",
            "pyArchives": "MyApplication/lib/myArchive.zip"
          }
        },

它似乎只接受一个 jar 文件作为依赖项。

关于如何将这两个 jar 文件包含为依赖项的任何想法？

谢谢

4

0 回答 0