Skip to content

Commit d3f87a2

Browse files
authored
Fix incorrect UnitTypeInformation equality logic
1 parent 240e1e5 commit d3f87a2

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

modules/scala-api/src/main/scala/org/apache/flinkx/api/typeinfo/UnitTypeInformation.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -10,16 +10,16 @@ class UnitTypeInformation extends TypeInformation[Unit] {
1010
override def isKeyType: Boolean = true
1111
override def getTotalFields: Int = 0
1212
override def isTupleType: Boolean = false
13-
override def canEqual(obj: Any): Boolean = obj.isInstanceOf[Unit]
13+
override def canEqual(obj: Any): Boolean = obj.isInstanceOf[UnitTypeInformation]
1414
override def getTypeClass: Class[Unit] = classOf[Unit]
1515
override def getArity: Int = 0
1616
override def isBasicType: Boolean = false
1717

1818
override def toString: String = "{}"
1919

2020
override def equals(obj: Any): Boolean = obj match {
21-
case _: Unit => true
22-
case _ => false
21+
case _: UnitTypeInformation => true
22+
case _ => false
2323
}
2424

2525
override def hashCode(): Int = ().hashCode()

0 commit comments

Comments
 (0)