intsmaze/flink-boot

懒松鼠Flink-Boot 脚手架让Flink全面拥抱Spring生态体系，使得开发者可以以Java WEB开发模式开发出分布式运行的流处理程序，懒松鼠让跨界变得更加简单。懒松鼠旨在让开发者以更底上手成本（不需要理解分布式计算的理论知识和Flink框架的细节）便可以快速编写业务代码实现。为了进一步提升开发者使用懒松鼠脚手架开发大型项目的敏捷的度，该脚手架默认集成Spring框架进行Bean管理，同时将微服务以及WEB开发领域中经常用到的框架集成进来，进一步提升开发速度。比如集成Mybatis ORM框架，Hibernate Validator校验框架,Spring Retry重试框架等，具体见下面的脚手架特性。

flink-boot's Issues

pom依赖缺失

flink-base模块中，由于引入了druid，所以需要添加如下依赖：

com.alibaba
druid

mysql mysql-connector-java

flink是否可以作为javaWeb的技术方案

javaWeb 开发选取 java+SSM 框架进行开发，分层清晰架构合理；
但javaWeb并发量和横向扩展性不足，在高并发的需求下也会有一些高并发的架构；
本人看到当前项目产生疑问 : 是否可以借助java-flink+SSM的方式来开发出高性能高可靠性的web项目呢？

直接集成spring boot 即可

Flink版本太低

现在flink已经到了1.12.0 但是代码使用的是1.7 版本有点太老了。有计划更新版本吗

SqlClient运行报错

通过继承BaseFlink实现的com.intsmaze.flink.client.SqlClient，运行的时候报错，查了一些资料说是需要给实体类添加无参构造，但是实际是存在的 com.intsmaze.flink.base.bean.SourceData，但仍然报如下的错误。
报错信息：
Exception in thread "main" org.apache.flink.table.api.ValidationException: Too many fields referenced from an atomic type.
at org.apache.flink.table.typeutils.FieldInfoUtils.extractFieldInfoFromAtomicType(FieldInfoUtils.java:393)
at org.apache.flink.table.typeutils.FieldInfoUtils.extractFieldInformation(FieldInfoUtils.java:264)
at org.apache.flink.table.typeutils.FieldInfoUtils.getFieldsInfo(FieldInfoUtils.java:232)
at org.apache.flink.table.api.java.internal.StreamTableEnvironmentImpl.lambda$asQueryOperation$0(StreamTableEnvironmentImpl.java:415)
at java.util.Optional.map(Optional.java:215)
at org.apache.flink.table.api.java.internal.StreamTableEnvironmentImpl.asQueryOperation(StreamTableEnvironmentImpl.java:414)
at org.apache.flink.table.api.java.internal.StreamTableEnvironmentImpl.fromDataStream(StreamTableEnvironmentImpl.java:205)
at org.apache.flink.table.api.java.internal.StreamTableEnvironmentImpl.createTemporaryView(StreamTableEnvironmentImpl.java:229)
at org.apache.flink.table.api.java.internal.StreamTableEnvironmentImpl.registerDataStream(StreamTableEnvironmentImpl.java:224)

能否一键运行

看着有些头大

有相关讲解视频吗？想好好学习下