Skip to content

Commit b7edadf

Browse files
fix exception caused by same types registered multiple times
1 parent 5dd9508 commit b7edadf

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

modules/scala-api/src/main/scala/org/apache/flinkx/api/StreamExecutionEnvironment.scala

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -967,7 +967,8 @@ object StreamExecutionEnvironment {
967967
}
968968

969969
private def configureFailFastOnScalaTypeResolutionWithClass(configuration: Configuration): Unit = {
970-
if (!isFailFastOnScalaTypeResolutionWithClassDisabled) {
970+
if (!isFailFastOnScalaTypeResolutionWithClassConfigured && !isFailFastOnScalaTypeResolutionWithClassDisabled) {
971+
isFailFastOnScalaTypeResolutionWithClassConfigured = true
971972
val serializationOption = ConfigOptions.key("pipeline.serialization-config").stringType().asList().noDefaultValue()
972973
val serializationConfig = configuration.getOptional(serializationOption).orElse(new util.ArrayList[String])
973974
serializationConfig.add("scala.Product: {type: typeinfo, class: org.apache.flinkx.api.typeinfo.FailFastTypeInfoFactory}")
@@ -979,6 +980,8 @@ object StreamExecutionEnvironment {
979980
}
980981
}
981982

983+
private var isFailFastOnScalaTypeResolutionWithClassConfigured: Boolean = false
984+
982985
private lazy val isFailFastOnScalaTypeResolutionWithClassDisabled: Boolean =
983986
sys.env
984987
.get("DISABLE_FAIL_FAST_ON_SCALA_TYPE_RESOLUTION_WITH_CLASS")

0 commit comments

Comments
 (0)