代碼如下:

ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();BatchTableEnvironment tEnv = BatchTableEnvironment.create(env);DataStream<Order> orderA = env.fromCollection(Arrays.asList(new Order(1L, "beer", 3),new Order(3L, "rubber", 2),new Order(1L, "diaper", 4)));

完整報錯如下:

Incompatible types. Required DataStream<Order> but 'fromCollection' was inferred to DataSource<X>:

no instance(s) of type variable(s) X exist so that DataSource<X> conforms to DataStream<Order>

解決方案:

import org.apache.flink.api.java.DataSet;DataSet<Order> orderA = env.fromCollection(Arrays.asList(new Order(1L, "beer", 3),new Order(3L, "rubber", 2),new Order(1L, "diaper", 4)));

因為這個報錯信息太誤導人了，所以記錄下.

大致原因就是env是批處理的環境，那么你就別用DataStream
?

總結

以上是生活随笔為你收集整理的no instance(s) of type variable(s) X exist so that DataSource＜X＞ conforms to DataStream＜Order＞的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。