flink 相关问题整理如下。可以Ctrl+F检索关键词进行查找，本合集持续更新中，记得关注、收藏哦
flink 1.11 rest api saveppoint接口 异常
flink1.11 可以使用processtime开窗，但是无法使用eventtime开窗
flink1.11 sql 发布到yarn session时找不到hbase相关的类
flink on yarn 读取 hbase数据时 ，Task失败，具体描述如下
flink-1.11 hive-1.2.1 ddl 无法写入数据
Flink SQL 解析复杂（嵌套）JSON的问题 以及写入到hive类型映射问题
flink1.11.0 执行sqlQuery时报NullPointException
Could not find any factory for identifier 'kafka'
【flink sql】flink sql insert into插入语句的问题
自定义metr自定义metrics reporter 如何不通过flink conf来注册并生效ics reporter 如何不通过flink conf来注册并生效
flink sql 1.11 kafka source with子句使用新参数，下游消费不到数据
flink 1.9.2 升级 1.10.0 任务失败不能从checkpoint恢复
flink 1.11 使用sql写入hdfs无法自动提交分区
flink 1.11 on kubernetes 构建失败…
关于1.11Flink SQL 全新API设计的一些问题，请指教
flink-1.11 ddl kafka-to-hive问题
flink 1.11 cdc: kafka中存了canal-json格式的多张表信息，需要按表解析做处理，sink至不同的下游，要怎么支持？
flink 1.11 on k8s native session cluster模式报找不到configmap
flink1.11 pyflink stream job 退出
Flink整合hive之后，通过flink创建的表，hive beeline可见表，不可见字段？
Flink on k8s 中，Jar 任务 avatica-core 依赖和 flink-table jar 冲突问题
flink-1.11 KafkaDynamicTableSouce groupBy 结果怎样发送到 kafka
flink-1.11 ddl 写入json 格式数据到hdfs问题
[sql-client] 通过sql-client提交sql怎么设置checkpointing.interval
flink1.11 set yarn slots failed？
flink1.11 sql kafka 抽取事件时间，有没有好的方式
自定义的sql connector在sql-cli中运行问题，如何结局？
flink-1.11 DDL 设置chk目录问题，怎么回事？
flink1.11.0读取mysql数据decimal类型会强转成decimal(38,18)的问题？
[flink-sql] 如何在sql运行时动态修改kafka的scan.startup.mode
flink-1.11使用executeSql()执行DDL语句问题，请大佬赐教
代码中如何取消正在运行的Flink Streaming作业？
flink1.9状态及作业迁移，还有哪些其他需要注意的问题？
flink 同时sink hbase和hive，hbase少记录，怎么回事？
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，请问这是Flink1.10的bug吗？
Table options do not contain an option key 'connector' for discovering a connector.
flink使用debezium-json format报错，大佬帮忙看下
flink1.10.1 flink sql消费kafka当parallelism大于1时不产生watermark，怎么解决
flink sql 侧输出，api中要怎么操作比较合理一点？或者有没有其他处理延迟数据的方式？
flink 1.11 sql作业提交JM报错，是不是不推荐在作业里同时使用executeSQL和statementset.execute？
flink 1.11 local execution oom问题，求指教
Flink 1.11 SQL作业中调用UDTF 出现“No match found for function signature ”异常，大佬帮忙指教下
flink kafka connector中获取kafka元数据
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。
