1

作为我的 flink 应用程序的运行时，我使用 AWS 托管的 flink（Kinesis 数据分析应用程序）

我添加了功能（接收器），用于以镶木地板格式从 S3 中的 kinesis 队列写入已处理的事件。本地一切都对我有用，但是当我尝试在云中运行应用程序时，出现以下异常：

    "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)",

在找到问题的解决方案后，我发现我需要更改以下属性（在本地集群上检查过）：

classloader.resolve-order：子优先-> classloader.resolve-order：父优先

在以任何方式使用 AWS 托管的 Fink（不是 EMR、Kinesis Data Analytics 应用程序）时，是否可以更改此配置？

4

1 回答 1

0

aws 支持回答：否。无法更改此属性。

于 2020-10-07T12:02:31.570 回答