关于Flink SQL + Auron Collaboration有一些想法,

1、当前是计划重新开发一套flink-extension模块以连接native-engine吗,据我所了解目前auron的jniBridge与spark-memory关联较为密切,需要在native-engine中对spark-memory进行解藕。是否有计划将spark-extension中的部分逻辑进行拆分,以实现二者的共享。


2、Calc Operator的native实现,是否有计划在前后添加r2c,c2r operator,这块的添加逻辑是否也有计划在flink的改造中添加接口
3、当前对Flink的版本有选择吗,Flink的改造是否有接口的计划表(据我所了解需要在Phyiscal/ExecNode、Rule、Processor、OperatorChain等方面需要考虑)
 4、回撤类型、水位线、Checkpoint、时间服务、状态后端的支持可能是后续阶段的重点,是否有计划在native-engine中支持。

Reply via email to