aws 运动数据分析应用程序 (flink) 更改 属性 最初位于 flink-conf.yaml

aws kinesis data analytics application (flink) change property originally located at flink-conf.yaml

作为我的 flink 应用程序的运行时间,我使用 AWS(Kinesis Data Analytics 应用程序)托管的 flink

我添加了以镶木地板格式从 S3 中的运动队列写入已处理事件的功能(接收器)。 在本地一切都适合我,但是当我尝试 运行 云中的应用程序时,出现以下异常:

    "throwableInformation": [
        "com.esotericsoftware.kryo.KryoException: Error constructing instance of class: org.apache.avro.Schema$LockableArrayList",
        "Serialization trace:",
        "types (org.apache.avro.Schema$UnionSchema)",
        "schema (org.apache.avro.Schema$Field)",
        "fieldMap (org.apache.avro.Schema$RecordSchema)",

找到问题的解决方案后,我发现我需要更改以下内容属性(在本地集群上检查过):

类加载器。resolve-order:child-first -> 类加载器。resolve-order:parent-first

在使用 AWS 管理的 Fink(不是 EMR、Kinesis Data Analytics 应用程序)时是否可以以任何方式更改此配置?

aws 支持回答:否。这个属性 无法更改。