代碼如下:

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)));

完整報(bào)錯(cuò)如下:

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)));

因?yàn)檫@個(gè)報(bào)錯(cuò)信息太誤導(dǎo)人了，所以記錄下.

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

總結(jié)

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

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。