EventCountJob for Flink 1.7.2

[Flavio Pompermaier]

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

[Flavio Pompermaier]

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 <[hidden email]> 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

[Fabian Hueske-2]

Thanks Flavio!

Am Di., 5. März 2019 um 11:23 Uhr schrieb Flavio Pompermaier <[hidden email]>:

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 <[hidden email]> 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

[Flavio Pompermaier]

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 <[hidden email]> wrote:

Thanks Flavio!

Am Di., 5. März 2019 um 11:23 Uhr schrieb Flavio Pompermaier <[hidden email]>:

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 <[hidden email]> 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