1. 云栖社区>
  2. 全部标签>
  3. #flink#
flink

#flink#

已有49人关注此标签

内容分类:
博客 | 问答 | 视频 | 资料 |

flink写hive表有什么好的建议?

转自钉钉群21789141:flink 写 hive 表 有什么好的建议?

大数据 钉钉 Hive 流计算 flink 实时计算

blink中hive维表的支持,并支持定时的load外部数据

业务中维表主要存储在Hive中,维表的支持要实现lookuptablefunction,但是blink本身的hivetablesource并没有实现该接口,且不支持定时Load数据,请问自己要怎么实现

Hive 存储 flink

Aapche flink:PythonAPI实现流式计算无法引入三方模块

想利用flink提供的PythonAPI实现流式计算,碰到下面无法导入三方包的问题.通过flink安装包提供的shell命令执行Python脚本无法引用三方模块 ,但通过Python命令进入可以引入kafka模块./bin/pyflink…

python Apache 模块 reduce 流式计算 API 脚本 class input flink

flink 类型转换,scala 继承map接口后,报java.lang.ClassCastException

类型: case class RIchMap(data:Map[String,Any] = Map()) extends Map[String, Any] with GenMap[String, Any] with Serializabl…

云栖社区 大数据 java Apache runtime scala API string list thread flink

flink的checkpoint提交超时问题

任务一开始正常,跑一两天后就会checkpoint超时,收不到Latest Acknowledgement,然后用同样的包重启又可以正常跑几天如此反复,一直找不到原因。设置项如下: final StreamExecutionEnv…

大数据 flink

请问 Flink滑动时间窗口数量撑爆,解决思路?

比如需要处理每15秒窗口数据,每1毫秒滑动一次,通过底层创建窗口源码看到会创建15000个窗口,在这个窗口数量级的情况下数据的处理是非常慢的,需求是例如,每15秒数据值达到阈值做处理,因为每1秒的数据就会有几十万起,请问这种处理应该怎么处理…

源码 flink

Flink idea启动WEBSERVER问题

环境: win10, idea2016, FLink1.7.1maven已经导入 <dependency> <groupId>org.apache.flink</groupId>…

Apache API string class source thread WebServer IDEA unit flink

Flink keyby之后再keyBy

各位大神,对keyBy完的结果 Reduce完之后,再次进行不同Key的keyBy,是只对之前keyBy的结果再次进行分组还是 对全局进行分组呢,

reduce flink

flink1.7.1 dataStream table API 的 distinc问题

tenv.registerDataStream("data", dataStream, 'a, 'b, 'c, 'time.rowtime) import org.apache.flink.table.api.scala._ …

Apache Image scala API class flink

flinkstream的checkpoint是要同步到hdfs中的,如果没有hdfs是不是会导致无法checkpoint?

转自钉钉群21789141:flinkstream的checkpoint是要同步到hdfs中的,如果没有hdfs是不是会导致无法checkpoint?

hdfs 钉钉 同步 flink

flink的时间窗口怎么写?

转自钉钉群21789141:flink的时间窗口怎么写.window(TumblingEventTimeWindows.of(Time.seconds(5)))算子直接这样写就行了么?里面的多道流数据处理写在哪啊?

钉钉 flink 流数据

请问一下 Flink做批处理一般用什么调度工具比较好

转自钉钉群21789141:请问一下 Flink做批处理一般用什么调度工具比较好

钉钉 flink

请问,flink写hdfs目前支持exactly once么?

转自钉钉群21789141:请问,flink写hdfs目前支持exactly once么?

hdfs 钉钉 flink

请问下 为什么 1.6.1版本为什么不能这样order by呢 ?

转自钉钉群21789141:请问下 为什么 1.6.1版本为什么不能这样order by呢 ?

大数据 Image 钉钉 flink 实时计算

有大佬知道 blink 共享模式 只能强制写sql 吗

转自钉钉群21789141:有大佬知道 blink 共享模式 只能强制写sql 吗

SQL 钉钉 Blink flink

各位大神,问一个入门问题: 我在flatMap算子里放了一个状态,我需要在sink中拿出来看这个状态,但是发现是null,请问这个是什么原因? 用的是同一个ValueStateDescriptor

转自钉钉群21789141:我在flatMap算子里放了一个状态,我需要在sink中拿出来看这个状态,但是发现是null,请问这个是什么原因? 用的是同一个ValueStateDescriptor,状态存储,用的是:FsStateBack…

钉钉 flink

flink standalone yarn的区别是什么

转自钉钉群21789141:flink standalone yarn的区别是什么

大数据 钉钉 流计算 flink 实时计算

大神们,问一下怎么在yarn上提交程序到flink集群上,yarn客户端和flnk的masters不在同一台机器上,yarn提交的时候怎么知道是提交到指定的flink集群上,需要在哪配置一下吗?

转自钉钉群21789141:大神们,问一下怎么在yarn上提交程序到flink集群上,yarn客户端和flnk的masters不在同一台机器上,yarn提交的时候怎么知道是提交到指定的flink集群上,需要在哪配置一下吗?

大数据 配置 集群 钉钉 流计算 flink 实时计算

大神们,有没有flink on yarn比较完整的环境搭建参考啊,我搭个测试集群Standalone都可以起来,但on yarn就不行

转自钉钉群21789141:大神们,有没有flink on yarn比较完整的环境搭建参考啊,我搭个测试集群Standalone都可以起来,但on yarn就不行

大数据 集群 测试 钉钉 flink 实时计算

flink中如何实现,只统计一天的pv,到凌晨00:00的时候置为0,再进行统计

flink中如何实现,只统计一天的pv,到凌晨00:00的时候置为0,再进行统计

flink

上一页 1 ... 4 5 6 7 8 ... 30 下一页
30
GO