We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 983b97c commit 7527dbfCopy full SHA for 7527dbf
scenario-compiler/src/main/java/pl/touk/nussknacker/engine/spel/internal/FlinkRowToMapConverter.scala
@@ -32,7 +32,8 @@ class FlinkRowToMapConverter(val conversionService: ConversionService) extends C
32
// fields.map(e => e -> r.getField(e)).toMap.asJava
33
val getFieldsMethod = source.getClass.getMethod("getFieldNames", classOf[Boolean])
34
getFieldsMethod.setAccessible(true)
35
- val fields = getFieldsMethod.invoke(source, true).asInstanceOf[java.util.Set[String]].asScala
+ val fields =
36
+ getFieldsMethod.invoke(source, (true).asInstanceOf[AnyRef]).asInstanceOf[java.util.Set[String]].asScala
37
fields
38
.map(e => {
39
val getFieldMethod = source.getClass.getMethod("getField", classOf[String])
0 commit comments