实时计算 Flink版产品使用问题之拉取代码没有这个类，但是在下载的jar包中有这个类，是什么导致的

问题一：flink on yarn 运行，taskmanager 没有logs 是什么原因？

flink on yarn 运行，taskmanager 没有logs 是什么原因？

参考答案：

日志没调试好

关于本问题的更多回答可点击进行查看：

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

问题二：flink kafka source在有ck的情况下，flink kafkasource会如何处理？

flink kafka source在有ck的情况下，从上一次ck或者savepoint启动时，要是ck中的kafka offset不在当前kafka topic的offset范围内，就是出现了越界，flink kafka source会如何处理？有小伙伴碰到过这种情况吗？

参考答案：

你这个情况 ck找不到消费位置的时候，会根据你的消费kafka的配置

如果你配置的是 auto.reset.offset=earliest 那么会从你的topic当前的最早位置消费，如果配置的是latest 那么就是最新位置消费 ，

关于本问题的更多回答可点击进行查看：

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

问题三：flink1.18 拉的代码没有这个类，但是再 下载的jar包中 有这个类，这是啥意思？

flink1.18 拉的代码没有这个类，但是再 下载的jar包中 有这个类，这是啥意思？

参考答案：

缺依赖没导入进来呗，有没有这个类文件？如果有文件，没导入就是依赖问题

关于本问题的更多回答可点击进行查看：

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

问题四：Flink中webui为啥转圈圈啊？

Flink中webui为啥转圈圈啊？

cancel掉才会显示

看了下都没报错，standalone模式，但是没做免密（这个不影响把）

参考答案：

我遇到过 可能和版本有关

关于本问题的更多回答可点击进行查看：

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

问题五：使用阿里flink ctas同步数据从mysql->SR，有时候发现同步的延迟会偏高，怎么回事？

使用阿里flink ctas同步数据从mysql->SR，有时候发现同步的延迟会偏高，怎么回事？看了一下TM打印的日志，Stopped reading binlog after 0 events,

last recorded offset

参考答案：

看报错，是因为binlog检索或者处理出现了问题，导致中断，查看TaskManager日志，寻找可能导致延迟的具体错误或警告信息。

关于本问题的更多回答可点击进行查看：

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