我有一个scala文件,里面有导入和代码。我不知道如何解决这个问题:
package uimp
import org.apache.flink.streaming.api.scala._
import org.apache.flink.streaming.api.TimeCharacteristic
import org.apache.flink.streaming.util.serialization.
{SimpleStringSchema,JSONKeyValueDeserializationSchema}
import org.apache.flink.core._
import org.apache.flink.streaming.connectors.kafka.{FlinkKafkaConsumer010}
import java.util.Properties
import scala.util.parsing.json.JSONObject
import com.fasterxml.jackson.databind.node.ObjectNode
object Silocompro {
def main(args: Array[String]): Unit = {
// set up the execution environment
val env = StreamExecutionEnvironment.getExecutionEnvironment
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime)
//...more code
val myConsumerDemographic = new FlinkKafkaConsumer010[ObjectNode]("topic_demographic", new org.apache.flink.streaming.util.serialization.JSONKeyValueDeserializationSchema(false), propertiesTopicDemographic)
// ...more code
我有这个build.sbt来解决所有的依赖关系:
ThisBuild / scalaVersion := "2.12.11"
val flinkVersion = "1.9.0"
val flinkDependencies = Seq(
"org.apache.flink" %% "flink-scala" % flinkVersion ,
"org.apache.flink" %% "flink-streaming-scala" % flinkVersion ,
"org.apache.flink" %% "flink-connector-kafka-base" % flinkVersion ,
"org.apache.flink" % "flink-core" % flinkVersion ,
"org.apache.flink" %% "flink-clients" % flinkVersion,
"org.apache.flink" %% "flink-connector-kafka-0.10" % flinkVersion ,
"com.fasterxml.jackson.core" % "jackson-databind" % "2.10.1")
但我在装配后有一个错误:
重载方法构造函数flinkkafkaconsumer010及其替代项
有什么办法解决这个问题吗?
1条答案
按热度按时间uqjltbpv1#
我和你有同样的问题。
检查你的flinkkafcaumer010()方法,你从包“org.apache.flink.streaming.util.serialization”中导入了一个错误依赖,它的真正依赖在flink-core.jar中。
问题可能在于没有引用flink的依赖项或选择了错误的导入类。