You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by Elias Levy <fe...@gmail.com> on 2018/08/28 22:02:44 UTC

Queryable state and state TTL

Is there a reason queryable state can't work with state TTL?  Trying to use
both at the same time leads to a "IllegalArgumentException: Queryable state
is currently not supported with TTL"

Re: Queryable state and state TTL

Posted by Andrey Zagrebin <an...@data-artisans.com>.

Hi,

Fabian is right, support of TTL for queryable state needs an extra effort because of some specifics of its interaction with state objects, but there is no fundamental problem. It is on the roadmap for the future realises.

Best,
Andrey

> On 29 Aug 2018, at 09:30, Fabian Hueske <fh...@gmail.com> wrote:
> 
> Hi,
> 
> I guess that this is not a fundamental problem but just a limitation in the current implementation.
> Andrey (in CC) who implemented the TTL support should be able to give more insight on this issue.
> 
> Best, Fabian
> 
> Am Mi., 29. Aug. 2018 um 04:06 Uhr schrieb vino yang <yanghua1127@gmail.com <ma...@gmail.com>>:
> Hi Elias,
> 
> From the source code, the reason for throwing this exception is because StateTtlConfig is set to StateTtlConfig.DISABLED. 
> Please refer to the usage and description of the official Flink documentation for details.[1]
> 
> And there is a note you should pay attention : Only TTLs in reference to processing time are currently supported.
> 
> [1]: https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/stream/state/state.html#state-time-to-live-ttl <https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/stream/state/state.html#state-time-to-live-ttl>
> 
> Thanks, vino.
> 
> Elias Levy <fearsome.lucidity@gmail.com <ma...@gmail.com>> 于2018年8月29日周三 上午6:03写道：
> Is there a reason queryable state can't work with state TTL?  Trying to use both at the same time leads to a "IllegalArgumentException: Queryable state is currently not supported with TTL"
> 
>

Re: Queryable state and state TTL

Posted by Fabian Hueske <fh...@gmail.com>.

Hi,

I guess that this is not a fundamental problem but just a limitation in the
current implementation.
Andrey (in CC) who implemented the TTL support should be able to give more
insight on this issue.

Best, Fabian

Am Mi., 29. Aug. 2018 um 04:06 Uhr schrieb vino yang <yanghua1127@gmail.com
>:

> Hi Elias,
>
> From the source code, the reason for throwing this exception is because
> StateTtlConfig is set to StateTtlConfig.DISABLED.
> Please refer to the usage and description of the official Flink
> documentation for details.[1]
>
> And there is a note you should pay attention : Only TTLs in reference to *processing
> time* are currently supported.
>
> [1]:
> https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/stream/state/state.html#state-time-to-live-ttl
>
> Thanks, vino.
>
> Elias Levy <fe...@gmail.com> 于2018年8月29日周三 上午6:03写道：
>
>> Is there a reason queryable state can't work with state TTL?  Trying to
>> use both at the same time leads to a "IllegalArgumentException: Queryable
>> state is currently not supported with TTL"
>>
>>
>>

Re: Queryable state and state TTL

Posted by vino yang <ya...@gmail.com>.

Hi Elias,

From the source code, the reason for throwing this exception is because
StateTtlConfig is set to StateTtlConfig.DISABLED.
Please refer to the usage and description of the official Flink
documentation for details.[1]

And there is a note you should pay attention : Only TTLs in reference
to *processing
time* are currently supported.

[1]:
https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/stream/state/state.html#state-time-to-live-ttl

Thanks, vino.

Elias Levy <fe...@gmail.com> 于2018年8月29日周三 上午6:03写道：

> Is there a reason queryable state can't work with state TTL?  Trying to
> use both at the same time leads to a "IllegalArgumentException: Queryable
> state is currently not supported with TTL"
>
>
>