备案控制台

开发者社区

开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

【百问百答】flink全知道系列5

flink 相关问题整理如下。可以Ctrl+F检索关键词进行查找，本合集持续更新中，记得关注、收藏哦

Flink sql 主动使数据延时一段时间有什么方案？

Flink SQL 关键字 user

flink1.10 定义表时，把json数组声明成STRING类型的，查询出来是空？

Flink的shuffle mode，在应用里面可以设置么?

Flink job不定期就会重启，版本是1.9，怎么回事？

flink1.9读取阿里Mq问题？

table execution-options 能否通过 -yd 生效

flink1.10在通过TableFunction实现行转列时，Row一直是空？

rocksdb的block cache usage应该如何使用？

kafkaf To mysql 写入问题？

flink job 跑一段时间 watermark 不推进的问题

flink1.11 Application 模式下启动失败问题

flink sqlUpdate,如何获取里面的字段，字段类型，with 等3个属性

flink 1.11 executeSql查询kafka表print没有输出

flink1.9写权限认证的es6

flink state问题

[sql-client] 通过sql-client提交sql怎么设置checkpointing.interval

flink1.11 set yarn slots failed

Flink-1.11内置connector测试问题求解

flink 1.11 upsert结果出错

flink1.11 sql kafka 抽取事件时间

flink sql 1.10 insert into tb select 复杂schema 失败

Flink1.10 flinksql 多表join状态ttl不成功的问题

TableEnvironment 里面无法执行 Hop等窗口函数

滑动窗口数据存储多份问题

flink 双流join报错，java.lang.AssertionError

自定义的sql connector在sql-cli中运行问题

flink-1.11 DDL 设置chk目录问题

flink1.11.0读取mysql数据decimal类型会强转成decimal(38,18)的问题

flink cep 如何处理超时事件？

flink 1.11运算结果存mysql出错

如何在sql运行时动态修改kafka的scan.startup.mode

flink-1.11使用executeSql()执行DDL语句问题

flink-benchmarks使用求助

代码中如何取消正在运行的Flink Streaming作业

State 0点清除的问题

flink1.9状态及作业迁移

Flink SQL处理Array型的JSON

flink 同时sink hbase和hive，hbase少记录

【Flink Join内存问题】

flink 1.11 createTemporaryTable 指定 rowtime 字段报 Field null does not exist 错误

单流的一条数据，需要先sink 至mysql，再sink至kafka，并保证两sink的原子性以及sink顺序，是否可以做到？

flink sql报错 Could not find any factory for identifier 'kafka

使用Flink Array Field Type

flink 1.11 es未定义pk的sink问题

pyflink问题求助

flink使用debezium-json format报错

Flink es7 connector认证问题

flink sql 侧输出

flink 1.11 sql作业提交JM报错

flink 1.11 local execution oom问题

flink1.10.1 flink sql消费kafka当parallelism大于1时不产生watermark

flink sql连接HBase报错

作业从flink1.9.0迁移到1.10.1

pyflink udf中发送rest api会导致udf被调用两次

flink1.10升级到flink1.11 提交到yarn失败

Flink DataStream 统计UV问题

flink时间窗口

kafka connector问题

DataStream统计uv问题

Flink SQL如何将多个表的查询结果(列不同)聚合成一张表

一个source多个sink的同步问题

Flink SQL复杂JSON解析

State里面用guava Cache

如何在Flink SQL中使用周期性水印?

flink 1.11 on kubernetes 构建失败

如何在窗口关闭的时候清除状态

flink 1.11 中cdc功能中，使用flink sql来操作一个kafka topic中的多张表，并保证有序？

flink 1.11 connector jdbc 依赖解析失败

求助：FLINKSQL1.10实时统计累计UV

flink 1.11 作业执行异常

FlinkKafkaProducer没有写入多个topic的功能

flink 1.10.1 入 hive 格式为parquet

作业升级到flink1.11，idea运行失败

嵌套 json 中string 数组的解析异常

【Flink的shuffle mode】

Flink 1.11 SQL作业中调用UDTF 出现“No match found for function signature ”异常……

flink sql 读写写kafka表的时候可以指定消息的key吗

DataStream的state问题

关于jdbc connector扩展问题

Flink从SavePoint启动任务，修改的代码不生效

Flink状态调试

Flink sql 主动使数据延时一段时间有什么方案

Flink SQL 关键字 user？

flink1.10 定义表时，把json数组声明成STRING类型的，查询出来是空

flink1.10在通过TableFunction实现行转列时，Row一直是空

作业因为异常restart后，频繁OOM

Flink job不定期就会重启，版本是1.9

flink1.9读取阿里Mq问题

flink 1.10 kafka collector topic 配置pattern

kafkaf To mysql 写入问题

rocksdb的block cache usage应该如何使用

flink对task分配slot问题

做实时数仓，sql怎么保证分topic区有序

flink任务提交方式

flink的state过期设置

UDTAGGs sql的查询怎么写

想请教下MaxDirectMemorySize的大小有必要设置这么大吗？

StreamTableEnvironment.registerDatastream()

‘=-yD Kerberos 认证问题

Flink1.9批任务yn和ys对任务的影响

source并行度不同导致任务没有数据落地

Flink 1.9 SQL Kafka Connector，Json format，how to deal with not json message?

Flink实现Kafka到Mysql的 End-To-End Exactly-Once中遇到的问题

Rewind offset to a previous position and ensure certainty.

关于 FLink historyserver没有completed-jobs的问题

展开

收起

开发者小助手 2021-12-27 17:30:03 3235 0

0 条回答

写回答

取消提交回答

问答分类：

流计算实时计算 Flink版云消息队列 MQ 云数据库 RDS MySQL 版实时数仓 Hologres 云数据库HBase版容器服务Kubernetes版云消息队列 Kafka 版云解析DNS

问答标签：

实时计算 Flink版全知道系列

问答地址：

开发者社区 > 大数据与机器学习 > 实时计算 Flink > 问答

相关产品：

实时计算 Flink版

版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

相关问答

实时计算 Flink版

【百问百答】flink全知道系列4

2511

0

0

【百问百答】flink全知道系列3

2887

0

0

【百问百答】flink全知道系列2

3807

0

0

【百问百答】flink全知道系列1

4624

0

0

各位大佬，请教一下，如果在flink cdc sql客户端使用SQL查询表，怎么能记录原系统的数据

1850

1

0

那cdc最新版支持到flink的哪个版本，flink1.15还有guava兼容性问题吗？

963

0

0

flink cdc(mysql) -> elasticsearch7, 任务每次持续跑了一段时间之后

927

2

0

各位大佬，请教个问题，使用flink cdc读取数据时，如果配置一个表，数据过滤是发生在server

1704

3

0

flink cdc 怎么做断点续传啊

5679

6

0

我使用flink cdc StartupOptions.latest() 采最新的日志。要是程序挂了

1212

5

0

大数据与机器学习

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。

我要提问

相关产品

实时计算 Flink版

文档详情产品详情

热门讨论

热门文章

flinkcdc3.0整库同步mysql的数据到starrocks中全量能过去增量过不去怎么排查？

FlinkCDC MySQL 中 scan.startup.mode 用的是什么模式啊？

哪位大佬有遇到过Flink这个问题呢？同步pg的时候，是不是类冲突了，所以导致抓不到这个类？

Flink-CDC 文档网站地址是什么？

Flink1.17为什么需要JDK 11呢？JDK8我试了也能运行

使用Flink CDC，生产环境要申请的服务器如何评估

flink cdc，读取datetime类型，全都变成了时间戳，怎么解决？下游是可以解决。但是我想知

flink1.15启动后无法访问webui的问题有人遇到过吗

flink 1.18必须配套JDK11吗 1.8是不是不行了呢？

FlinkCDC同步Oracle的月表数据如何用一个job同步

展开全部

Flink+Paimon+Hologres 构建实时湖仓数据分析

OPPO数据中台之基石：基于Flink SQL构建实数据仓库

Flume+Kafka+Flink+Redis构建大数据实时处理系统：实时统计网站PV、UV展示

如何在 PyFlink 1.10 中自定义 Python UDF？

Flink SQL 功能解密系列 —— 数据去重的技巧和思考

使用 Kafka 和 Flink 构建实时数据处理系统

超燃！Apache Flink 全球顶级盛会强势来袭

Apache Flink 进阶（一）：Runtime 核心机制剖析

Flink on YARN（下）：常见问题与排查思路

Flink 1.9 实战：使用 SQL 读取 Kafka 并写入 MySQL

展开全部

相关课程

更多

大数据Flink实时旅游平台环境篇 2020版

582

29

去学习

Apache Flink 入门到实战 - Flink开源社区出品

1392

16

去学习

实时计算 Flink 版产品入门与实操

3806

10

去学习

开源 Flink 极速上手教程

1752

7

去学习

大数据实时计算框架Spark快速入门

778

93

去学习

Apache Flink 入门

4826

9

去学习

相关电子书

更多

Flink CDC Meetup PPT - 龚中强 立即下载

Flink CDC Meetup PPT - 王赫 立即下载

Flink CDC Meetup PPT - 覃立辉 立即下载

相关实验场景

更多