Я изучаю проект flink с зависимостями sbt
и log4j, slf4j
и пытаюсь запустить StreamExecutionEnvironment из org.apache.flink.streaming.api.scala._
Получил ошибку. Не могли бы вы помочь мне решить эту проблему.
Исходный рабочий проект с Gradle содержит файл log4j.properties в ресурсах и в build.gradle:
if (plugins.findPlugin('application')) {
applicationDefaultJvmArgs = ["-Dlog4j.configuration=log4j.properties"]
run.classpath = sourceSets.main.runtimeClasspath
ошибка:
ERROR StatusLogger No Log4j 2 configuration file found. Using default configuration (logging only errors to the console), or user programmatically provided configurations. Set system property 'log4j2.debug' to show Log4j 2 internal initialization logging. See https://logging.apache.org/log4j/2.x/manual/configuration.html for instructions on how to configure Log4j 2
зависимости sbt:
libraryDependencies ++= Seq(
"log4j" % "log4j" % "1.2.17",
"org.slf4j" % "slf4j-log4j12" % "1.7.30",
"org.apache.flink" % "flink-java" % flinkVersion,
"org.apache.flink" %% "flink-streaming-java" % flinkVersion,
"org.apache.flink" %% "flink-clients" % flinkVersion,
"org.apache.flink" %% "flink-scala" % flinkVersion,
"org.apache.flink" %% "flink-streaming-scala" % flinkVersion,
"org.apache.flink" %% "flink-runtime-web" % flinkVersion,
"org.apache.flink" %% "flink-cep" % flinkVersion,
"org.apache.flink" %% "flink-cep-scala" % flinkVersion,
"org.apache.flink" %% "flink-state-processor-api" % flinkVersion,
"org.apache.flink" %% "flink-table-uber" % flinkVersion,
"org.apache.flink" % "flink-test-utils-junit" % flinkVersion,
"org.apache.flink" %% "flink-test-utils" % flinkVersion,
"org.apache.flink" %% "flink-streaming-java" % flinkVersion,
"org.apache.flink" %% "flink-runtime" % flinkVersion
)
Оригинальный проект основан на Gradle? Как здесь задействован sbt? Также добавьте соответствующую структуру каталогов.