我正在使用Flink Connector Kafka 1.8.0。(取决于kafka-clients 2.0.1) https://mvnrepository.com/artifact/org.apache.flink/flink-connector-kafka_2.12/1.8.0 使用gradle： // https://mvnrepository.com/artifact&
浏览 23提问于2019-12-26得票数 0
我有一个容器化的flink集群，具有独立的JobManager和2个任务管理器。当我提交一个包含我需要的连接器和代码的胖jar时，一切都会正常运行，但是一个只有我的代码的jar将失败--尽管我已经将连接器jar添加到/opt/flink/lib，容器进程显示它们将被添加到类路径中。当我试图从IDE进行远程连接时，也会发生同样的失败；不用说，每次都要打包
浏览 0提问于2019-04-12得票数 1
回答已采纳
更新当识别压缩类型时，尝试将LZ4与运行时由于某种原因可以找到的KafkaLZ4BlockInputStream相关联。作业，用来消费卡夫卡的唱片。:kafka-clients:jar:2.4.1确实存在于依赖树中。:flink-connector-kafka_2.11:jar:1.14.0:compile
| \- org.apache.kafka:kafka-clients:ja
浏览 18提问于2021-12-09得票数 1
这是我的java web应用程序的控制器。public interface Kafka_ObjectDao {
dao接口的实现是</dependency> <groupId>org.apache.kafka</groupId>
<artifactId>kafka-clie
浏览 6提问于2017-02-07得票数 0
回答已采纳
我需要提交一个flink sql程序来运行纱线，在flink目录下将依赖项添加到/lib时，它正常工作，但如果我希望从jar包加载依赖项，而不是在/lib下加载依赖项java.lang.NoClassDefFoundError将在我执行flink run时发生<?这是我的flink/lib
-rw-r--r-- 1 ghost staf
浏览 64提问于2021-12-13得票数 1
我创建了一个计算维基百科单词的程序。它工作正常，没有任何错误。然后，我创建了带有两列"word(text)和count(bigint)“的Cassandra表。token, 1)); } }
运行这段代码后，我得到了以下错误：
线程"main“org.apache.flink.api.common.InvalidProgramException:中的异常AbstractCassandraTupleSink<e
浏览 0提问于2018-12-24得票数 0
回答已采纳
我是flink的新手，我正试图在emr集群上从flink 1.8升级到flink 1.11。升级到flink1.11之后，我看到的一个不同之处是，我没有得到任何度量。我发现flink 1.11在/usr/lib/ flink /opt中没有org.apache.flink.metrics.statsd.StatsDReporterFactory jar，这是<
浏览 2提问于2020-10-22得票数 0
尝试将Flink 1.9 SQL-Client与Kafka一起使用，但未成功。在弄清楚所需的jar文件并将它们复制到lib目录后，当执行SELECT * FROM table-name时，我得到了以下运行时异常： Flink SQL> select * from default_catalog.default_database.member_customer_newsletters/lib/flink-sql-connector-kafka-0.11_2.12-
浏览 231提问于2019-09-20得票数 0
(Thread.java:745) )
第一个是对maven应用程序(javax.ws.rs.jar)The上库的传递依赖，第二个是位于目录中的jar，其中包含来自hortonworks的所有hadoop依赖项，我需要将这些依赖项导出到类路径以使应用程序工作为(jsr311-api-1.1.1.jar)。因此，我需要以某种
浏览 7提问于2019-09-20得票数 1
回答已采纳
我试图运行Apache，我使用Kafka主题作为输入，在尝试运行Flink时，我得到了以下错误： <artifactId>flink-streaming-java_2.10</artifa
浏览 3提问于2017-11-20得票数 1
我在同一个Flink项目中有多个工作。我想知道，当我向Flink集群提交作业时，我不知道哪个作业正在为这个提交的jar运行。例如：然后，我更改job2，并创建新的jar文件。然后使用新上传的jar提交job2。
在这种情况下，当查看提交U
浏览 7提问于2021-04-21得票数 0
我一直试图使用Kafka运行一个简单的wordcount应用程序，但是每当我运行它时，我就会得到以下错误：public static void main(final String[] args) throws
浏览 0提问于2018-12-12得票数 0
回答已采纳
1回答
但是，当我尝试使用原生kubernetes集成在集群上运行它时，我会看到下面这样的奇怪错误。
集群看起来也很好，因为我试图在集群上运行一个wordcount应用程序，它运行得很好。异常不清楚，堆栈跟踪也显示了任务管理器堆栈跟踪，因此不知道应用程序中的问题可能在哪里。这可能是序列化问题吗？是否有一种方法来调试这些问题，并在应用程序代码中找到有问题的实际点？(LocalCache.java:2302) ~[flink-dist_2.12-1.12-SNAPSHOT.jar:1.12-SNAP
浏览 2提问于2021-09-01得票数 0
回答已采纳
我正在配置我的自定义kafka源代码，我得到了一个与value.deserializer kafka属性相关的错误。<!</constructor-arg><project xmlns="http://maven
浏览 5提问于2017-04-11得票数 0
谁能给我指引一条正确的路？DataStream<MyDataObject> dataStream = stream.flatMap(new DataTransformation());
我使用flatMapFunction来处理我的输入对象并获得多个对象。，我使用collect()收集记录，然后将所有记录传递给下一个操作符，以处理数据库插入操作。我使用
浏览 8提问于2018-01-16得票数 4
我在使用Spark streaming API时得到了NoClassDefFoundErrorerror。这是我的流代码。我知道这是一些令人讨厌的jars和依赖的问题，但我不能确切地弄清楚这是什么。 <artifactId>SparkPOC</artifac
浏览 0提问于2016-10-07得票数 0
3回答
我要使用apache运行简单的worcount示例。使用$SPARK_HOME/jars中的本地jar文件，它正确运行，但使用maven依赖于它的错误： <groupId>org.apache.flink</groupId>
浏览 19提问于2017-11-28得票数 0
回答已采纳
我与kafka Producer有一些问题，但我不知道如何解决它 <dependency>
<groupId>org.apache.kafka</groupId>
浏览 2提问于2017-06-20得票数 5
我正在使用flink和kafka，我得到了这个错误。)我使用的是flink - 1.0.3版本和Kafka-kafka_2.11-0.8.2.1和scala - 2.11.5，这些是我在构建路径中使用的jar：
asm-4.0.jar,commons-codec-1.6.<e
浏览 2提问于2016-06-30得票数 4
我使用Terraform来提供EMR (我在下载和运行作业之后运行ansible )。打开盒子，它看起来不像EMR的Flink发行版包括可选的jars (flink-指标-prometheus，flink-cep等等)。看看弗林克的文档，上面写着
“要使用此记者，必须将/opt/flink-metrics-prometheus-1.6.1.jar复制到Flink发行版的
浏览 0提问于2019-03-06得票数 4
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
