探索云世界
flink 相关问题整理如下。可以Ctrl+F检索关键词进行查找，本合集持续更新中，记得关注、收藏哦
1flink 1.13编译 flink-parquet报错 -类重复：org.apache.flink.formats.parquet.generated.SimpleRecord
2Dynamic Table Options 被优化器去掉了
6flink sql消费kafka join普通表为何会性能爬坡？
8flink 1.12.2 sql-cli 写入Hive报错 is_generic
10flink1.11版本 -C 指令并未上传udf jar包
11flink1.12.1 Sink数据到ES7,遇到 Invalid lambda deserialization 问题
13请问flink 1.12如何使用RateLimiter哈？
14flink使用RocksDB增量checkpoints，程序运行一段时间报出：超出物理内存
15flink jdbc connector 在checkpoint的时候如何确保buffer中的数据全都sink到数据库
16flink 1.11.2 on yarn 可用slot始终为0，job无法提交如何处理？
17FlinkSQL如何定义JsonObject数据的字段类型
18flink sql 1.11 kafka cdc与holo sink有一些问题
20关于flink sql往postgres写数据遇到的timestamp问题
22求助如何用flink1.11.2 on yarn集成CDH的hbase2.0版本
23[flink-1.10.2] 异步IO结果DataStream 该如何注册为table？？
24Re:flink 1.9.2 容器ha部署是jobid 一直是00000000000000000000000000000000
25Flink 1.11.2 on yarn 提交job失败怎么处理？
28Flink HA目录下数据不完整，导致JobManager启动失败如何解决？
29flink sql 如何实时计算百分比CodeGenException: Unsupported cast from 'ROW' to 'ROW'.
30在map算子中对redis进行sadd写入之后再sget读取
31Flink 1.11版本LeaseRenewer为什么线程不释放？
32ScanTableSource 为什么不支持SupportsFilterPushDown的问题
33分组查询时，select的字段是否一定要都在group by中吗？
34flink 使用关系型数据库的默认事务是否可以做到端对端的精确一次，还是需要实现2p2提交
35flink使用RocksDB增量checkpoints，程序运行一段时间报出：超出物理内存怎么处理？
37flink 1.11.2写hive 2.1.1 orc 遇到的问题
39使用stop命令停止yarn队列任务携带Kerberos认证信息
40Flink1.11.2写hive提示UnknownHostException
41使用RedisSink无法将读取的Kafka数据写入Redis中
43flinksql维表join之后不能做些过滤这样的操作吗？
44使用DataStream → IterativeStream → DataStream 方式做流关联
45生产hive sql 迁移flink 11 引擎，碰到的问题
49flinksql1.11长时间没有数据写入mysql，会报ava.sql.SQLException: No operations allowed after statement closed.
52用代码执行flink sql 报错 Multiple factories for identifier 'jdbc' that implement
55Flink SQL使用Tumble窗口函数报NoSuchMethodError functions/AggregateFunction 异常
56Flink SQL GROUP BY后写入postgresql数据库主键如何实现业务场景需求呢？
57修改topic名称后从Savepoint重启会怎么消费Kafka？
58大家有用Flink SQL中的collect函数执行的结果用DataStream后，用什么数据类型匹配该字段的结果，数据类型的类名和需要的依赖是什么？
59【Flink SQL】无法启动 env.yaml怎么处理？
60使用flink-sql解析debezium采集的mysql timestamp字段报错
61Flinksql通过phoenix查询维表，报Caused by: org.apache.calcite.avatica.NoSuchStatementException
62使用 StreamingFileSink后 checkpoint状态中的数据如何hive读取
63flink sql es写入时，用户名密码认证不支持怎么办？
65请教一下目前flink submit能不能指定额外的依赖jar
67flink-1.11.2提交到yarn一直处于CREATED中
70Flink SQL 是否存在类似MySQL的group_concat函数
72flink 1.11.2 cdc: cdc sql 结果表的sink顺序问题， 不同并行度下从save point中恢复job时，会导致sink结果不对！！
81Flink CDC 遇到关于不发生packet造成的卡顿问题该如何解决
83flink 1.11.2 rowtime和proctime流 Interval Join 问题错误问题
84slot问题
86用flink 1.11.2 查询hive表自关联(self inner join) 结果不正确
87Flink SQL Row里嵌套Array该如何用DDL定义?
88SQL Cli中找不到DeserializationSchemaFactory
93关于flink实时写入hbase用flush方法频繁报操作超时问题
94flink sql 中是否可以使用 mysql 的存储过程和函数？
96JdbcUpsertTableSink输出的时候报‘Duplicate entry’问题
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。
