> 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

Reply via email to