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

Posted to user@flink.apache.org by Flavio Pompermaier <po...@okkam.it> on 2019/03/04 17:54:24 UTC

EventCountJob for Flink 1.7.2

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

Re: EventCountJob for Flink 1.7.2

Posted by Flavio Pompermaier <po...@okkam.it>.

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 <fh...@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 <po...@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
>>>
>>>

Re: EventCountJob for Flink 1.7.2

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

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 <po...@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
>>
>>

Re: EventCountJob for Flink 1.7.2

Posted by Flavio Pompermaier <po...@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 <po...@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
>
>