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 支持回答:否。这个属性 无法更改。
作为我的 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 支持回答:否。这个属性 无法更改。