[
https://issues.apache.org/jira/browse/FLINK-36904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-36904:
----------------------------------
Assignee: Zhanghao Chen
> Fix document error on how to programmatically configure serialization
> ---------------------------------------------------------------------
>
> Key: FLINK-36904
> URL: https://issues.apache.org/jira/browse/FLINK-36904
> Project: Flink
> Issue Type: Sub-task
> Affects Versions: 2.0.0, 1.20.0
> Reporter: Zhanghao Chen
> Assignee: Zhanghao Chen
> Priority: Major
> Labels: pull-request-available
> Fix For: 2.0.0
>
>
> From user email:
> https://lists.apache.org/thread/mdokv42k0zxlxdwl7y61hv2pc3fjwmyq
>
> ??I am trying to use 3rd party serializers as per
> [https://nightlies.apache.org/flink/flink-docs-release-1.20/docs/dev/datastream/fault-tolerance/serialization/third_party_serializers/]??
> |??[3rd Party Serializers \\| Apache
> Flink\|https://nightlies.apache.org/flink/flink-docs-release-1.20/docs/dev/datastream/fault-tolerance/serialization/third_party_serializers/]??
> ??3rd Party Serializers # If you use a custom type in your Flink program
> which cannot be serialized by the Flink type serializer, Flink falls back to
> using the generic Kryo serializer. You may register your own serializer or a
> serialization system like Google Protobuf or Apache Thrift with Kryo. To do
> that, simply register the type class and the serializer via the configuration
> option pipeline ...??
> ??nightlies.apache.org??|
>
> ??but the code sample does not compile??
> ??```??
> ??Configuration config = new Configuration();??
> ??// register the class of the serializer as serializer for a type??
> ??config.set(PipelineOptions.SERIALIZATION_CONFIG, ??
> ?? "[org.example.MyCustomType: \\{type: kryo, kryo-type: registered,
> class: org.example.MyCustomSerializer}]");??
> ??```??
> ??because the expected parameter is a list of strings. I can do??
>
> ??```??
> ??config.set(PipelineOptions.SERIALIZATION_CONFIG, List.of(??
> ?? "org.example.MyCustomType: \{type: kryo, kryo-type: registered, class:
> org.example.MyCustomSerializer}"));??
> ??```??
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
