Thanks Haibo,
bummer ;)
On Mon, Jul 15, 2019 at 12:27 PM Haibo Sun wrote:
> *This Message originated outside your organization.*
> --
> Hi, Avi Levi
>
> I don't think there's any way to solve this problem right now, and Flink
> documentation clearly shows that this i
Hi,
I added a ttl to my state
*old version :*
private lazy val stateDescriptor = new ValueStateDescriptor("foo",
Types.CASE_CLASS[DomainState])
*vs the new version *
@transient
private lazy val storeTtl = StateTtlConfig.newBuilder(90)
.setUpdateType(StateTtlConfig.UpdateType.OnCreateAndWrite)
