回答情况：
提问时间：
问题标签：
>
<groupId>org.apache.flink</groupId> <artifactId>flink-connector-cassandra_2.10</artifactId>
<ver
浏览 10修改于2016-07-28得票数 0
我使用Kafka作为Flink job的数据源。当我将作业部署到flink集群作业管理器时，我收到一个错误ClassNotFoundException：Caused by: java.lang.ClassNotFoundException: org.apache.flink.connector.kafka.source.KafkaSource</groupId>
<artifactId>flink-connector-kafka_
浏览 489提问于2021-08-28得票数 0
回答已采纳
当我跟随通过flink流写入数据时，出现“不可序列化”错误。我使用flink1.6、Elastic-Search-6.4和flink-connector-Elastic ticsearch6。at org.apache.flink.util.Preconditions.checkArgument(Preconditions.java:139)
at org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSink
浏览 2提问于2018-10-19得票数 0
其他Flink连接器被放置在容器中，在中使用以下命令RUN wget -P /opt/flink/lib/ https://repo.maven.apache.orgopt/flink/lib/ https://repo.maven.apache.org/maven2/org/apache/flink</
浏览 3提问于2022-06-13得票数 1
回答已采纳
我正在使用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/org.
浏览 23修改于2019-12-26得票数 0
所以，我遵循了这里解释的步骤()ARG GCS_CONNECTOR_VERSION=latest-hadoop2ARG GCS_CONNECTOR_URI=https://storage.googleapis.com/
浏览 12修改于2022-08-11得票数 1
下面是我得到的错误的图片：
pom.xml中的Flink包是：flink-streaming-java_${scala.binary.version}flink-statebackend-rocksdb_2.11flink-sql-client_2.11我还
浏览 23修改于2022-08-02得票数 0
回答已采纳
当我使用pyflink hive sql read data insert into es时，抛出以下异常:环境: flink 1.11.2 flink-sql-connector-hive-3.1.2(HiveVectorizedOrcSplitReader.java:99) ~[flink-sql-connector-hive-3.1.2_2.11-1.11.2.jar:1.11.2]
at.nextBatch(OrcShimV210.java:35) ~[flink-sql
浏览 338提问于2020-12-17得票数 0
flink Dockerfile：
ADD http://central.maven.org/maven2/org/apache/flink/flink-connector-kafkaclasspath /opt/flink/lib/flink-avro-confluent-registry-1.7.2.jar:/o
浏览 0修改于2019-04-12得票数 1
回答已采纳
我尝试在Google上Shell中的ssh控制台中导入这个库：我以前安装过flink：tar -xzf flink-1.14.42.11.t
浏览 12修改于2022-05-12得票数 0
我正在尝试向Kubernates中部署的ververica平台提交作业，但我收到了下面的消息，我向Flink standalone提交了相同的代码，它的工作正常！！我使用的是Flink 1.10.1，代码是Scala 2.12。The following properties are requested:
connector.password=****** connect
浏览 74修改于2020-07-12得票数 1
回答已采纳
Flink是否支持Kafka 0.10.1.0？<dependency> <artifactId>flink-connector-kafka-0.9
浏览 1修改于2016-12-26得票数 4
The following properties are requested:connector.properties.0.value=localhost:2181connector.properties.1.value=localhost:9092conn
浏览 0提问于2018-10-24得票数 0
我想使用flink sql client创建一个配置单元表。我可以成功创建表t2，但是当我查询t2时，它会报错 Table options do not contain an option key 'connector' for discovering a connectorFlink SQL> use testdb1;
[INFO] Table has been creat
浏览 103提问于2020-12-21得票数 0
回答已采纳
Classpath是：failure cause: java.io.IOException: unable to open JDBC writer
at org.apache.flink.connector.
浏览 16修改于2022-05-24得票数 1
回答已采纳
/blob/83a6400e2587b067d08a64bc7e10edd4b57e71b4/flink-connectors/flink-connector-filesystem/src/main/java(HadoopFileSystem.java:215)
at org.apache.flink.connector.file.sink.FileSink$RowFormatBuilder.createBucketWriter
浏览 5提问于2022-07-19得票数 1
我想创建一个用scala编写的flink项目。当我导入时'flink-streaming-scala_2.11'我可以运行如下代码：但我看到每一个都是这样：
flink-conne
浏览 6提问于2017-07-23得票数 0
回答已采纳
of type org.apache.kafka.clients.consumer.OffsetResetStrategy in instance of org.apache.flink.connector.kafka.source.enumerator.initializer.ReaderHandledOffsetsInitializer:flink-connector-kafka:${flinkVersion}"
// https://mvnrepositor
浏览 61修改于2022-05-17得票数 4
但是，在我的pom.xml中： <groupId>org.apache.flink</groupId> <version>1.3.0</version>我拿到了这个：
浏览 2提问于2017-06-08得票数 3
回答已采纳
我检查了类似但有7年历史的问题，但它不适用于较新的Flink版本。 "org.apache.flink" %% "flink-streaming-scala" % flinkVersion,
&qu
浏览 20修改于2022-10-06得票数 1
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号