已有1人关注此标签
Flink idea启动WEBSERVER问题
作者： 冷丰
455人浏览
2人回答
环境: win10, idea2016, FLink1.7.1maven已经导入 <dependency> <groupId>org.apache.flink</groupId>…
初学者安装LNMP，提示Failed to start php-fpm.service: Unit is not loaded properly
作者： mings丶
898人浏览
3人回答
查看相关文档。文档地址（https://help.aliyun.com/document_detail/97251.html?spm=a2c4g.11186623.6.890.4c087377CLroNl）搭建LNMP 到 5.启动PHP…
如何在两个数组列中查找公共元素？
作者： 社区小助手
300人浏览
2人回答
我有两个以逗号分隔的字符串列（sourceAuthors和targetAuthors）。 val df = Seq( ("Author1,Author2,Author3","Author2,Author3,Author1")).toDF…
RichAllWindowFunction的open方法在什么时候被触发
作者： 乌野
419人浏览
1人回答
如题 还有, 自定义的RichAllWindowFunction应该怎样使用才能触发open方法. var filteredstream = inputStream .flatMap(buildHbaseMsg(_)) .filter…
[@徐雷frank][¥20]centos7设置mysql自启动的配置文件中[Service] User=mysql Group=mysql，user和group这边的mysql是指的什么？centos的登录用户名？
作者： 晓生寒
393人浏览
1人回答
centos7设置mysql自启动的配置文件中 [Unit]Description=MySQL ServerDocumentation=man:mysqld(8)Documentation=http://dev.mysql.com/doc…
Flink - 如何在多个任务槽中聚合和查询富接收器功能状态
作者： flink小助手
411人浏览
1人回答
我实现了一个rich sink函数，它根据调用的对象执行一些网络调用。我希望能够计算这些事件的一些元数据，这些事件由事件中包含的某些上下文信息（事件的batchID）键入，并将此元数据公开给外部系统。 例如，事件如下所示： case cl…
了解Flink - 任务不可序列化
作者： flink小助手
444人浏览
1人回答
我正在研究一个Flink项目，并遇到了一个问题，我在Stackoverflow的帮助下设法解决了这个问题。但是，我不清楚为什么提出的解决方案实际可行，我发现有关该主题的信息很少。请考虑以下代码： object DeCP { def ma…
Flink：如何持久化并恢复ValueState
作者： flink小助手
866人浏览
1人回答
我使用Flink来丰富输入流 case class Input( key: String, message: String )预先计算得分 case class Score( key: String, score: Int )并产生一个输…
如何在时间窗口内获取最新值
作者： flink小助手
279人浏览
1人回答
这就是我的流数据： time id group 1 a1 b1 2 a1 b2 3 a1 b3 4 a2 b3 在我们的窗口中考虑上面的所有示例 我的用例获取最新的独特ID。 我需要输出如下： time i…
RichParallelSourceFunction中的水印
作者： flink小助手
366人浏览
1人回答
我正在实现一个SourceFunction，它从数据库中读取数据。如果停止或压碎（即保存点和检查点），数据只能处理一次，则应该能够恢复该作业。 到目前为止我所拥有的： @SerialVersionUID(1L)class JDBCSour…
阿里云实时计算 Flink是如何计量和收费？
作者： 李博 bluemind
499人浏览
2人回答
实时计算 Flink的基本计量单位为CU(Compute Unit），即计算资源。一个CU对应于实时计算底层系统是一个CPU的计算能力。实时计算底层使用虚拟化技术进行资源隔离，保证一个基本的CU消费且最大消费仅能为一个CPU的计算能力。 …
批量安装centos7.5时DHCP服务起不来
作者： 酷谷马
881人浏览
2人回答
报错提示如下：[root@server dhcp]# systemctl restart dhcpd.serviceJob for dhcpd.service failed because the control process exit…
cloud-init一直出错是为什么？
作者： leohuang2018
908人浏览
1人回答
出错信息如下所示: UNIT LOAD ACTIVE SUB DESCRIPTION● cloud-init-local.service loaded failed failed …
