I want to write an StreamTableExample(java style) of https://github.com/apache/flink/blob/master/flink-examples/flink-examples-table/src/main/scala/org/apache/flink/table/examples/scala/basics/StreamTableExample.scala
My code is: https://paste.ubuntu.com/p/WcBb7Rr6gb/ Could you tell me why my code is wrong? The intellij tell me what I got is DataStreamSource, instead of DataStream, How can I fix it? Thanks for your help.
