https://github.com/vesoft-inc/nebula-java/commit/e3207167dbf574ab0b84a9ff9d8563129a088c2d 我看到官网有这个提交,所以想问下,我们在Spark/flink是否可以用序列化session
这个在nebula-java的哪个版本
com.vesoft
client
3.0.0
这个3.0.0的版本的session没有实现序列化啊
这个 pr 只是合到 master,还没发
这个大概什么时候发 我这边可以自己打包测试下吗 因为这个session序列化对我并发写入有很大作用 不用频繁创建销毁
如果用最新的 java,可以用 snapshot 的坐标
<dependency>
<groupId>com.vesoft</groupId>
<artifactId>client</artifactId>
<version>3.0-SNAPSHOT</version>
</dependency>
我试试
<repositories>
<repository>
<id>snapshots</id>
<url>https://oss.sonatype.org/content/repositories/snapshots/</url>
</repository>
</repositories>
1 个赞
好的 我看看
可以拉到新包 但是 我看 pr 写的修改Session为序列化 实际使用还是有问题:object not serializable (class: com.vesoft.nebula.graph.GraphService$Client, value: com.vesoft.nebula.graph.GraphService$Client@6abaa14b)
我打断看了下主要是:
GraphService.Client没有序列化导致SyncConnection序列化异常 导致Session 序列化
由于 SyncConnection
中的 GraphService.Client
是通过 fbthrift 生成出来的结构, 这个结构不能被序列化, 所以目前还没办法做 session 序列化
明白了
此话题已在最后回复的 7 天后被自动关闭。不再允许新回复。