Skip to content

Commit 0513754

Browse files
feat(#286): fix CI "No ClassTag available for Nothing" error
1 parent 58ad376 commit 0513754

File tree

1 file changed

+18
-23
lines changed

1 file changed

+18
-23
lines changed

modules/flink-common-api/src/main/scala/org/apache/flinkx/api/serializers.scala

Lines changed: 18 additions & 23 deletions
Original file line numberDiff line numberDiff line change
@@ -3,35 +3,27 @@ package org.apache.flinkx.api
33
import org.apache.flink.api.common.serialization.{SerializerConfig, SerializerConfigImpl}
44
import org.apache.flink.api.common.typeinfo.{BasicTypeInfo, LocalTimeTypeInfo, TypeInformation}
55
import org.apache.flink.api.common.typeutils.TypeSerializer
6-
import org.apache.flink.api.common.typeutils.base.{
7-
BooleanSerializer,
8-
ByteSerializer,
9-
CharSerializer,
10-
DoubleSerializer,
11-
FloatSerializer,
12-
IntSerializer,
13-
LongSerializer,
14-
ShortSerializer
15-
}
166
import org.apache.flink.api.common.typeutils.base.array._
7+
import org.apache.flink.api.common.typeutils.base.{ListSerializer, MapSerializer, _}
178
import org.apache.flink.api.java.typeutils.EnumTypeInfo
189
import org.apache.flink.types.{Nothing => FlinkNothing}
1910
import org.apache.flinkx.api.mapper.{BigDecMapper, BigIntMapper, UuidMapper}
2011
import org.apache.flinkx.api.serializer.MappedSerializer.TypeMapper
2112
import org.apache.flinkx.api.serializer._
2213
import org.apache.flinkx.api.typeinfo._
2314

24-
import java.lang.{Float => JFloat}
25-
import java.lang.{Long => JLong}
26-
import java.lang.{Double => JDouble}
27-
import java.lang.{Short => JShort}
28-
import java.lang.{Byte => JByte}
29-
import java.lang.{Boolean => JBoolean}
30-
import java.lang.{Integer => JInteger}
31-
import java.lang.{Character => JCharacter}
32-
import java.math.{BigInteger => JBigInteger}
33-
import java.math.{BigDecimal => JBigDecimal}
34-
import java.time.{Instant, LocalDate, LocalDateTime, LocalTime, OffsetDateTime, ZoneId, ZoneOffset, ZonedDateTime}
15+
import java.lang.{
16+
Boolean => JBoolean,
17+
Byte => JByte,
18+
Character => JCharacter,
19+
Double => JDouble,
20+
Float => JFloat,
21+
Integer => JInteger,
22+
Long => JLong,
23+
Short => JShort
24+
}
25+
import java.math.{BigDecimal => JBigDecimal, BigInteger => JBigInteger}
26+
import java.time._
3527
import java.util.UUID
3628
import scala.collection.immutable.{SortedSet, TreeSet}
3729
import scala.concurrent.duration.{Duration, FiniteDuration, TimeUnit}
@@ -115,9 +107,12 @@ trait serializers extends LowPrioImplicits {
115107
implicit lazy val finiteDurationInfo: TypeInformation[FiniteDuration] = SimpleTypeInfo(2, 2, keyType = true)
116108
implicit lazy val flinkNothingInfo: TypeInformation[FlinkNothing] =
117109
SimpleTypeInfo(0)(classTag[FlinkNothing], new NothingSerializer().asInstanceOf[TypeSerializer[FlinkNothing]])
118-
implicit lazy val scalaNothingInfo: TypeInformation[Nothing] =
110+
implicit lazy val scalaNothingInfo: TypeInformation[scala.Nothing] =
119111
// At runtime scala.Nothing is scala.runtime.Nothing$ and extends Throwable
120-
SimpleTypeInfo[Nothing](6, 11)(classTag[Nothing], new NothingSerializer().asInstanceOf[TypeSerializer[Nothing]])
112+
SimpleTypeInfo[scala.Nothing](6, 11)(
113+
classTag[scala.Nothing],
114+
new NothingSerializer().asInstanceOf[TypeSerializer[scala.Nothing]]
115+
)
121116
implicit lazy val timeUnitInfo: TypeInformation[TimeUnit] = new EnumTypeInfo(classOf[TimeUnit])
122117
implicit lazy val uuidMapper: TypeMapper[UUID, Array[Byte]] = new UuidMapper()
123118
implicit lazy val uuidInfo: TypeInformation[UUID] = mappedTypeInfo[UUID, Array[Byte]]

0 commit comments

Comments
 (0)