The execution within the IDE is most likely not loading the flink-conf.yaml
file to read the configuration. When run from the IDE you get a
LocalStreamEnvironment, which starts a LocalFlinkMiniCluster.
LocalStreamEnvironment is created by
StreamExecutionEnvironment.createLocalEnvironment without passing it any
configuration. So none
of StreamExecutionEnvironment., LocalStreamEnvironment,
and LocalFlinkMiniCluster try to read the config file.
This makes it difficult to test certain Flink features from within the IDE,
as some configuration properties can't be set programmatically. For
instance, you can't configure the external checkpoint URL in code. It can
only be yet in the config file. That means you can't run a job that turns
on external checkpoints from within the IDE.
Ideally one of these components would try load the config file when
executing locally. You could then point it to the config file via
the FLINK_CONF_DIR environment variable.
On Fri, Sep 8, 2017 at 8:47 AM, AndreaKinn <[EMAIL PROTECTED]> wrote: