作为我的flink应用程序的运行时,我使用aws管理的flink(kinesis数据分析应用程序)
我以Parquet格式为s3中的kinesis队列添加了写处理事件的功能(sink)。在本地,一切都适合我,但当我尝试在云中运行应用程序时,出现以下异常:
"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数据分析应用程序)时,是否可以更改此配置?
1条答案
按热度按时间50pmv0ei1#
aws支持答案:否。此属性不能更改。