java.lang.ClassNotFoundException: scala.Serializable - PullRequest
Новая
       11

java.lang.ClassNotFoundException: scala.Serializable

0 голосов
/ 06 июля 2019

Я попытался создать тестовое задание scala для чтения потоковых данных kafka с помощью потокового соединителя flink, но получил следующую ошибку

java.lang.ClassNotFoundException: scala.Serializable 

import java.util.Properties

import org.apache.flink.api.common.typeinfo.TypeInformation
import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment
import org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer
import org.apache.flink.api.common.serialization.SimpleStringSchema

object kafka_int_s3 {

  def main(args: Array[String]): Unit = {

    implicit val typeInfo = TypeInformation.of(classOf[(String)])
    val env: StreamExecutionEnvironment = 
    StreamExecutionEnvironment.getExecutionEnvironment

    val properties = new Properties()
    properties.setProperty("bootstrap.servers", "localhost:9092")
    properties.setProperty("zookeeper.connect", "localhost:2181")
    properties.setProperty("group.id", "test")
    properties.setProperty("auto.offset.reset", "earliest")

    val kkConsumer = new FlinkKafkaConsumer[String](
      "testtopic",
      new SimpleStringSchema(),
      properties)

    val stream = env
      .addSource(kkConsumer)
      .print()

  }

}
...