Scala中的Flink:在尝试将map应用于DataStreamSource时出现问题

Question

在我使用Flink的Scala代码中，我已经能够阅读这样一个Kafka主题：

val stream_demographic = env.addSource(new FlinkKafkaConsumer[String]("topic_demographic",
new SimpleStringSchema(), properties_demographic))

stream_demographic val的类型为DataStreamSource。然而，当我试图将map应用于它以解析正在接收的JSON时，我得到了一个错误：

错误屏幕截图

它导致"；无法解析重载的方法"map"；，所以我无法解析任何内容，因为这是一个错误。有人能帮我吗？

提前谢谢。

Answer 1

多亏了官方文档，我发现了问题：我为Flink的scala-api加载了糟糕的依赖项。