Skip to content

Commit

Permalink
0005494: Batch error missing method sendMissingForeignKeyRowsForLoad
Browse files Browse the repository at this point in the history
  • Loading branch information
erilong committed Oct 3, 2022
1 parent c66bfce commit 5139a66
Showing 1 changed file with 2 additions and 1 deletion.
Expand Up @@ -614,7 +614,8 @@ protected IDataWriter chooseDataWriter(Batch batch) {
if (parameterService.is(ParameterConstants.AUTO_RESOLVE_FOREIGN_KEY_VIOLATION_REVERSE_RELOAD)
&& listener.getCurrentBatch() != null && listener.isNewErrorForCurrentBatch()
&& listener.getCurrentBatch().isLoadFlag()
&& listener.getCurrentBatch().getSqlCode() == ErrorConstants.FK_VIOLATION_CODE) {
&& listener.getCurrentBatch().getSqlCode() == ErrorConstants.FK_VIOLATION_CODE
&& !Version.isOlderThanVersion(sourceNode.getSymmetricVersion(), "3.12.6")) {
engine.getDataService().reloadMissingForeignKeyRowsForLoad(sourceNode.getNodeId(), ctx.getBatch().getBatchId(),
listener.getCurrentBatch().getFailedLineNumber(), ctx.getTable(), ctx.getData(), Constants.CHANNEL_CONFIG);
}
Expand Down

0 comments on commit 5139a66

Please sign in to comment.