我有一个小的Flink应用程序： public class App { out.collect(value.toUpperCase());} 我希望它能输出类似如下的内容： 18> ABC
18> $123 但是，它只<e
浏览 15提问于2020-09-13得票数 1
Apache与Hadoop上的Mapreduce相比如何？在哪些方面更好，为什么呢？
浏览 9提问于2015-04-28得票数 14
回答已采纳
我试图用Flink编写一个计算，它需要两个阶段。在第一个阶段，我创建一个图并获取它的顶点ids：在第二阶段，我希望使用这些ids来运行每个顶点的SingleSourceShortestPath/bin/flink run ...的命令行中)，但是当我使用它的WebUI在Fli
浏览 6提问于2017-11-28得票数 0
回答已采纳
1回答
对我来说，很难理解Flink中的流表。我可以理解Hive，将一个固定的静态数据文件映射到一个“表”，但是如何体现一个建立在流数据之上的表呢？例如，每1秒就有5个具有相同结构的事件被发送到Kafka流：{"num":2, "value": "b"}
浏览 2提问于2020-10-29得票数 0
回答已采纳
我在我的应用程序中使用flink作为流处理器，我想将结果转储到位于远程服务器上的apache ignite中。在ignite.xml的TcpDiscoverySpi部分，我指定了ignite服务器的ip地址；但是，到服务器的任何连接都不会稳定。</property>
</bean>
浏览 41提问于2021-03-12得票数 0
回答已采纳
我从官方的flink存储库使用以下docker-compose.yml启动了flink。我只添加了到外部hadoop网络的连接。import org.apache.flink.api.scala._import stoff.schnaps.pojo.ActorMovieBatch Scala API Skeleton")} 它只是将一个tsv文件从hdfs读取到pojos的DataSet
浏览 1293提问于2019-01-04得票数 2
回答已采纳
我正在运行Apache版本1.12.7，并将流式执行环境配置为任务管理器=3(只是试验)的任务槽数，但无法看到环境读取的文件的输出。相反，正如在日志中所看到的，执行图按计划被卡住了，没有进入运行状态。注意，如果在属性文件中没有传递任何配置，那么一切都会正常工作，并且由于执行图形切换到运行状态，所以输出被看作是能够读取文件的环境。otherwise everything works
浏览 13提问于2022-10-23得票数 0
故事是，我们有一个由Tomcat + Apache托管的webapp作为前端。webapp需要额外长的时间来处理某些REST请求(对数据库的查询时间很长，然后在获得数据库响应后生成一个摘要)。在当前实现下，即使REST客户端停止请求，也仍在处理查询，直到数据库查询完成，响应被发送回并发现输出流已关闭。另一方面，we应用程序不会在很长时间内发回任何内容，导致Apache会话超时(我们将5分钟配置为超时
浏览 0提问于2017-09-11得票数 1
我正在研究ETL工具(比如Talend)，并研究是否可以使用Apache。Nifi能否用于执行以下操作：
看
浏览 15提问于2017-03-20得票数 5
回答已采纳
1回答
我正在flink集群上运行一个流束作业，在那里我得到了以下异常。我正在使用Spotify的scio在Scala中编写这项工作。))
.toSinkTap(sink) 从异常中，我可以看到源路径和输出路径应该具有相同的URI方案，但是我不知道这是如何发生的，因为我使用了一个alluxio路径作为输出目录。在alluxio输出目录中创建了一些临时目录，但在
浏览 24提问于2020-09-01得票数 0
我的代码是1mvn清洁3 3run所以我需要在$FLINK_HOME/log/*..out中查找结果。
有办法收集这些结果并打印在intellij的控制台窗口中吗？谢
浏览 1提问于2020-09-28得票数 0
回答已采纳
我使用getSideOutput创建了一个端输出流，在使用getSideOutput处理之前，预处理流中存在元素，但当调用getSideOutput方法时，不会发出任何元素。System.out.println(value); // nothing detect elements }); ExtractList如下所示 import org.apache.flink<
浏览 36提问于2020-08-04得票数 0
回答已采纳
我在KSQL中有一个蒸汽和一个表，如下所述：表名: EXPENSE_TABLE这是预期的产出吗。TD.EXPENSE_CODE = TE.EXPENSE_CODE查询的输出如下所示
浏览 0提问于2018-04-25得票数 2
回答已采纳
我们正在尝试实现下面描述的用例，我们有我们希望克服的实现问题，我们正在尝试通过匹配两个流的消息中存在的关键字(JSON)来在两个Kafka主题之间进行KStream连接。此外，我们应该维护消息序列，因为它是从源文件到达KStream的。
场景是，如果匹配的键还没有到达任何一个流，我们应该停止或重试join，直到预期的键到达其他主题。我们想把不匹配的记录放回KStream，
浏览 2提问于2019-05-08得票数 2
这是一个简单的、普通的Kafka应用程序，它执行使用EXACTLY_ONCE_V2配置的简单记录转换。如果删除上面提到的EXACTLY_ONCE_V2设置，此错误将消失，流应用程序将运行数天而不会出现错误。线程id-mapping-app-1eede139-ace6-4aff-9e94-ca508cb9c98d-StreamThread-1任务_11错误，发送记录到主题数据-记录-输出的任务0_11，因为不会记录书面
浏览 29提问于2021-11-27得票数 5
回答已采纳
我正在尝试使用Apache NIFI中的SelectHiveQL处理器执行select操作。输出格式应为'CSV‘。select name, surname, birth_place from persons
假设我们没有person_1的</em
浏览 0提问于2021-05-12得票数 0
1回答
当客户端在操作完成之前超时或断开与服务器的连接时，服务器将一直运行该操作，直到操作完成为止。我希望让服务器检测客户端断开连接的时间，并相应地处理它。是否有一种方法可以检测客户端何时使用Apache断开连接？那么使用其他Java web服务栈呢？
浏览 6提问于2008-09-07得票数 7
我使用执行WordCount。它的文件大小为10 of。at org.apache.flink.api.scala.FlinkShell.main(FlinkShell.scala)
org.apache.flink<
浏览 0提问于2015-10-27得票数 2
回答已采纳
我已经创建了一个日期工作流，如下所示: GenerateFlowFile --> Custom Processor --> LogAttribute我的自定义处理器有一个属性作为start NiFi。但每次计划的运行中的开始日期应根据上次运行的最大结束日期进行更改。基本上是从服务器获取增量数据。
您能帮助一下，如何在Apache NiFi中实现这一点？
浏览 1提问于2017-04-14得票数 1
出于不同的原因，我们需要手动从检查点读取数据(假设我们需要更改状态对象/类结构，因此我们希望读取还原数据并将数据复制到新类型的对象中)，但是，当我们读取所有内容时，当我们希望将其保存/存储在内存中并部署到flink集群时，就会得到空的list/map。在日志中，我们看到我们正在正确地读取和添加所有数据到list/map，但是一旦我们的方法完成了它的工作，我们丢失了数据，list
浏览 3提问于2022-06-04得票数 0
回答已采纳
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
