我试图让Apache项目与Apache 1.0.0集成。当我试图在我的build.sbt文件中添加flink连接器-kafka包时，我会看到一个错误，它不能解决它。val flinkVersion = "1.4.1" "org.apache.flink" %% "flink-scala" % flinkVersion% "provided",
浏览 2提问于2018-03-03得票数 2
回答已采纳
尝试将Apache Flink连接到rabbitmq时出现错误。我用Apache Maven做了这个项目，但错误仍然存在。我的代码是：import org.apache.flink.api.common.serialization.SimpleStringSchema;;
import org.apache.flink.streaming.con
浏览 25提问于2019-08-13得票数 1
1回答
我正在尝试使用带有RabbitMq流连接器的Flink。尝试了所有可能的版本组合，但仍然失败。val json4sNative = "org.json4s" %% "json4s-native" % "3.3.0"
"org.apache.flink" %% "flink-scala" % flinkVersion % "provid
浏览 0提问于2016-03-08得票数 2
我得到了以下错误 at org.apache.flink.streaming.connectors.rabbitmq.RMQSource.open(RMQSource.java:172)
at org.apache.flink.api.common.functions.util.FunctionUtils.openFunction
浏览 2提问于2018-01-21得票数 3
; import org.apache.flink.api.common.typeinfo.TypeInformation; import org.apache.flink.api.java
浏览 1提问于2017-08-24得票数 0
1回答
我正在将flink(v1.10.0)作业提交到我的群集，但显示以下错误： System.out: (none) at org.apache.flink.client.program.OptimizerPlanEnvironment.generateException/flink/streaming/connectors/rabbitmq/common/RMQConnectionConfig$Buil
浏览 57提问于2020-04-05得票数 0
回答已采纳
根据这里的文档： https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/connectors/ 和 https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table&#
浏览 58提问于2020-07-10得票数 0
在使用PyFlink编写Flink 1.15.2代码时，我使用Flink 1.15.2和使用以下连接器从RabbitMQ获取消息：flink-sql-connector-rabbitmq-1.15.2.for the RabbitMQ connection
'queueName', # name of the RabbitMQ queue to send messages"/home/ali
浏览 34提问于2022-09-05得票数 0
3回答
我想测试RMQSource类来接收来自RabbitMQ的数据，但是我不知道如何为我的交换机配置兔子虚拟主机，我认为这就是我遇到的问题。我的代码：import org.apache.flink.streaming.connectors.rabbitmq.RMQSourceimport org.apache.flink</e
浏览 4提问于2016-06-07得票数 0
回答已采纳
:6123上使用地址localhost:6123连接到JobManager的独立集群。<init>(FlinkKafkaConsumer.java:192) at org.apache.flink.streaming.connectors.kafka
浏览 0提问于2020-03-09得票数 0
回答已采纳
我有一个maven项目，我在其中添加了flink库的依赖项，如下所示： <repository> <name>Apache Development Snapshot Repository</name>
<url>https://repository.
浏览 0提问于2016-12-05得票数 1
1回答
我使用flink 1.9.0和rabbitmq连接器读取数据，我可以成功地编译我的代码，但当我运行代码时，我得到以下错误：我在pom文件中没有为依赖项定义任何作用域。.setPort(1234).setUser
浏览 44提问于2019-11-06得票数 1
回答已采纳
我使用apache flink-gelly lirbrarie设置我的边、顶点、数据集和图。; import org.apache.flink.graph.Graph; import org.apach
浏览 97提问于2020-09-10得票数 0
1回答
我使用Apache进行流.I，将Apache的数据作为流通过flink，并在Azure数据lake.Is中拥有并保存最终的流，在flink中有可用的连接器在Azure数据湖中转储流数据吗？
浏览 2提问于2017-04-12得票数 0
回答已采纳
当我使用RabbitMQ作为Flink DataStream源代码时，正如Flink文档所说的那样。objects这段代码将连接到RabbitMQ并自动创建队列"queueName".So --我遇到了一个问题。RabbitMQ队列已经存在，我在前面创建了它。我不想让<
浏览 0提问于2018-05-13得票数 3
回答已采纳
我需要在Flink流媒体方面的帮助。下面我制作了一个简单的Hello类型的代码。这会从RabbitMQ中流Avro消息并将其保存到HDFS。我希望有人能检查代码，也许它能帮助其他人。这里的数据来源是RabbitMQ。我使用客户端应用程序将"MyAvroObjects“发送到RabbitMQ。;import org.apache
浏览 8提问于2015-12-28得票数 4
我正在创建一个简单的Apache作业(使用Scala)，它只尝试打印表示RabbitMQ队列(RMQSource)接收的事件的case类。org.angoglez.deserializers.eventSerializationSchema.deserialize(eventSerializationSchema.scala:14)
at org.apache.flink.streaming.connectors.rabbitmq.RMQDeserializationSchemaWrapper.d
浏览 1提问于2021-11-16得票数 1
回答已采纳
1回答
at org.apache.flink.streaming.runtime.tasks.StreamTask.<init>(StreamTask.java:290) at org.apache.flink.streaming.runtime.tasks.SourceStreamTask
浏览 94提问于2021-01-29得票数 3
be loaded.at org.apache.flink.formats.avro.AvroInputFormat.open:54)at org.
浏览 207提问于2018-02-14得票数 7
1回答
我正在尝试创建带有芹菜任务的django apache服务器并使用rabbitmq作为message brooker的文件。我的问题是芹菜和兔子没有联系。我得到了那个错误：RUN DEBIAN_FRONTEND=nonint
浏览 1提问于2021-02-18得票数 3
云服务器
ICP备案
实时音视频
云直播
对象存储
腾讯云开发者
