[
https://issues.apache.org/jira/browse/FLINK-2231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14644152#comment-14644152
]
ASF GitHub Bot commented on FLINK-2231:
---------------------------------------
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/935#discussion_r35631275
--- Diff:
flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/ScalaSpecialTypesSerializerTest.scala
---
@@ -93,8 +98,11 @@ class ScalaSpecialTypesSerializerTest {
val typeInfo = implicitly[TypeInformation[T]]
val serializer = typeInfo.createSerializer(new ExecutionConfig)
val typeClass = typeInfo.getTypeClass
- val test =
+ val test = if (typeInfo.isInstanceOf[EnumValueTypeInfo[_]]) {
+ new ScalaSpecialTypesSerializerTestInstance[T](serializer,
typeClass, 4, instances)
--- End diff --
We could use serializer.getLength here.
> Create a Serializer for Scala Enumerations
> ------------------------------------------
>
> Key: FLINK-2231
> URL: https://issues.apache.org/jira/browse/FLINK-2231
> Project: Flink
> Issue Type: Improvement
> Components: Scala API
> Reporter: Stephan Ewen
> Assignee: Alexander Alexandrov
>
> Scala Enumerations are currently serialized with Kryo, but should be
> efficiently serialized by just writing the {{initial}}.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
