RapidMiner Studio Spark集群连接问题

skalogerskaloger 成员职位:1新手
2020年9月编辑 在帮助
嗨，我目前正在使用RapidMiner Studio来帮助我设计我的流工作流程。我有一个关于火花连接器的问题。我想要实现的是设计一个简单的工作流程，并将其上传到我的本地火花集群。我的工作流由一个spark连接器(检索)和一个Streaming Nest(包含一个Kafka Source，一个aggregate和一个sink)组成。我已经设法使用flink连接器执行相同的工作流，将其上传到flink集群，并使用我的kafka源和sink执行一些测试。所以工作流程的其余部分肯定是正常工作的。我假设我的问题是我的连接的配置设置，所以我希望如果可能的话，指导我完成与本地spark集群执行成功连接所需的步骤和所有配置。请注意，在我执行了所有配置测试之后，“测试连接”字段显示连接成功，这在我的情况下似乎不正确。

< ?xml version="1.0" encoding="UTF-8"?><进程版本="9.7.002">      <参数key="logverbosity" value="init"/> <参数key="random_seed" value="2001"/> <参数key="send_mail" value="never"/> <参数key="notification_email" value="30"/> <参数key="encoding" value="SYSTEM"/> <进程expanded="true">  <       <

标记:

最佳答案

    登录或注册置评。