问答 2023-10-03 来自:开发者社区

Flink CDC中doris的符合分区,可以 时间range + 类型list 组合分区吗?

Flink CDC中doris的符合分区,可以 时间range + 类型list 组合分区吗,我尝试过 报错,看官网例子比较多的是 时间range分区 ,类型list 分桶?

问答 2023-08-29 来自:开发者社区

Flink CDC 只能通过yarn application list 找到?

Flink CDC 只能通过yarn application list 找到 applicationid 找不到进程id?

问答 2022-12-26 来自:开发者社区

flink sql 中有类似 collect_list ,collect_set 这样的函数吗?

flink sql 中有类似 collect_list ,collect_set 这样的函数吗?

问答 2022-09-27 来自:开发者社区

flink 消费topic list 是咋消费的 一个一个来吗

flink 消费topic list 是咋消费的 一个一个来吗

问答 2022-07-22 来自:开发者社区

flink list -a yarn-cluster模式怎么使用呢 直接写会报超时

flink list -a yarn-cluster模式怎么使用呢 直接写会报超时

问答 2021-12-03 来自:开发者社区

要如何设置,List才可以识别成为Flink可序列化的类呢?

hi,咨询一个问题,我们在定义实体的时候,如果属性中使用了List,就会被识别成 generic type。这个要如何设置,才可以识别成为Flink可序列化的类,而不是使用kyro。 class pojo{ String name; List someList; } 在flink-core中存在ListSerializer,可是不知道要如何使用。*来自志愿者整理的FLINK邮件归档

问答 2020-07-17 来自:开发者社区

你们flinksql 处理kafka的json格式,如果其中一个字段是这样的:"list#Flink

你们flinksql 处理kafka的json格式,如果其中一个字段是这样的:"list_datas":"[{"bid":0.0,"gameId":"167074","itemType":"AndroidGame","passthrough":"b77d914cc1b14efeb8dc1429630fa8bc","pos":1,"secondPrice":0.0}]",你们flinkt建表的时候....

问答 2020-06-03 来自:开发者社区

Flink stream如何buffer一批数据,我想放20条数据到list,就是我需 #Flink

Flink stream如何buffer一批数据,我想放20条数据到list,就是我需要从stream流中buffer一批数据,放到一个list中,批量写入kafka,这样就相当于将20条数据一次性写入kafka #Flink

问答 2018-12-13 来自:开发者社区

使用Flink为DateStreamSource <List <T >>分配水印的正确方法

我有一个持续的JSONArray数据产生到Kafka主题,我想处理具有EventTime特征的记录。为了达到这个目标,我必须为包含在JSONArray中的每个记录分配水印。 我没有找到实现这一目标的便捷方法。我的解决方案是使用DataStreamSource>中的数据,然后迭代List并使用匿名ProcessFunction将Object收集到下游,最后为此下游分配水印。 主要代码如下: D...

问答 2018-11-22 来自:开发者社区

Flink提交任务到yarn-cluster模式时,flink list执行超时,获取不到JobManager信息。定位到问题原因与HA有关,有没有哪位大神遇到过类似问题

Flink提交任务到yarn-cluster模式时,flink list执行超时,获取不到JobManager信息。定位到问题原因与HA有关,有没有哪位大神遇到过类似问题

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等

登录插画

登录以查看您的控制台资源

管理云资源
状态一览
快捷访问