1.自我介绍,项目介绍2.你简历里说你用 Flink CDC 做了 MySQL 的增量同步,那我问你个问题哈:如果MySQL 有一张表发生了历史字段变更,比如某个字段从int改成了 string,你们的 Flink CDC 是怎么处理这种变更的?你们有遇到这种情况吗?线上出现这种情况怎么办3.Hive我想问下,你跑的慢的那个任务,是单表扫描慢,还是Join的时候卡住了?有没有看过 DAG?是哪个 Stage 卡住了?如果是Join卡,你是怎么调优的?广播 Join、Map Join、BucketMapJoin 你用过哪些?各自适合什么场景?4.看你用过kafka,你当时Kafka的Topic ...