aws kinesis数据分析应用程序(flink)更改原来位于flink-conf.yaml的属性

gc0ot86w  于 2021-06-26  发布在  Flink
关注(0)|答案(1)|浏览(501)

作为我的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数据分析应用程序)时,是否可以更改此配置?

50pmv0ei

50pmv0ei1#

aws支持答案:否。此属性不能更改。

相关问题