> The result here is the representation of the statement execution result, NOT > the query output. > You can define a print connector table[1] as your sink table, and insert into > the query output to the sink table to achieve your goal.
Correction: you can also iterate the output result from table_result.collect() or call print function to print the output result or sink to print table[1], all of them should woks. Looks like your flink cluster need to increase the slots resource from the root cause "Caused by: org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException:" [1] https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/table/print/ Best, Leonard