flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Flavio Pompermaier <pomperma...@okkam.it>
Subject Re: EventCountJob for Flink 1.7.2
Date Tue, 05 Mar 2019 13:48:52 GMT
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 right way to continue the migration..

Any suggestions?

[1]
https://github.com/okkam-it/flink-examples/blob/master/src/main/java/com/dataartisans/queryablestatedemo/EventCountJobLegacy.java
[2]
https://github.com/okkam-it/flink-examples/blob/master/src/main/java/com/dataartisans/queryablestatedemo/EventCountJobNew.java

On Tue, Mar 5, 2019 at 1:11 PM Fabian Hueske <fhueske@gmail.com> wrote:

> Thanks Flavio!
>
> Am Di., 5. März 2019 um 11:23 Uhr schrieb Flavio Pompermaier <
> pompermaier@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.:
>>
>> <dependency>
>> <groupId>org.apache.flink</groupId>
>>
>> <artifactId>flink-queryable-state-client-java_${scala.version}</artifactId>
>> <version>${flink.version}</version>
>> <scope>provided</scope>
>> </dependency>
>>
>> I hope this could help someone else..
>>
>> On Mon, Mar 4, 2019 at 6:54 PM Flavio Pompermaier <pompermaier@okkam.it>
>> wrote:
>>
>>> Hi to all,
>>> I was trying to test the EventCountJob[1] on Flink 1.7.2 but there's no
>>> more QueryableStateOptions.SERVER_ENABLE. How can I specify to enable query
>>> server on LocalFlinkMiniCluster?
>>> I've tried to chenage it to
>>> config.setString(QueryableStateOptions.SERVER_PORT_RANGE, "9067");
>>> but it is ignored.
>>>
>>> [1]
>>> https://github.com/dataArtisans/flink-queryable_state_demo/blob/master/src/main/java/com/dataartisans/queryablestatedemo/EventCountJob.java
>>>
>>> Best,
>>> Flavio
>>>
>>>

Mime
View raw message