Copy config using constructor instead of Clone to avoid synchronizations

arnaud-daroussin · arnaud-daroussin · commit 326eb59b2e63 · 2025-01-30T01:25:28.000+01:00
diff --git a/modules/scala-api/src/main/scala/org/apache/flinkx/api/StreamExecutionEnvironment.scala b/modules/scala-api/src/main/scala/org/apache/flinkx/api/StreamExecutionEnvironment.scala
@@ -977,7 +977,7 @@ object StreamExecutionEnvironment {
       serializationConfig.add("scala.util.Either: {type: typeinfo, class: org.apache.flinkx.api.typeinfo.FailFastTypeInfoFactory}")
       serializationConfig.add("scala.Array: {type: typeinfo, class: org.apache.flinkx.api.typeinfo.FailFastTypeInfoFactory}")
       serializationConfig.add("scala.collection.Iterable: {type: typeinfo, class: org.apache.flinkx.api.typeinfo.FailFastTypeInfoFactory}")
-      config.clone().set(serializationOption, serializationConfig)
+      new Configuration(config).set(serializationOption, serializationConfig)
     } else {
       config
     }

Original file line number	Diff line number	Diff line change
`@@ -977,7 +977,7 @@ object StreamExecutionEnvironment {`
`977`	`977`	`serializationConfig.add("scala.util.Either: {type: typeinfo, class: org.apache.flinkx.api.typeinfo.FailFastTypeInfoFactory}")`
`978`	`978`	`serializationConfig.add("scala.Array: {type: typeinfo, class: org.apache.flinkx.api.typeinfo.FailFastTypeInfoFactory}")`
`979`	`979`	`serializationConfig.add("scala.collection.Iterable: {type: typeinfo, class: org.apache.flinkx.api.typeinfo.FailFastTypeInfoFactory}")`
`980`		`- config.clone().set(serializationOption, serializationConfig)`
	`980`	`+ new Configuration(config).set(serializationOption, serializationConfig)`
`981`	`981`	`} else {`
`982`	`982`	`config`
`983`	`983`	`}`