[FLINK-36904] Fix document error on how to programmatically configure…

… serialization
apache · Dec 16, 2024 · d541997 · d541997
1 parent 8aeb2ff
commit d541997
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/...nt/docs/dev/datastream/fault-tolerance/serialization/third_party_serializers.md b/...nt/docs/dev/datastream/fault-tolerance/serialization/third_party_serializers.md
@@ -45,8 +45,8 @@ You could also programmatically set it as follows:
 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}]");
+config.set(PipelineOptions.SERIALIZATION_CONFIG,
+    List.of("org.example.MyCustomType: {type: kryo, kryo-type: registered, class: org.example.MyCustomSerializer}"));
 
 StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(config);
 ```

diff --git a/...ontent/docs/dev/datastream/fault-tolerance/serialization/types_serialization.md b/...ontent/docs/dev/datastream/fault-tolerance/serialization/types_serialization.md
@@ -274,8 +274,8 @@ while block-style YAML list is used in the above example for better readability)
 ```java
 Configuration config = new Configuration();
 config.set(PipelineOptions.SERIALIZATION_CONFIG,
-    "[org.example.MyCustomType1: {type: pojo, class: org.example.MyCustomSerializer1},"
-        + "org.example.MyCustomType2: {type: kryo, kryo-type: registered, class: org.example.MyCustomSerializer2}]");
+    List.of("org.example.MyCustomType1: {type: pojo, class: org.example.MyCustomSerializer1}",
+        "org.example.MyCustomType2: {type: kryo, kryo-type: registered, class: org.example.MyCustomSerializer2}"));
 StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(config);
 ```