nebula-flink-connector 3.0.0更新edge报错

问答 问题
,
1

在进行edge报错的时候报错：
[nebula-write-output-format-thread-1] ERROR o.a.f.c.n.s.NebulaEdgeBatchExecutor - [executeBatch,85] - write data failed: SyntaxError: syntax error near ` ’

2

把具体的写入边的代码语句贴下。

3

最后我发现在对没有属性的edge做更新的时候会报这个错 :grinning: 在这里顺便想咨询下在多source和多sink的情况下，这个报错信息如何能定位到某一个具体的source或者sink的图空间、tag/edge呢，或者可以提供一点自己实现的思路建议吗

4

写入失败时会有日志输出，查找关键词：failed to write ${exec} for ${result.getErrorMessage}
通过日志可以看到是哪个tag/edge 写失败以及失败原因。

如果日志有不太清晰的地方，欢迎来给我们提issue 来改进优化 Issues · vesoft-inc/nebula-spark-connector · GitHub

1 个赞
6

你好 这是我实际运行的日志（更新没有属性的edge）并没有你说的这个关键词，不知道是要到哪里看还是说要先设置 如下

+I[userTagRelation39574, person270]
+I[userTagRelation39574, userTagSetting2647]
10:53:31.964 [nebula-write-output-format-thread-1] ERROR o.a.f.c.n.s.NebulaEdgeBatchExecutor - [executeBatch,85] - write data failed: SyntaxError: syntax error near ' 10:53:31.965 [nebula-write-output-format-thread-1] ERROR o.a.f.c.n.s.NebulaEdgeBatchExecutor - [executeBatch,85] - write data failed: SyntaxError: syntax error near ’

7

抱歉，我上面回复成了spark conenctor的日志了，flink connector 你可以搜一下 insert error statements: 的日志。
image