【百问百答】flink全知道系列2

阿里云问答 2021-12-30 08:13:48 阅读数:664

编程开发 Flink 系列 知道 阿里云问答

flink 相关问题整理如下。可以Ctrl+F检索关键词进行查找,本合集持续更新中,记得关注、收藏哦

【百问百答】flink全知道系列1

【百问百答】flink全知道系列3

1flink 1.13编译 flink-parquet报错 -类重复:org.apache.flink.formats.parquet.generated.SimpleRecord

2Dynamic Table Options 被优化器去掉了

3flink如何从流中取出自定义的数据结构并赋值给变量

4Flink撤回机制不起作用

5官网文档和样例的不完整性和不严谨性的问题

6flink sql消费kafka join普通表为何会性能爬坡?

7flink mysql cdc疑问

8flink 1.12.2 sql-cli 写入Hive报错 is_generic

9設置look up table source

10flink1.11版本 -C 指令并未上传udf jar包

11flink1.12.1 Sink数据到ES7,遇到 Invalid lambda deserialization 问题

12Flink SQL 1.11支持将数据写入到Hive吗

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有一些问题

19flink11 SQL 如何支持双引号字符串?

20关于flink sql往postgres写数据遇到的timestamp问题

21flink 1.12如何使用RateLimiter

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失败怎么处理?

26Flink SQL读取复杂JSON格式

27Flink 1.11.2 on yarn报错如何处理?

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,程序运行一段时间报出:超出物理内存怎么处理?

36flink使用多个keytab的情况怎么处理?

37flink 1.11.2写hive 2.1.1 orc 遇到的问题

38Flink-yarn模块加载外部文件的问题

39使用stop命令停止yarn队列任务携带Kerberos认证信息

40Flink1.11.2写hive提示UnknownHostException

41使用RedisSink无法将读取的Kafka数据写入Redis中

42为什么要关闭calcite的隐式转换功能

43flinksql维表join之后不能做些过滤这样的操作吗?

44使用DataStream → IterativeStream → DataStream 方式做流关联

45生产hive sql 迁移flink 11 引擎,碰到的问题

46动态表 Change Log 格式

47SQL解析复杂JSON问题

48一个关于实时合并数据的问题

49flinksql1.11长时间没有数据写入mysql,会报ava.sql.SQLException: No operations allowed after statement closed.

50请问flink sql实时计算分位数如何实现哈?

51Flink SQL共享source 问题

52用代码执行flink sql 报错 Multiple factories for identifier 'jdbc' that implement

53Flink CEP 动态加载 pattern

54ookeeper更换leader对flink的影响?

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写入时,用户名密码认证不支持怎么办?

64带有状态的算子保存checkpoint失败

65请教一下目前flink submit能不能指定额外的依赖jar

66flink-1.11.2 job启动不起来怎么办?

67flink-1.11.2提交到yarn一直处于CREATED中

68FlinkSQL导致Prometheus内存暴涨

69flink-json 函数用法

70Flink SQL 是否存在类似MySQL的group_concat函数

71FLINK SQL 消费kafka消息乱序问题

72flink 1.11.2 cdc: cdc sql 结果表的sink顺序问题, 不同并行度下从save point中恢复job时,会导致sink结果不对!!

73flink1.11编译失败是什么原因

74canal-json 分库分表场景应用有什么思路吗?

75flink on native k8s

76flink sql cdc 如果只处理一次全量数据问题

7flink sql实时计算分位数如何实现

78发现flinksql写hive比写hdfs慢很多

79udtf collect方法 报NEP

80flink1.11.2 一直不入hbase问题

81Flink CDC 遇到关于不发生packet造成的卡顿问题该如何解决

82flink sql 连接mysql 无数据输出

83flink 1.11.2 rowtime和proctime流 Interval Join 问题错误问题

84slot问题

85flink sql时间戳字段类型转换问题

86用flink 1.11.2 查询hive表自关联(self inner join) 结果不正确

87Flink SQL Row里嵌套Array 该如何用DDL定义?

88SQL Cli中找不到DeserializationSchemaFactory

89flink使用hive udf函数会报错

90ProcessingTime下的watermark

91关于Catalog的建议

92Flink SQL 对延迟数据怎么处理?

93关于flink实时写入hbase用flush方法频繁报操作超时问题

94flink sql 中是否可以使用 mysql 的存储过程和函数?

95flink读mysql分库分表

96JdbcUpsertTableSink输出的时候报‘Duplicate entry’问题

97pyflink 1.11.1 调用包含第三方依赖库的udf时报错

98FlinkSQL CDC 窗口分组聚合求助

99TUMBLE函数不支持 回撤流

100求助:Flink DataStream 的 windowoperator 后面apply 方法不执行


版权声明:本文为[阿里云问答]所创,转载请带上原文链接,感谢。 https://developer.aliyun.com/ask/386507