JDBC source running continuously

[Fanbin Bu]

Hi,

My app creates the source from JDBC inputformat and running some sql and
print out. But the source terminates itself after the query is done. Is
there anyway to keep the source running?
samle code:
val env = StreamExecutionEnvironment.getExecutionEnvironment
val settings = EnvironmentSettings.newInstance()
      .useBlinkPlanner()
      .inStreamingMode()
      .build()
val tEnv = StreamTableEnvironment.create(env, settings)
val inputFormat = JDBCInputFormat.buildJDBCInputFormat.setQuery("select *
from table")... .finish()
val source = env.createInput(inputFormat)
tEnv.registerTableSource(source)
val queryResult = tEnv.sqlQuery("select * from awesomeSource")
queryResult.insertInto(mySink)


I searched around and its suggested to use .iterate(). can somebody give
more examples on how to use it in this case?

Thanks,
Fanbin