在Flink WordCount计算中，何时调用sum计数？Flink源代码中的实现在哪里？
浏览 15提问于2019-02-28得票数 0
我能够在远程hdfs集群中的文件上运行示例wordcount.jar，而无需在flink中声明fs.hdfs.hadoopconf变量。flink-cluster.vm ~]$ /opt/flink/bin/flink run /opt/flink/examp
浏览 2提问于2016-07-13得票数 3
回答已采纳
我正在寻找一个长期运行流处理的Flink示例工作用于测试目的。我检查了Flink项目中包含的流/字数，但它似乎运行时间不长，在处理输入文件后，它退出了。 我需要自己写一个吗？获得无休止流输入的最简单方法是什么？
浏览 11提问于2019-10-17得票数 1
回答已采纳
1回答
我是弗林克的新手。在我的计算机上运行本地集群时遇到了问题。此外，当我运行Flink示例时，会出现异常：Starting cluster./bin/flink run examples/streaming/WordCount.jar
Executing WordCount</em
浏览 7提问于2021-05-31得票数 1
回答已采纳
我已经在flink集群中上传了jar文件。我使用的是flink 1.6.0address "http://localhost:8081" 0 uploaded 1537174925000 0
name
浏览 0提问于2018-09-17得票数 0
回答已采纳
我使用Maven在CentOS服务器中管理我的自定义Flink应用程序。我是Java的初学者。WordCount修改了文件StreamingJob.java。据我所知，我应该得到两个jar文件，一个用于BatchJob.java，另一个用于StreamingJob.java (以WordCount为例)。但是，在执行命令mvn clean package之后，我得到了myflink-1.jar和original-myflink-1.jar。我搞不清楚它们是什么<
浏览 8提问于2020-05-27得票数 0
回答已采纳
我一直在尝试从以前的检查点重新启动Apache Flink，但没有太多运气。我已经将代码上传到GitHub，下面是主类：https://github.com/edu05/wordcount/blob/restart/src/main/java/edu/streaming/AppWithKafka.java这是一个简单的字数统计程序，只是我希望程序在重新启动后继续它已经<
浏览 10提问于2019-04-22得票数 0
1回答
我正在尝试通过NAT运行Flink集群，其中通告的端口将不同于绑定端口。 在Flink中有对此的支持吗？ 我查看了配置和源代码，但没有注意到支持NAT的任何提示。如果没有，推荐的实现方法是什么？
浏览 23提问于2020-01-26得票数 0
回答已采纳
1回答
如何在jvm之间分发代码
、、、
一些分布式计算引擎，如Spark或Flink，能够在计算机和jvm之间分发代码，例如(在scala中使用spark)：另外，如果有人能给我指出一些现有的分布式计算框架(如Spark/Flink )中与此问题相关的源代码(类)，我将不胜感激
浏览 4提问于2018-04-03得票数 2
我几乎没有读过关于Flink的文章，当我在Flink上读博客的时候，我看到了短语“最多有60秒的服务延迟(事件不正常，最多1分钟) "。定义无序事件持续时间是否用于Flink中的“水印”技术，如果没有，内部用途是什么？
浏览 1提问于2016-05-26得票数 0
我在Flink中使用keyBy()按特定属性(国家)对这些值进行分组，因此对于每个不同的国家，我都有一组不同的元组(层)。我计算数据流中每个组(层)的均值和方差，并返回每个层的数量均值/方差(μ/σ)。在我的Flink程序中，当我的算法运行时，我需要将这个量的所有最后值(均值/方差)相加，即来自每一层的最新值。换句话说，如果从每一层得
浏览 3提问于2020-02-19得票数 0
我正试图在我的Windows 11计算机上运行本地Flink集群。我按照推荐文档的步骤安装了Java和Cygwin。Flink似乎从start-cluster.sh脚本开始很好，但是我无法连接到WebUI。在Windows上部署Flink v1.14.3的推荐方法是什么？
浏览 1提问于2022-01-26得票数 0
我是flink的新手。在使用java进行flink编程的过程中，我多次注意到它有时被声明为StreamExecutionEnvironment，有时被声明为ExecutionEnvironment。这两个类的主要区别是什么。什么时候用什么。
浏览 367提问于2021-06-27得票数 0
如果我想在本地运行一个Flink应用程序，直接从Intellij内部运行，但我需要指定配置params (比如fs.hdfs.hdfssite来设置S3访问)，那么除了ExecutionEnvironment.createLocalEnvironment我可以在我的项目中有一个Flink配置并指向本地应用程序吗？
这样做合适吗？或者，您会设置IDE将应用程序提交到真正的本地Flink实例吗？
浏览 3提问于2016-06-10得票数 8
回答已采纳
1回答
我的wordcount程序给出了所需的输出文件，其中包含所有单词及其出现的次数。现在，我必须附加这段代码来支持查询，这样，当我输入一个特定的单词时，它就会输出相应的文件名& wordcount程序的输出应该是要查询的输入。我得到这些错误--在sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)，在</
浏览 2提问于2012-02-09得票数 0
回答已采纳
我想通过Flink来计算卡夫卡的数据，但问题是卡夫卡中的杰森数据可能是变异的。"name"}}{"data"{"type":"type1","props":"props","strem":"stream1"}st
浏览 0提问于2018-08-02得票数 0
回答已采纳
在我的工作流程中，我使用pyflink从RDS加载和转换数据，并将其存入MYSQL。使用FLINK CDC，我能够从RDS获得我想要的数据，并使用JDBC库汇到MYSQL。我的目标是读取一个表，并使用下面的代码示例创建另外10个表，在一个作业中(基本上将一个巨大的表分成较小的表)。我面临的问题是，尽管在flink cdc中使用RocksDB作为状态后端和选项，如scan.incremental.sn
浏览 30提问于2021-11-24得票数 0
我正在编写一个简单的程序来计算文本的可读性，在计算平均值时，我得到了一个奇怪的结果："-nan“。这是我的代码底部的两个浮点计算函数返回的结果，当我在main函数中计算索引时，我得到了一个负数。这应该是不可能的，因为被除的数字都不是负数。有人知道-nan是什么意思吗?或者我怎么解决这个问题？ 谢谢!);
float a
浏览 25提问于2020-04-07得票数 1
回答已采纳
我正在使用Flink来处理来自某些数据源(如Kafka、Pravega等)的数据。
在我的例子中，数据源是Pravega，它为我提供了一个flink连接器。我使用了FlinkPravegaReader和一个正确的反序列化器来获取来自Pravega的JSON流。org.apache.flink.api.common.operators.Keys$ExpressionKeys.我不是Flink专家所以我不知道为什么。我已经阅读了官方示例<
浏览 0提问于2020-06-03得票数 0
回答已采纳
1回答
流在Hadoop中的应用
、、、、
我正在尝试学习的例子。在这个例子中，我确实看到他们创建了一个单独的应用程序(类似于流应用程序)，该应用程序生成和消费数据，并在数据上应用模式匹配。他们现在还没有在.Till(如卡夫卡)之间放置一个流层，单应用程序就足以满足这一目的，这使得它非常优化。现在，我知道，如果我使用Kafka，那么我需要两个应用程序；一个用于将数据摄取到Kafka主题中，另一个用于消费Kafka主题的数据。什么时候?在哪里需要流？？
参考Flink CEP的例子，我想知道流层(如Kafka&
浏览 2提问于2016-06-13得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
