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

百问求答(17)Flink 问题专场!回答问题赢小米电动牙刷等好礼

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

奖项设置:

image.png

重要说明

图文并茂定义:图片需要能起到辅助回答的说明作用,如配合回答内容的流程截图、界面截图等,每个图文并茂的回答需至少包含1张图片,纯插图、代码截图等不计入内;有效的图文并茂回答示例:

https://developer.aliyun.com/ask/498337 该问题中“凌云cloud”的回答

https://developer.aliyun.com/ask/493319 该问题中“凌云cloud”和“飞云觅宙”的回答

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

活动流程

1、点击https://yida.alibaba-inc.com/o/wdg进行报名(未报名用户将视为未参与,请大家填写表单进行报名)

2、回答文末问题

活动时间

2024年1月12日至2024年1月28日24:00

获奖名单及奖品邮寄时间

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

活动规则及注意事项

1、本活动限制同人账号同时参与,如发现,只向一个账号发放奖励。“同人账号”是指同一用户拥有多个阿里云账号的,各个账号之间互为同人账号。

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

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

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

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

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

7、奖品不叠加,以最高级发放;

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

问题链接

1、在Flink为什么报了连接错误 ,还能读取数据呢?

2、flink任务一直报错,怎么解决?

3、Flink怎么诊断问题出现在哪里呢?或者有没有降低延迟的办法呢?

4、新版本flink1.17-1.19写入ES,官方例子报错 ,怎么解决?

5、实时FLINK是否支持云原生数据仓库AnalyticDB PostgreSQL到DORIS同步

6、本地测试可以正常运行,在flink集群上跑就报这个错误?

7、Flink找不到javassist动态创建的类一般是啥原因?

8、新版本flink1.17-1.19写入ES,官方例子报错 什么原因?

9、flink 消费kafka,之前任务正常的,突然有个分区没法消费了,重启下任务久正常了?

10、Flink有2023 Flink Forward Asia 资料下载地址吗?

11、Flink这种报错是由于什么呢?

12、Flink的keyBy不生效,怎么搞?

13、Flink点击启动后,卡了很久,怎么回事?

14、Flink启动报这个错怎么解决?flinksql认为提交启动异常。

15、Flink这个问题怎么解决?

16、Flink的ctas有办法把 这三个字段也同步进去嘛?

17、Flink的tmp的这个目录产生临时文件很大,我想配置到外面,有配置项可以配置吗?

18、Flink这个监控在哪看呀?

19、Flink这个问题怎么处理?

20、Flink是不是下个月出调度的功能?

21、Flink为什么找不到这个包呢?

22、flink的历史服务historyserver起来之后,看页面请求有一个404是什么情况啊?

23、有遇到Flink这个错嘛?

24、Flink sql-client 针对kafka的protobuf格式数据建表,有人遇到过吗?

25、有遇到FLINK 写ES 需要过SSL验证的问题吗?

26、有遇到Flink Debezium ddl中文乱码的没有?

27、Flink解析json到表,有没有强大的插件?

28、实时计算 Flink版为什么 我测试出来不是这样的?

29、Flink这个bug躺了好久了,社区又没什么好的方案?实在搞不定了?

30、flink官网给了例子但是不是很详细 写了之后好像有点问题?

31、Flink cdc2.0用下来,发现全量故障恢复不能从checkpoint点恢复?

32、Flink系统时间是北京时间,但是flink窗口在北京时间的基础上+8了,咋解决?

33、Flink触发器定义了何时触发计算,但是reduce这种每来一个元素就计算?

34、flinksql 怎么使用rebalence?kafka单个分区lag很高 flinksql没法搞?

35、Flink经过测试发现使用 事务传播机制 无论是那种事务传播机制都不行,如果都成功还好,有一个失败?

36、Flink启动了两个任务,但是有一个运行期间挂掉了,在compeleted job 啥都没有?

37、flink 从savepoint 恢复的问题我目前发现 类名修改 或者包路径修改?

38、Flink现在我有个这样的操作,就是原先有个接口是修改数据的接口,因为业务复杂他是先删除后增加?

39、flink cdc采集sqlserver2008版本的数据如何兼容?

40、使用的Flink1.16,然后消费kafka,过了几天了,老是出现了不消费kafka数据,然后kafka的consumer groupid 手动查询发现不存在了

41、Flink 1.15解析sql报这个错误 大家有遇到过吗?

42、Flink这个问题怎么解决?

43、有人用minio作为statebackend吗?flink-conf.yml怎么配置的

44、Flink在 k8s 上部署作业会碰到 NoClassDefFoundError 的问题吗?

45、请问如何用flink sql客户端用yarn application模式提交任务呢?

46、flink程序本地可以启动,提交到Apache Flink Dashboard上报错,怎么解决?

47、请教个flink sql问题:为啥TVF不支持changelog呢?

48、Flink Async IO 超时导致检查点一直失败帮忙看一下嘛?

49、有用过flink 1.17.1的 hive方言吗?

50、Flink数据从kettle迁移到Mysql有什么比较好的方案吗?

51、有没有用flink计算过历史累计数据?

52、flink catalog 链接 pg 这个 有啥办法设置替代没有?

53、Flink有没有 那种不同 数据库 之间DDL 语句转换的 脚本或程序?

54、有人用过flink官方operator的reactive模式吗?

55、flink比如,半小时内状态一直停留在13,我的语法匹配规则是不是有什么问题?

56、flink 跑到k8s 按照官网介绍的配置这些参数,但是好像没看到自动扩缩的操作?怎么回事

57、Flink 有遇到这个问题吗 ,是什么原因啊 ?

58、Flink 这个值是空的配置没生效。是什么原因?

59、Flink是这样设置提交参数的吗?

60、我想统计今天0点到明天0点 但是窗开的是今天8点到明天8点,全托管Flink的话需要怎么设置一下?

61、Flink统计的数值感觉像flink开窗的时候,判断现在的时间是8小时前,该如何解决?

62、用Flink mongocdc遇到这样的问题,读线上云mongo库数据,没有数据进来,这是什么原因?

63、Flink的前段源码怎么替换啊?

64、请问下,有大佬遇到过flink web ui上的指标都是loading状态吗?

65、问一下Flink:我这边使用pyflink将json的流数据写入kafka后,请问应该如何解决?

66、Flink sql读取postgre josnb类型异常?

67、帮忙解答下native k8s和flink k8s operator 哪种方式更好些?

68、flink 手动触发savepoint会出现timeout,有办法调整超市时间之类吗?

69、在Flink 我的jobmanager 怎么老是报这个日志,怎么解决?

70、Flink sql 中 怎么 将bin函数 转成的二进制 数据 转为数组?

71、这个是报错文件,是不是实时计算Flink没有用户访问的目录啊?

72、flink sink hudi container is running 大家有遇到过吗?

73、Flink我在map里面写函数,一直报错,B cannot be cast to怎么改都不行?

74、请问Flink,从迭代器创建datastream,这里的类型怎么填呢?

75、Flink CDC中像这种情况,要怎么样才能保证数据的原始有序性?是不是不能使用keyBy算子?

76、Flink CDC中我从阿里仓库拉的2.4的依赖看着跟2.4版本的对不上呢?

77、Flink 中一直抱这个错 有大佬知道怎么解决吗?

78、flink版本是1.15.1 ha部署,算子设置了多并发 ,如何确保每一个并发都运行在同一台机器上,现在的效果是这样的,会有某一个并发运行到了另一台机器上,这种情况在1.11的时候还没有?

79、各位大佬请问flink这个报错有遇到过吗?启动的时候报错

80、大佬们知道 flink这个错误吗,是什么原因,搞半天了,kerberos 认证?

81、有用flink消费过mq的嘛,我自定义了一个,本地是一直在消费,集群上直接进入FINISHED状态了,现在mq里没数据?

82、flinkKafka 怎么配置两个不同sasl.mechanism?

83、flink中Mesos在大数据领域用的更多?

84、我有两套环境 用的一个flink,kafka在A集群,HBase在B 集群,我在其他节点安装了一个?

85、 flink1.15.2使用hdfs的filesystem做存储,state backend为EmbeddedRocksDBStateBackend。现在对state设置ttl,报这个错?

86、请问flink session里的checkpoints这个里面没有内容呢,我任务是开启了?

87、请问Flink这个语句哪里写的有问题么?运行不过去?

88、Flink中yarn-application 模式 可以把多个任务提交到一个集群里吗 有没有提交命令的样例可以参考下

89、大佬们有没有遇到这个Flink问题啊?

90、Flink中现在大数据组件,用docker部署 k8s管理的场景 多不多,比如计算flink ?

91、Flink中一个任务的输入依赖于前面两个任务的输出,三个任务都是独立的。应该怎么做?

92、flink作业 中 ,现在没有什么一条sql 更新 多条 数据的语句吧?

93、flink1.15启动standalone模式后进行测试,发现UI界面无法启动,防火墙关闭的,端口也没有占用,请问一下这个是什么情况?

94、flink 启动 sql gateway链接hiveserver2报错有人遇见过吗?

95、Flink中支持的事件时间属性数据类型必须为 TIMESTAMP 或者 TIMESTAMP_LTZ?

96、Flink中这个问题那个大佬知道吗,我用TO_TIMESTAMP_LTZ函数返回的字段作为水位线字段就没有问题?

97、flink1.14.5我用table api从mysql写入es,mysql源中有一个字段通过collect聚合函数默认得到了MULTISET类型,该字段需要对应输出到es的array类型中,但是报错

98、Flink中这个forwarded是什么含义有人知道吗?

99、Flink中standalone 集群,一个taskmanager挂掉,这个taskmanager上的任务不会挂掉,会直接平移到别的taskmanager上 正常吗?

100、Flink中这个是啥情况,jar包都放到lib下面,还是出这个问题?

展开
收起
提个问题 2024-01-12 11:22:26 2164 11
22 条回答
写回答
取消 提交回答
  • 响应有点慢

    2024-04-06 18:29:20
    赞同 展开评论 打赏
  • 重在参与

    2024-04-06 09:10:08
    赞同 1 展开评论 打赏
  • ddx

    不知道可好试一试

    2024-04-05 21:53:54
    赞同 1 展开评论 打赏
  • 重在参与

    2024-04-02 13:51:13
    赞同 展开评论 打赏
  • 重在参与

    2024-02-19 13:55:00
    赞同 展开评论 打赏
  • 在参与

    2024-02-18 15:38:49
    赞同 展开评论 打赏
  • 重在参与

    2024-02-18 12:23:20
    赞同 展开评论 打赏
  • 参与

    2024-02-15 08:59:24
    赞同 展开评论 打赏
  • 重在参与

    2024-02-09 08:02:57
    赞同 展开评论 打赏
  • 重在参与

    2024-02-08 08:18:50
    赞同 展开评论 打赏
  • 积极参与

    2024-02-07 11:21:28
    赞同 展开评论 打赏
  • 图片.png

    2024-02-02 17:52:00
    赞同 1 展开评论 打赏
  • image.png

    2024-01-28 13:45:37
    赞同 5 展开评论 打赏
  • 十分耕耘,一定会有一分收获!

    必须参加

    2024-01-27 13:56:15
    赞同 6 展开评论 打赏
  • 企业微信20240117-130027@2x.png

    2024-01-17 13:04:35
    赞同 7 展开评论 打赏
  • yun1958715

    image.png

    2024-01-15 19:59:59
    赞同 10 展开评论 打赏
  • 某政企事业单位安全运维工程师,主要从事系统运维及网络安全工作,多次获得阿里云、华为云、腾讯云征文比赛一二等奖;CTF选手,白帽,全国交通行业网络安全大赛二等奖,全国数信杯数据安全大赛银奖,手握多张EDU、CNVD、CNNVD证书。

    image.png

    第一次参加,已提交

    2024-01-12 21:45:02
    赞同 9 展开评论 打赏
  • 北京阿里云ACE会长

    image.png

    百问求答(17)Flink 问题专场

    https://developer.aliyun.com/ask/588660

    2024-01-12 16:18:04
    赞同 8 展开评论 打赏
  • image.png

    2024-01-12 15:05:40
    赞同 9 展开评论 打赏
  • image.png

    2024-01-12 15:04:03
    赞同 6 展开评论 打赏
滑动查看更多

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

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载