you can setup a specific port using
https://ci.apache.org/projects/flink/flink-docs-master/ops/config.html#rest-port.
On 03.09.2018 12:12, Mar_zieh wrote:
Hello
I added these dependencies to "pom.xml"; also, I added configuration to my
code like these:
Configuration config = new Configuration(
Hello
I added these dependencies to "pom.xml"; also, I added configuration to my
code like these:
Configuration config = new Configuration();
config.setBoolean(ConfigConstants.LOCAL_START_WEBSERVER, true);
StreamExecutionEnvironment env =
StreamExecutionEnvironment.createLocalEnvironment(getP,
Thanks a ton, Till.
That worked. Thank you so much.
-Biplob
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Can-t-access-Flink-Dashboard-at-8081-running-Flink-program-using-Eclipse-tp8016p8035.html
Sent from the Apache Flink User Mailing Li
Hi Biplob,
if you want to start the web interface from within your IDE, then you have
to create a local execution environment as Ufuk told you:
Configuration config = new Configuration();
config.setBoolean(ConfigConstants.LOCAL_START_WEBSERVER, true);
StreamExecutionEnvironment env =
StreamExecu
Yes you have to provide the path of your jar. The reason is:
1. When you start in the pseudo-cluster mode the tasks are started in their
own JVM's with their own class loader.
2. You client program has access to your custom operator classes but the
remote JVM's don't. Hence you need to ship the JAR
Thanks Ufuk, for the input. I tried what u suggested as well ( as follows)
Configuration config = new Configuration();
config.setBoolean(ConfigConstants.LOCAL_START_WEBSERVER, true);
StreamExecutionEnvironment env =
StreamExecutionEnvironment.crea
You can explicitly create a LocalEnvironment and provide a Configuration:
Configuration config = new Configuration();
config.setBoolean(ConfigConstants.LOCAL_START_WEBSERVER, true);
ExecutionEnvironment env = new LocalEnvironment(config);
...
On Tue, Jul 19, 2016 at 1:28 PM, Sameer W wrote:
>
Hi Sameer,
Thanks for that quick reply, I was using flink streaming so the program
keeps on running until i close it. But anyway I am ready to try this
getRemoteExecutionEnvironment(), I checked but it ask me for the jar file,
which is weird because I am running the program directly.
Does it mea
>From Eclipse it creates a local environment and runs in the IDE. When the
program finishes so does the Flink execution instance. I have never tried
accessing the console when the program is running but one the program is
finished there is nothing to connect to.
If you need to access the dashboard
Hi,
I am running my flink program using Eclipse and I can't access the dashboard
at http://localhost:8081, can someone help me with this?
I read that I need to check my flink-conf.yaml, but its a maven project and
I don't have a flink-conf.
Any help would be really appreciated.
Thanks a lot
Bip
10 matches
Mail list logo
