阿里云开发者社区作为一个充满活力的技术社区，有许多技术同道在这里勤学好问。为了让这些用户的疑惑得到解答，我们举办了“百问求答”活动，本期为Flink专场，期待用你的技术知识储备帮助同行解决难题，赢取行李箱等好礼，还有机会成为阿里云开发者社区“乘风问答官”，享受专属权益！赶快参与起来！

奖项设置：

注：问题如有回答，若你有其他解决方案也可作答，将记录在内；若回答雷同，将不计数。 

乘风问答官权益可点击https://developer.aliyun.com/ask/469378进行查看。

活动流程

1、点击https://yida.alibaba-inc.com/o/wdg进行报名；

2、回答文末Flink问题

活动时间

2023年4月23日至5月7日24：00

获奖名单及奖品邮寄时间

获奖名单将于活动结束后7个工作日公布，奖品将于10个工作日内进行邮寄，节假日顺延。

活动规则及注意事项

1、本活动回答数据不记录问答官排位赛活动中；

2、 回答仅限文章链接中的问题，其他回答不计数；

3、 回答请解答能力范围之内的问题进行，充数回答将不计算在内，如111、等与问题无关的回答；

4、 问题及回答需为中文，英文不记录数据；

5、 回答发布后将进入审核状态，审核完成即可查看；

6、 标题党、黑稿、通稿、包含违法违规、未被许可的商业推广、外站链接、非原创内容、营销软文、抄袭嫌疑的文章审核将不予通过，同时取消参赛资格；

7、奖品不叠加，以最高级发放。

Flink问题链接：

1、Fink汇聚后打印的时候发现没数据，请问是什么原因了？在汇聚之前上一步是有数据的

2、flink 是13.6版本照着cdc connector的例子写的直接报错了能帮忙解决一下么？

3、请问有人知道flink为什么这个issue一直不解决吗？是有什么难点吗？

4、实时数据Flink SQL无法使用纯SQL解决（不采用jar的方式下） 有没有比较好的方式

5、我想创建个flink实例测试下，结果卡在一个虚拟交换机半天了

6、jdbc sink支持回撤流吗？似乎flink sql中-D的数据并不能执行删除的mysql的对应数据

7、flinksqlAPI的状态设置永不超时，是否也可以使用rocksdb作为状态后端呢？

8、以后flink连接器都放在这个仓库了吗？

9、flinksql创建表，不设置水位线。没办法窗口聚合计算？

10、你们公司项目中flink任务取消检查点也是使用这个策略吗？

11、flink 读取mongo的时候，发过来的数据 source.ts_ms 时间戳不够精确

12、咨询下，2.x 可以兼容flink1.12吗?

13、请教一下：flinksql创建的同步sqlsever到mysql的任务，重启Flink程序后，任务还能自动从检查点开始吗？

14、在实际中使用flinkSQL 多吗？

15、阿里云实时计算Flink 如果使用自定义connector。支持哪个scala版本呢？

16、flink之前配置一个实时同步数据库到Kafka的任务，开发和生产都会同步，为什么改了？

17、哪位大佬知道啥时候支持flink1.15啊，我看到支持flink1.15的pr 被block了

18、请问flink-connector-jdbc在sink时，如何设置批量写入？

19、flink任务重启起来之后还是会消费之前的日志信息，这个咋解决

20、怎么让flink 部分算子跑批 部分跑流模式？

21、flink 批处理 使用table去读取MySQL的数据，报这个

22、bufferTimeout 这个参数在flink-conf.yaml 是怎么配置啊

23、flink-sql 可以配置退出时不清理 checkpoint 嘛

24、flink standalone 1.13 随着运行时间增加出现Metaspace OOM是为什么

25、flink 如何将 DataStream 转为 DataStream ？

26、flink将数据全量写入到mysql有什么好的方案吗

27、为什么flinkRunning Jobs Overview一直在转，任务正常运行的

28、在flnk sql.clent 连接mysql的shell中如何设置超时时间

29、各位 flink sql 写入 这个问题 如何解决呢

30、大佬们，flink源码里面开头有@Internal 注解的类是不是不能调用？

31、flink sql为啥会出现计算结果不正确呢？？

32、flink必须要管理员账号吗？

33、flinksql中的窗口聚合是不是无法使用where进行条件过滤呢

34、使用flinkSQL将数据写入hudi，而hudi的数据存储在s3上，提交程序运行报错是怎么回事？

35、flink on yarn 怎么设置按周期清理下任务运行日志呢

36、flink SQL在通过参数指定job name吗

37、flink现在支持elasticsearch8以上的版本吗？

38、各位大佬，flinksql可以实现多流join吗，比如十几张表join

39、flink可以实时处理 月同比 月环比吗

40、flink的日志可以分开打印吗

41、FlinkKafkaConsumer 1.11的clientId什么的看不到这个怎么解决吗？

42、请问一下flink执行mysql同步整库到hologres的时候无法转换jobgraph 为什么？

43、有把springboot集成flink的么，主要想用下配置中心和jpa读取flink的配置

44、flink怎么获取历史数据和当前数据进行合并计算

45、有人有flip-191 sink的Demo吗。或者哪里可以看具体怎么自定义

46、请教下，finksql 这个statettl 哪里设置

47、这个id应该是数值类型，用在flink 中用bigint会报错，用string后，才发现字段值是这种

48、我在flinksql客户端执行sql出现这个字段过多的一个报错需要调节什么解决呢?

49、flink 批任务 动态资源管理 是在哪个版本有？

50、flink 也能 使用 sql 查询 hive 表？

51、flink 做批 处理 用的api 都一样？

52、flink 中事件类型为r可能重复吗

53、flink keyed window 会因为下游BackPressure 导致数据被扔掉吗

54、flinkcep 能做批处理吗？

55、flink开一天窗口，设置时区好像没有生效，1.13.6版本，有知道怎么解决时区问题吗

56、pyflink1.15 同样的代码报错，在java里面不报错能正常运行，知道是什么原因吗

57、flink on k8s时候打镜像怎么自定义hosts文件？

58、flink处理数据，突然有时间戳异常的数据那么我后续来的正常数据还会被处理（filter算子）吗

59、flink做批处理，需要配置资源吗？

60、flink批处理，一次性读多少数据合理，怎么分批读

61、flink 打了断点 debug模式但一直不进断点是啥情况？也没报错

62、flink同步分库分表的数据时，使用DataStreamAPI怎么设置？

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

64、哪位大佬遇见这种问题，flink on yarn(application提交)

65、flink支持按不同粒度（1min、1hour、1day) 统计直播观看人数，应该怎么设计？

66、为啥flink离线压缩hudi表 每次只压缩一个commit呀

67、求教 如何让flink释放内存啊

68、flink离线压缩hudi 表 追不上flink写hudi表的速度怎么解决啊

69、flink yarn资源 queue消耗过多 是什么原因呢

70、有没有对flink 离线任务压缩 hudi表 增大一次压缩的commit个数，感觉默认的太慢了

71、对于两个事实表使用flink 大宽 有什么好建议 例如t1数据先到 t2的数据可能很久到 这种场景

72、有没有flink sink到hudi的demo

73、你们用flinksql做复杂聚合好还是用stream处理好？

74、大佬们遇到过flink 写hudi 出现这种问题吗？Hadoop拒绝连接

75、postgres分区后，flink 拿不到数据，有大佬知道吗？

76、flink CUMULATE 窗口统计1天的pv，uv之类时候，有没有碰到过统计结果不准的情况？

77、Flink Lookup Join是不可以用OR吗？

78、flink写hudi 离线压缩，采用哪种策略啊

79、flink sql 同步mongo数据报了个错，大家有人遇到过没

80、flinksql 可以 设置自增id 吗？

81、flink 可以 不用 侧输出 流来 复制流吧，只需要 重复调用 这个流就可以了吧

82、flink sql 给DAG算子命名咋弄哇？就是,name 那种用法。有人知道么

83、flink 有人遇到这个报错吗?

84、有人改过flink-jdbc-connector源码部署到yarn上不生效的吗？怎么解决的？

85、想问一下, tidb的VARBINARY映射到flink中是什么类型?

86、有大佬做native flink on k8s的部署方案吗，按照官网的配置，报这种异常，大佬帮忙瞅瞅

87、按照官网的配置，报这种异常，大佬帮忙瞅瞅

88、提交flink任务有遇到这种情况吗？

89、flink，我更新了代码， 重新启动任务，会从头同步数据么

90、大佬们这个位置怎么改，你们遇到过吗

91、这个问题怎么解决呀，cdc2.1.1，就是简单的全字段同步一张表，正常跑了一个多月突然挂了。

92、我flinksql 连接oracle时间长 Closed Connection报错这个怎么设置？

93、请问有人知道为啥 flink源码中有很多 判断是否在主线程中运行这个是为啥呢

94、各位 帮忙看个问题，flink sql从hive 读数据报错，能不能不改配置文件 改sql就可以跑

95、请问下使用flink同步数据到mysql，mysql有相同的主建怎么处理的？

96、Flink如何读取hudi在changelog下的insert呢

97、大家好，flink有没有一款包含很多规则的流数据清洗组件呢？

98、大家生产上有用nacos管理flink的配置吗

99、这个报错有什么好的解决方法吗

100、各位大佬们，下面这个指令，可以只指定给需要的库么？ mysql> GRANT SELECT, SHOW DATABASES, REPLICATION SLAVE, REPLICATION CLIENT ON . TO 'user' IDENTIFIED BY 'password';