I’m trying to run a very simple flink app - run flink locally (without a local cluster, just from the code with

createLocalEnvironmentWithWebUI

), read from kafka topic, and print.

val env = StreamExecutionEnvironment.createLocalEnvironmentWithWebUI()
    val tableEnv = StreamTableEnvironment.create(env)

    val ddl =
      """CREATE TABLE invalid_events ( ... ) WITH ( 'connector' = 'kafka' .... ) """

    val sql1 = """CREATE TABLE print_table ( ... ) WITH ('connector' = 'print');"""

    val sql2 = """INSERT INTO print_table SELECT * FROM invalid_events;"""

    tableEnv.executeSql(ddl)

    tableEnv.executeSql(sql1)
    tableEnv.executeSql(sql2)
    
    env.execute("my job")

I’m getting:

Exception in thread "main" java.lang.IllegalStateException: No operators defined in streaming topology. Cannot execute.

What am I missing?

no need for this: env.execute("my job").

@hui ch Without the env.execute the program exits with exit code 0, (without even creating the local cluster)

i have no problem running it locally. make sure your configuration is correct:`WITH ( 'connector' = 'kafka' .... )`