Usually, the problem occurs when users import the wrong classes. The
current class naming is a bit confusing as there are 3
StreamTableEnvironment classes. You need to choose the one that matches
your programming language. E.g.
org.apache.flink.table.api.java.StreamTableEnvironment.
Regards,
Thanks, I will check it out.
Michael
Sent from my iPad
> On Nov 1, 2018, at 8:22 PM, Hequn Cheng wrote:
>
> Hi Michael,
>
> There are some test cases in Flink git, such as[1] which I think may help you.
>
> Best, Hequn
> [1]
> https://github.com/apache/flink/blob/master/flink-libraries/fli
Hi Michael,
There are some test cases in Flink git, such as[1] which I think may help
you.
Best, Hequn
[1]
https://github.com/apache/flink/blob/master/flink-libraries/flink-table/src/test/java/org/apache/flink/table/runtime/stream/sql/JavaSqlITCase.java
On Fri, Nov 2, 2018 at 7:46 AM TechnoMage
I am trying to get a minimal Flink SQL program going to test it out. I have a
StreamExecutionEnvironment and from that created a StreamTableEnvironment. The
docs indicate there should be a fromDataStream method to create a Table, but
none appears to exist according to Eclipse. The method regi
