I've just uploaded a Flink-1.7.2 compatible version of the original code at
[1].
However FoldingStateDescriptor is now deprecated and should be migrated
to AggregatingStateDescriptor (according to the javadoc).
Is there any guide about how to do this? I've drafted it in [2] but I
didn't know the ri
Thanks Flavio!
Am Di., 5. März 2019 um 11:23 Uhr schrieb Flavio Pompermaier <
pomperma...@okkam.it>:
> I discovered that now (in Flink 1.7.2( queryable state server is enabed if
> queryable state client is found on the classpath, i.e.:
>
>
> org.apache.flink
> flink-queryable-state-client-java_$
I discovered that now (in Flink 1.7.2( queryable state server is enabed if
queryable state client is found on the classpath, i.e.:
org.apache.flink
flink-queryable-state-client-java_${scala.version}
${flink.version}
provided
I hope this could help someone else..
On Mon, Mar 4, 2019 at 6:54 PM
