flink使用nebula-flink-connector 3.0.0流处理时session过期导致数据同步失败问题

问答 问题
,
3

:grinning:目前我是重写了nebula-flink-connector3.0.0里面源代码的部分类，如下
image

image
image886×476 39.2 KB

image
image1123×1313 152 KB

image
image1325×1187 124 KB

还有一个NebulaVertexBatchExecutor类跟上图同理改法