kafka-apache flink执行log4j错误

文章/答案/技术大牛

发布

1回答

apache-kafka、apache-flink、flink-streaming

我试着用Kafka inegration运行一个简单的Apache Flink脚本，但我一直在执行中遇到问题。脚本应该读取来自kafka制作人的消息，详细说明它们，然后再次将处理结果发送回另一个主题。我从这里得到了这个例子：Exception in thread "main" java.lang.NoSuchFieldError:ALL at org.apache.flink.streaming.api.graph.StreamingJobGraphGenera‌tor.createJ

浏览 5提问于2017-07-27得票数 0

回答已采纳

1回答

kafka闪烁连接错误显示NoSuchMethodError

apache-flink

当我从flinkkafkaconsumer09更改为flinkkafkaconsumer闪烁代码时，出现新的错误： import org.apache.flink.api.common.functions.MapFunctionException { } } } 错误:log4j:警告找不到记录器(org.apache.fl

浏览 21提问于2020-01-23得票数 0

回答已采纳

1回答

IDE eclipse中的scala和maven错误

scala、maven、apache-flink

我使用双倍创建了这个示例程序log4j:WARN No appenders could be found for logger (org.apache.flink.api.scala.ClosureCleaner$).log4j:WARN See http://logging.apache.org/log4

浏览 0提问于2016-09-06得票数 0

2回答

Flink错误: java.lang.NoSuchMethodError: org.apache.flink.api.table.Table

java、apache-flink、flink-streaming

;import org.apache.flink.api.table.Table; }} 错误如下：(发生在行DataS

浏览 1提问于2016-12-21得票数 2

1回答

Flink错误: org.apache.flink.shaded.calcite.com.google.common.base.Throwables :java.lang.ClassNotFoundException

apache-flink、flink-streaming

我使用Flink流数据，这是在csv文件。我想用特定的模式把它转换成表格格式。为此目的，我使用的是Flink_2.10-1.1.3.jar(表api)，但是我得到了以下错误：log4j:WARN Please initialize the log4j system

浏览 1提问于2016-12-21得票数 2

1回答

我的Flink应用程序正在使用哪个日志记录框架？

java、logging、log4j、apache-flink、logback

我的Flink日志哪儿也没出现。所以我在读如何解决这个问题。我读过一些关于如何在flink/conf文件中更改日志级别的文章，以帮助我解决这个问题。那么现在如何确定我的Flink应用程序使用的是哪个框架呢？

浏览 18提问于2022-06-02得票数 2

回答已采纳

1回答

RuntimeException使用Flink的MapFunction与Cassandra“插入”，但不使用“语句”

java、cassandra、datastax、query-builder、apache-flink

但是，通过使用DataStream<Statement>，一切都如我所期望的那样正常工作，即使我仍然在执行的代码中使用Insert实例。我通过尝试和错误找到了一个解决方案(使用DataStream<Statement>)，但我仍然对是什么原因感到困惑。是故意的还是窃听器？预期输出(使用DataStream<Statement>)： log4j:WARN No appenders could be found for logger (org.apache.flink.api.java.ty

浏览 9提问于2017-01-17得票数 0

回答已采纳

3回答

设置Apache和Flink日志级别以显示调试消息

java、logging、apache-flink、apache-storm

因此，我正在用Storm和Flink应用程序构建一个JAR，其中我记录消息如下：import org.slf4j.LoggerFactory; 如果你需要更多的细节，

浏览 4提问于2019-10-11得票数 0

回答已采纳

1回答

从hbase读取串行化错误的Flink

hadoop、hbase、apache-flink、flink-streaming

当我在地图中使用richfatMapFunction读取hbase时，我得到了序列化错误。我想要做的是，如果数据存储等于从hbase中读取的特定字符串，则忽略它。下面是我得到的示例程序和错误。import org.apache.flink.api.java.tuple.Tuple2 t

浏览 4提问于2016-11-06得票数 0

回答已采纳

1回答

Flink 1.5中的批处理表API问题--对流API需求的抱怨

apache-flink、flink-sql

我试图用Flink 1.5.0创建一个面向批处理的Flink作业，并希望使用Table和SQL来处理数据。我的问题是试图创建一个编译错误的BatchTableEnviroment import org.apache.flink.table.api.Table; import org.apache.flink.table.api.TableEnvi

浏览 1提问于2018-06-19得票数 0

2回答

IntelliJ集成开发环境警告Flink* CEP未知错误*

scala、intellij-idea、apache-flink、complex-event-processing

我开始研究用Scala语言编写的Apache Flink的CEP库，当我试图通过执行https://ci.apache.org/projects/flink/flink-docs-stable/dev/flink-cep-scala libraryDependencies += "org.apache.flink" %% "flink-cep-scala" %

浏览 50提问于2020-01-14得票数 0

回答已采纳

1回答

flink作业中的org/apache/flink/streaming/connectors/rabbitmq/common/RMQConnectionConfig :java.lang.NoClassDefFoundError

java

我正在将flink(v1.10.0)作业提交到我的群集，但显示以下错误： System.out: (none) at org.apache.flink.client.program.OptimizerPlanEnvironment.generateException(PackagedProgramUtils.java:56) at org.apache.flink.runtime.webmonitor.handlers.utils.JarHandlerUtils<em

浏览 57提问于2020-04-05得票数 0

回答已采纳

1回答

原因: java.lang.ClassCastException: org.apache.hadoop.fs.s3a.S3AFileSystem无法转换为org.apache.hadoop.fs.FileSystem

apache-flink

我得到了错误消息： -->

浏览 3提问于2018-01-24得票数 0

1回答

尚未为shadowJar中的属性'mainClassName‘指定值

gradle、apache-flink

我正在使用gradle(v6.0.1)构建工具编译flink，但是显示了这个错误： ~ ⌚ 13:53:42 flinkShadowJar.exclude group: 'org.slf4j' flinkShadowJar.exclude group: 'log4jflink

浏览 228提问于2020-04-05得票数 0

回答已采纳

4回答

与卡夫卡连接的Flink

apache-kafka、apache-flink、kafka-consumer-api、flink-streaming

</groupId> <version>${log4j.version}</version> </dependency> <

浏览 5提问于2017-02-09得票数 0

2回答

未找到org.apache.flink.api.common.serialization.DeserializationSchema的类文件

java、maven、apache-kafka、apache-flink

当我试图构建(maven)项目时，我会得到以下错误：有什么办法解决这个错误吗</groupId>

浏览 16提问于2017-12-29得票数 2

回答已采纳

2回答

Apache :无法为指定的execution.target找到兼容的工厂(=local)

apache-flink

`org.apache.flink:flink-csv:1.10.0`import org.apache.flink.api.scala.extensions:937) //org.apache.flink.api.java.ExecutionEnvironment.exec

浏览 3提问于2020-02-25得票数 2

回答已采纳

2回答

在Apache Flink中使用SLF4J记录器时出错

log4j、slf4j、apache-flink、flink-cep、loggerfactory

我想在Flink中输出日志，我已经创建了如下所述的记录器代码import org.slf4j.LoggerFactory;附注-我在使用时遇到错误final static org.slf4j.Logger logger = LoggerFactory.getLogg

浏览 44提问于2017-08-29得票数 0

2回答

Apache Flink* -外部Jar*

java、sql、jdbc、apache-flink、flink-streaming

当我在本地运行代码时，一切正常，但当在Flink上运行时，我收到以下错误消息：因此，我最初的想法是，依赖项并没有使用maven卷影插件加载到fat jar上，但我认为是这样的。 <!>1.7.7</version> </dependency>

浏览 40提问于2020-05-14得票数 1

回答已采纳

1回答

NoClassDefFoundError: kafka/api/OffsetRequest请求Storm jar

scala、apache-kafka、sbt、apache-storm

我正在尝试将Storm拓扑提交到群集，但不断收到相同的错误： Exception in thread "main" java.lang.NoClassDefFoundError: kafka/api/kafkaVersion excludeAll( ExclusionRule("log4j", "log4j&qu

浏览 23提问于2020-01-28得票数 1

回答已采纳

点击加载更多