【百问百答】flink全知道系列1
flink 相关问题整理如下。可以Ctrl+F检索关键词进行查找，本合集持续更新中，记得关注、收藏哦
2flink-1.12.2 TM无法使用自定的serviceAccount访问configmap怎么办？
3flink sql count distonct 优化应该怎么办？
5interval join 如何用 process time?
6Flink 1.12.0 隔几个小时Checkpoint就会失败
7flink on yarn session模式与yarn通信失败是什么问题？ （job模式可以成功）
11Flink SQL JDBC connector不能checkpoint怎么办
13Flink Native Kubernetes 部署模式下，如何开启Queryable State？
14Flink on Native K8S模式下如何配置StandBy做高可用？
15FileSystemTableSink支持自定义分隔符写入吗？
16Flink1.11执行sql当判空使用<> null,程序直接结束怎么办？
19Flink1.11如何实现Tumble Window后基于event time倒序取第一条作统计？
20Flink sql 如何实现全局row_number()分组排序？
23flink sql 的 count(distinct )问题
24Temproal Tables 请教下大家，官网中对于时态表的定义的案例是基于debezium的，我现在具基于canal这样定义有问题吗？
25flink1.12版本，使用yarn-application模式提交任务失败怎么办？
26Flink 中 shuffle Partitioner 和 rebalance partitoner 有什么区别？
27关于pyflink LATERAL TABLE 问题请教
30PyFlink UDTF 运行一段时间后报 NullPointerException怎么办？
32将每个tm的slot数从2降低到1，任务反而无法启动怎么办
35BUG ：DataStream 转 Table 后无法 触发窗口计算怎么办
36如何自定义web-ui上对taskmanager的标识符？
38flink sql 这种实时计算结果如何与离线计算的结果做数据比对？
39flink Application Native k8s使用oss作为backend日志偶尔报错怎么办？
40flink sql-client 读写 Kerberos认证的hive问题？
41pyflink 如何使用session window对相同pv数据聚合？
42flink作业报 task manager连接错误怎么办？
43Re: Flink 1.11.2运行一段时间后，会报ResourceManager leader changed to new address null的异常
44Re: flink1.12 执行sql_query()，同样的数据源表，pyflink执行时间9min，java执行3s是为什么？
45flink dataStream多次sink DAG重复驱动执行？
48Flink SQL upsert-kafka connector 生成的 Stage ChangelogNormalize 算子的疑问？
50Flink1.12 如何使用代码提交Batch的Sql？
51yarn.containers.vcores使用有问题？
53Re: [DISCUSS] Deprecation and removal of the legacy SQL planner
54如何动态配置 flink run 的 client日志文件的路径？
56flink TableEnvironment.sqlUpdate不支持update 多表关联更新吗
57编译Flink1.11的flink-runtime-web失败怎么办？
59Flink 1.12 ApplicationMode运行在阿里云托管Kubernetes报错怎么办？
61flink如何在无数据流的情况下也能实现state定时输出的功能？
62Flink sql的state ttl设置有问题怎么做？
63rocksdb状态后端最多保留checkpoints有问题怎么做？
66flink on yarn 模式下，yarn集群的resource-manager切换导致flink应用程序重启，并且未从最后一次checkpoint恢复怎么办？
67flink 1.13 k8s native 启动找不到 KubernetesSessionClusterEntrypoint怎么办
73flink 1.13.0 中cumulate window该怎么使用？
74请问flink lookup表作为维表,那么lookup表是不是不能新增或者修改,如果修改了那么作业就需要重启?
76集群重启如何保证带状态的任务自动从最近一个checkpoint恢复？
80flink sql支持Common Table Expression (CTE)吗？
81flink mysql cdc支持mysql的json格式吗？
85flink 1.13.0 ，使用flink sql 链接数据库是否支持多模式，即表名为schema.name是吗？
86如何统计n小时内，flink成功从kafka消费的数据量？
87请教，有哪些连接器能让我获得一个非 update/delete，但又有主键的流呢？
88用table api 提交多个SQL 的时候，有什么API 能提前检查SQL 的错误吗？
89flinksql 1.12.1 row中字段访问报错怎么办
90Upsert Kafka 的format 为什么要求是INSERT-ONLY的？
91Pyflink dataset没有支持相关map reduce函数怎么办？
92flink-1.11.2版本，客户端如何设置dynamic properties？
94Re: Flink 1.11.2运行一段时间后，会报ResourceManager leader changed to new address null的异常
95flink 1.13 k8s native 启动找不到 KubernetesSessionClusterEntrypoint怎么办
96createTemporaryView接口注册table时，fieldname支持中横线（-）怎么处理？
99请教下为什么 无法通过t.* 将 自定义函数返回的嵌套字段查出来。
100flink cdc 查询mysql binlog时，在 streaming模式下，如果无法获得reload权限应该如何配置参数
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关课程
更多
相关文章
相关电子书
更多
