在Flink中实现流批一体处理，是否要求所有source都必须统一？

Flink实现流批一体的主要目标是使得流处理和批处理能够用同一套代码进行处理，无需再为流和批两种场景编写不同的代码。这主要通过在Flink的执行引擎层提供统一的数据处理流程Data Processing Pipeline (Logical Plan)来实现。

为了实现这一目标，Flink在SQL层和Table API上实现了流批一体化，这使得用户的业务逻辑只需要开发一遍，就可以同时在流和批的两种场景下使用。同时，Flink也在底层的DataStream API上实现了流批一体，预计这将在Flink的后续版本中实现。

具体到实现流批一体的条件或场景，首先需要的是Flink的版本支持。例如，Flink 1.10和1.11版本完成了SQL层的流批一体化和实现生产可用性。其次，需要使用的API是Table/SQL API或DataStream API。最后，对于source端的要求，目前并未明确指出需要统一。