问题一：Flink数据源是 mysql 和官网上的一样的？
Flink数据源是 mysql 和官网上的一样的？ 
参考答案：
第一，你去重写序列化类，第二在算子中处理 ，
关于本问题的更多回答可点击进行查看：
https://developer.aliyun.com/ask/587267
问题二：flinksql 新增字段后状态失效，无法使用savepoint启动 有什么解决方案吗？
flinksql 新增字段后状态失效，无法使用savepoint启动 有什么解决方案吗？
参考答案：
当使用Flink SQL新增字段后，如果状态失效，无法使用savepoint启动，可以尝试以下解决方案：
- 检查表结构是否一致：确保在新增字段之前和之后，表的结构是一致的。可以使用
DESCRIBE <table_name>命令查看表结构。 - 清除缓存：在执行SQL操作之前，可以调用
CACHE TABLE <table_name>命令将表缓存到内存中。这样可以避免在新增字段后重新计算结果。 - 使用
ALTER TABLE命令修改表结构：如果表结构不一致，可以使用ALTER TABLE <table_name> ADD COLUMN <column_name> <column_type>命令添加新字段。 - 使用
INSERT INTO ... SELECT语句更新数据：如果新增字段是为了更新现有数据，可以使用INSERT INTO <table_name> SELECT <new_data> FROM <old_data>命令将新数据插入到表中。 - 检查Flink版本：确保使用的Flink版本与表结构兼容。如果遇到问题，可以考虑升级或降级Flink版本。
- 检查代码逻辑：检查代码中是否存在错误，导致状态失效。如果有错误，需要修复代码逻辑。
- 重启Flink集群：如果以上方法都无法解决问题，可以尝试重启Flink集群，以清除可能存在的临时状态。
关于本问题的更多回答可点击进行查看：
https://developer.aliyun.com/ask/587266
问题三：Flink中keyed state 不keyby()的流, 怎么存储状态呢？
Flink中keyed state can only be used on a 'keyed stream'
不keyby()的流, 怎么存储状态呢？
参考答案：
在Flink中，keyed state只能用于keyed stream。如果您的流没有使用keyby()进行分区，您可以考虑以下方法来存储状态：
- 使用全局变量或静态变量：您可以在程序的主类中定义一个全局变量或静态变量，用于存储状态。这样，即使流没有使用keyby()进行分区，您仍然可以在程序的其他部分访问和修改这个变量。但是，这种方法的缺点是全局变量或静态变量可能会受到其他线程的影响，导致数据不一致。
- 使用外部存储系统：您可以将状态存储在外部存储系统中，例如HDFS、HBase等。这样，即使流没有使用keyby()进行分区，您仍然可以通过外部存储系统访问和修改状态。但是，这种方法的缺点是需要额外的存储和管理成本。
- 使用RocksDB或其他嵌入式键值存储系统：您可以使用RocksDB或其他嵌入式键值存储系统来存储状态。这样，即使流没有使用keyby()进行分区，您仍然可以通过键值存储系统访问和修改状态。但是，这种方法的缺点是需要额外的依赖和配置成本。
关于本问题的更多回答可点击进行查看：
https://developer.aliyun.com/ask/587264
问题四：flink的jobmanager内存总是持续升高直到宕机，这个是什么原因呀，有解决思路么？
flink的jobmanager内存总是持续升高直到宕机，这个是什么原因呀，有解决思路么？ 
应该是失败重启导致的使用了restart策略，但是内存一直升高这个问题不知道怎么样解决
参考答案：
适当增大JobManager的内存大小限制，并合理配置不同内存区域的大小。
关于本问题的更多回答可点击进行查看：
https://developer.aliyun.com/ask/587263
问题五：flink中资源是充足的，但是提交任务一直刷这个信息是什么情况？
flink中资源是充足的，但是提交任务一直刷这个信息是什么情况？ 
参考答案：
集群部署有问题
关于本问题的更多回答可点击进行查看：
