具有替代项的重载方法构造函数FlinkKafkaConsumer010

Question

我有一个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

对解决这个问题有什么帮助吗？

Answer 1

我和你有同样的问题。

检查你的FlinkKafkaConsumer010()方法，你从"org.apache.flink.streaming.util.serialization“包中导入了一个错误的依赖项，它的真实依赖项在flink-core.jar中。

问题可能在于没有引用Flink的依赖项，或者选择了错误的导入类。