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

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

flink keyedState 能不能存储泛型或抽象类型
https://developer.aliyun.com/ask/364570

flink 1.11.1 使用flinksql，jdbc ，后台数据库设置主键的情况下，upsert不生效
https://developer.aliyun.com/ask/364568

使用flink1.11.1的debezium-changelog目前是否不支持Watermark
https://developer.aliyun.com/ask/364564

Flink未来会弃用TableSourceFactory吗
https://developer.aliyun.com/ask/364561

zookeeper更换leader对flink的影响
https://developer.aliyun.com/ask/364560

flink-1.11.2 的 内存溢出问题
https://developer.aliyun.com/ask/364559

native K8s模式下，pod系统占用内存
https://developer.aliyun.com/ask/364557

Blink 1.11 create view是不是没有办法把rowtime带下去？
https://developer.aliyun.com/ask/364556

Flink sql 无法用!=
https://developer.aliyun.com/ask/364555

flink 1.11.2 如何获取blink计划下的BatchTableEnvironment对象
https://developer.aliyun.com/ask/364553

flink算子类在多个subtask中是各自初始化1个实例对象吗？
https://developer.aliyun.com/ask/364551

flink 1.11.2 如何配置时区
https://developer.aliyun.com/ask/364550

flink1.11 sql ddl 连接kafka读取数据，使用事件时间窗口，无法触发，相同的sql使用系统时间触发没有问题
https://developer.aliyun.com/ask/364549

Re: flink-1.11 使用 application 模式时 jobid 问题
https://developer.aliyun.com/ask/364548

Flink与Yarn的状态一致性问题
https://developer.aliyun.com/ask/364547

怎样实现超过一定时间没有收到消息就发出报警的功能？
https://developer.aliyun.com/ask/364546

flink-1.11.2 执行checkpoint失败
https://developer.aliyun.com/ask/364545

flink sql 函数FIRST_VALUE调用报错
https://developer.aliyun.com/ask/364544

ElasticsearchApiCallBridge相关类构造函数问题
https://developer.aliyun.com/ask/364543

slot数量与并行度的大小关系
https://developer.aliyun.com/ask/364542

关于filesystem connector的一点疑问
https://developer.aliyun.com/ask/364541

flinksql kafka 插入mysql 的insert语法问题和唯一主键的问题
https://developer.aliyun.com/ask/371059

Flink sql 转义字符问题
https://developer.aliyun.com/ask/371063

flink kafka SQL Connectors 传递kerberos 参数
https://developer.aliyun.com/ask/371068

Flink使用Kafka作为source时checkpoint成功提交offset的机制
https://developer.aliyun.com/ask/371486

Flink操作 kafka ，hive遇到kerberos过期
https://developer.aliyun.com/ask/371487

flink 1.11 streaming 写入hive 5min表相关问题
https://developer.aliyun.com/ask/371488

Sql往kafka表写聚合数据报错
https://developer.aliyun.com/ask/371489

使用datagen connector生成无界数据，一秒时间窗口的聚合操作，一直没有数据输出打印
https://developer.aliyun.com/ask/371490

flink1.11.1启动问题
https://developer.aliyun.com/ask/371491

[讨论] 为 sql-client 添加 '--filename' 参数
https://developer.aliyun.com/ask/371492

解析kafka的mysql binlog问题
https://developer.aliyun.com/ask/371494

Flink SQL 解析复杂（嵌套）JSON 的问题以及写入到 hive 映射问题
https://developer.aliyun.com/ask/371495

flink1.11.0 执行sqlQuery提示NullPointException
https://developer.aliyun.com/ask/371496

flink1.11.1使用Table API Hive方言的executSql报错
https://developer.aliyun.com/ask/371497

sql-client的jdbc表出错
https://developer.aliyun.com/ask/371498

Blink的批量模式的并行度问题
https://developer.aliyun.com/ask/371499

找不到标识符“kafka”的任何工厂
https://developer.aliyun.com/ask/371501

flink聚合作业重启问题
https://developer.aliyun.com/ask/371503

【flink】flink sql insert into插入语句的问题
https://developer.aliyun.com/ask/371505

Flink CPU较低
https://developer.aliyun.com/ask/371507

metrics influxdb reporter 不支持https及jar放置路径问题
https://developer.aliyun.com/ask/371509

自定义metrics reporter 如何不通过flink conf来注册并生效
https://developer.aliyun.com/ask/371511

Flink的broadcast
https://developer.aliyun.com/ask/371514

关于 sql-client
https://developer.aliyun.com/ask/371516

flink-1.11 在 windows 下怎样启动
https://developer.aliyun.com/ask/371519

flink row 类型，请指教
https://developer.aliyun.com/ask/371521

flink1.11日志上报
https://developer.aliyun.com/ask/371523

application模式提交操作hive的任务相关疑问
https://developer.aliyun.com/ask/371524

flink 1.11.1 使用mysql作为维表进行temporal join时,偶尔会报超时异常导致数据更新失败,请教解决方案
https://developer.aliyun.com/ask/371526

Flink sql查询NULL值错误
https://developer.aliyun.com/ask/371530

1.11版本的yarn-session如何指定taskmanager数量
https://developer.aliyun.com/ask/371532

请问有哪些功能，是 stream api 可以做到，而 table api 无法做到的呢？
https://developer.aliyun.com/ask/371535

UDTAGG在SQL中可以使用么，语法是什么
https://developer.aliyun.com/ask/371537

Flink sql cdc 锁超时
https://developer.aliyun.com/ask/371558

有没有办法把flink Row类转换为Object
https://developer.aliyun.com/ask/371570

flinksql 输出到kafka用的fixed的方式 结果都输出到一个topic分区了，这个是什么原因
https://developer.aliyun.com/ask/371572

Flink cdc mysql 字段是datetime类型时0000-00-00 00:00:00会被flink转成1970-01-01T00:00
https://developer.aliyun.com/ask/371573

背压问题排查疑问求解
https://developer.aliyun.com/ask/371576

flink tm cpu cores设置
https://developer.aliyun.com/ask/371579

不同的算子能共用一个状态吗？
https://developer.aliyun.com/ask/371581

flink侧输出算子堵住的问题
https://developer.aliyun.com/ask/371582

KeyBy如何映射到物理分区
https://developer.aliyun.com/ask/371584

SQL从1.9迁移到1.11的问题
https://developer.aliyun.com/ask/371587

flink cdc 当mysql表字段修改之后提示没有找到这个字段
https://developer.aliyun.com/ask/371590

Flink SQL传递性
https://developer.aliyun.com/ask/371592

Flink sql tinyint类型使用in 报错
https://developer.aliyun.com/ask/371595

flink savepoint 异常
https://developer.aliyun.com/ask/371597

flink内存超用问题
https://developer.aliyun.com/ask/371598

flink sql kafka connector with avro confluent schema registry support
https://developer.aliyun.com/ask/371601

关于flink任务挂掉报警的监控指标选择
https://developer.aliyun.com/ask/371603

请教大神们关于flink-sql中数据赋值问题
https://developer.aliyun.com/ask/371605

flink savepoint
https://developer.aliyun.com/ask/371606

关于cluster.evenly-spread-out-slots参数的底层原理
https://developer.aliyun.com/ask/371608

flink 1.11 cdc: 如何将DataStream 要如何转成flink sql cdc里的table？
https://developer.aliyun.com/ask/371610

flink1.11的cdc功能对消息顺序性的处理
https://developer.aliyun.com/ask/371611

JobManager responsible for xxx lost the leadership.
https://developer.aliyun.com/ask/371626

keyBy的数据均衡性
https://developer.aliyun.com/ask/371627

union all 丢失部分数据
https://developer.aliyun.com/ask/371628

flink 1.11.0 chk超时
https://developer.aliyun.com/ask/371633

flink-1.11 写 hive 报错
https://developer.aliyun.com/ask/371647

flink 1.11.2 cep rocksdb 性能调优
https://developer.aliyun.com/ask/371646

cdc代码报错
https://developer.aliyun.com/ask/371645

使用flink-CDC checkpoint超时问题
https://developer.aliyun.com/ask/371644

flink1.11.0 sql自定义UDAF包含复合类型时报Incompatible types
https://developer.aliyun.com/ask/371643

flink 1.11.1 web ui 页面查看source算子的detail数据，recoreds sent等度量状态永远为0
https://developer.aliyun.com/ask/371642

1.11.1 报OutOfMemoryError: Metaspace. 错误
https://developer.aliyun.com/ask/371641

提交flink sql任务报错
https://developer.aliyun.com/ask/371640

kafka table connector eventTime的问题
https://developer.aliyun.com/ask/371639

使用BroadcastStream后checkpoint失效
https://developer.aliyun.com/ask/371638

FlinkSLQ双流join使用LAST_VALUE + INTERVAL JOIN时遇到问题
https://developer.aliyun.com/ask/371637

yarn部署模式kerberos问题
https://developer.aliyun.com/ask/371636

Flink中是否可动态Task调度
https://developer.aliyun.com/ask/371635

flink 1.11.2 keyby 更换partition
https://developer.aliyun.com/ask/371634

pyflink的where该如何使用？如何筛选？
https://developer.aliyun.com/ask/371632

Flink 1.11 submit job timed out
https://developer.aliyun.com/ask/371631

RocksDBKeyedStateBackend如何写磁盘
https://developer.aliyun.com/ask/371630

flink1.10.1/1.11.1 使用sql 进行group 和 时间窗口 操作后 状态越来越大，怎么回事
https://developer.aliyun.com/ask/371561

[DISCUSS] FLIP-133: Rework PyFlink Documentation
https://developer.aliyun.com/ask/371559

flink1.9.1 在WebUI中查看committedOffsets指标为负值
https://developer.aliyun.com/ask/371557