[jira] [Created] (FLINK-3039) Trigger KeyValueState cannot be Scala Int

["Fabian Hueske (JIRA)" <ji...@apache.org>]

Fabian Hueske created FLINK-3039:
------------------------------------

             Summary: Trigger KeyValueState cannot be Scala Int
                 Key: FLINK-3039
                 URL: https://issues.apache.org/jira/browse/FLINK-3039
             Project: Flink
          Issue Type: Improvement
    Affects Versions: 0.10.0
            Reporter: Fabian Hueske
             Fix For: 1.0.0


It is not possible to use a Scala Int as a KeyValueState in a {{Trigger}} function because {{TriggerContext.getKeyValueState}} requires that the state is Serializable.

{code}
override def onElement(e: (Int, Short), t: Long, w: TimeWindow, ctx: TriggerContext): TriggerResult = {
      val cnt = ctx.getKeyValueState[Int]("cnt", 0)
      ...
}
{code}

will fail with 
{code}
Error:(116, 44) type arguments [Int] do not conform to method getKeyValueState's type parameter bounds [S <: java.io.Serializable]
      val cnt = ctx.getKeyValueState[Int]("cnt", 0)
                                           ^
{code}

If I change {{Int}} to {{Integer}}, the code compiles.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)