Question about Scala Case Class and List in Flink

list can be serialize that I can ignore this info if I don’t care the performance. Should I use Java array list instead of scala list or create a custom serializer for SensorReading case class? Thanks! Best  regards Utopia

Can trigger fire early brefore specific element get into ProcessingTimeSessionWindow

Hi, I want to fire and evaluate the ProcessingTimeSessionWindow when a specific element come into current window. But I want to exclude the specific element when processing window function and remaining it for the next evaluation. Thanks Best  regards Utopia

Re: Cannot get value from ValueState in ProcessingTimeTrigger

Hi Vino, Maybe it is due to the type of window. What I used is ProcessingTimeSessionWindows, while keyedState is scoped to window and key. Window changes so that the ValueState is different. Best  regards Utopia 在 2019年12月18日 +0800 22:30，Utopia ，写道： > Hi Vino, > > Thanks for y

Re: Cannot get value from ValueState in ProcessingTimeTrigger

re, How can I stored the previous value so that I can get the value when next element come in and invoke the onElement method? Best  regards Utopia 在 2019年12月18日 +0800 21:57，vino yang ，写道： > Hi Utopia, > > The behavior may be correct. > > First, the default value is null. It's the

Cannot get value from ValueState in ProcessingTimeTrigger

: 9 after update value: 10 Best  regards Utopia

Scala ListBuffer cannot be used as a POJO type in Flink

has ListBuffer type field? https://stackoverflow.com/q/59352295/4388077 Best  regards Utopia

clear method of Trigger not be called after purge

Hi guys, I set allowLateness on SessionWindow. Then I return FIRE_AND_PURGE in onEventTime method of Trigger, but clear method not be called. While clear will be called, if I return FIRE_AND_PURGE in onElement method. Best regards. Utopia

[no subject]