starting query server when running flink embedded

[Henri Heiskanen]

Hi,

I would like to test queryable state just by running the flink embedded from my IDE. What is the easiest way to start it properly? If I run the below I can not see the query server listening at the given port. I found something about this, but it was about copying some base classes and post was from 2016 so maybe things have improved.

Configuration conf = new Configuration();

conf.setBoolean("query.server.enable", true);

conf.setInteger("query.server.port", 16122);

final StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironment(2, conf);

Br,

Henkka

[Piotr Nowojski]

Hi,

You can take a look at how is it done in the exercises here. There are example solutions that run on a local environment.

I Hope that helps :)

Piotrek

On Sep 28, 2017, at 11:22 PM, Henri Heiskanen <[hidden email]> wrote:

Hi,

I would like to test queryable state just by running the flink embedded from my IDE. What is the easiest way to start it properly? If I run the below I can not see the query server listening at the given port. I found something about this, but it was about copying some base classes and post was from 2016 so maybe things have improved.

Configuration conf = new Configuration();

conf.setBoolean("query.server.enable", true);

conf.setInteger("query.server.port", 16122);

final StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironment(2, conf);

Br,

Henkka