Problem is with dependencies in pom.xml file , adding required dependencies
solved my problem.
On Mon, 17 Apr 2023, 8:06 am Weihua Hu, <huweihua....@gmail.com> wrote:
> Hi, Mark
>
> Flink will load ui service automatically if the flink-runtime-web jars in
> classpath.
>
> So, adding the dependency of flink-runtime-web is the right way.
> You need to reload the maven project after the pod.xml changed.
> And check whether the classpath includes flink-runtime-web classes or not.
>
> Best,
> Weihua
>
>
> On Sun, Apr 16, 2023 at 10:02 PM Mark Petronic <markpetro...@gmail.com>
> wrote:
>
>> I am learning Flink for a new project. I am trying to understand the
>> development/debug environment to help me step through my code to better
>> learn Flink. I am using the Intellij community edition for my IDE and Flink
>> 1.17.0.
>>
>> I am using this simple Flink app to demonstrate my issue.
>>
>>
>> //===========================================================================
>> package streamwindowprocessor;
>>
>> import org.apache.flink.configuration.Configuration;
>> import org.apache.flink.streaming.api.datastream.DataStream;
>> import
>> org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
>>
>> public class SimpleFlink {
>>
>> public static void main(String[] args) throws Exception {
>>
>> Configuration conf = new Configuration();
>> final StreamExecutionEnvironment env =
>> StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(conf);
>> // final StreamExecutionEnvironment env =
>> StreamExecutionEnvironment.getExecutionEnvironment();
>>
>> DataStream<String> values = env.socketTextStream("localhost",
>> 9999);
>> values.print();
>>
>> env.execute("Alarm Stream Processor");
>> }
>> }
>>
>> //===========================================================================
>>
>> Before I run this from the IDE, I start up a socket listener on a
>> terminal:
>>
>> nc -lkp 9999
>>
>> Then I open a web browser to localhost:8081 and get this output
>>
>> {
>>
>> - errors:
>> [
>> - "Not found: /"
>> ]
>>
>> }
>>
>> If instead, I use ./start-cluster.sh to start a standalone cluster,
>> rebuild my jar using getExecutionEnvironment() and submit that same simple
>> jar using ./flink.sh run <path-to-jar>, then I can open the browser to
>> localhost:8081 and I do see my app running, as expected, and it processes
>> strings I send via the running netcat.
>>
>> Someone in SO noted that you should add this dependency, which I did and
>> it made no difference.
>>
>> <dependency>
>> <groupId>org.apache.flink</groupId>
>> <artifactId>flink-runtime-web</artifactId>
>> <version>${flink.version}</version>
>> </dependency>
>>
>> *Can anyone help me understand why the web UI does not work
>> in createLocalEnvironmentWithWebUI()?*
>>
>> Thanks,
>> Mark
>>
>
