Skip to content
Permalink
Browse files

Merge branch '3.9' of https://github.com/JumpMind/symmetric-ds.git in…

…to 3.9
  • Loading branch information...
chenson42 committed Jul 11, 2018
2 parents d8638a5 + ef0a3a4 commit 284b60a219d914b30b8e3545bb5526f250d3a43d
@@ -741,14 +741,15 @@ protected void checkSystemIntegrity(Node node) {
}
}

boolean useExtractJob = parameterService.is(ParameterConstants.INITIAL_LOAD_USE_EXTRACT_JOB, true);
boolean streamToFile = parameterService.is(ParameterConstants.STREAM_TO_FILE_ENABLED, false);
if (useExtractJob && !streamToFile) {
throw new SymmetricException(String.format("Node '%s' is configured with confilcting parameters which may result in replication stopping and/or empty load batches. "
+ "One of these two parameters needs to be changed: %s=%s and %s=%s",
node.getNodeId(), ParameterConstants.INITIAL_LOAD_USE_EXTRACT_JOB, useExtractJob, ParameterConstants.STREAM_TO_FILE_ENABLED,
streamToFile));
}
boolean useExtractJob = parameterService.is(ParameterConstants.INITIAL_LOAD_USE_EXTRACT_JOB, true);
boolean streamToFile = parameterService.is(ParameterConstants.STREAM_TO_FILE_ENABLED, true);
if (useExtractJob && !streamToFile) {
throw new SymmetricException(String.format(
"Node '%s' is configured with confilcting parameters which may result in replication stopping and/or empty load batches. "
+ "One of these two parameters needs to be changed: %s=%s and %s=%s",
node != null ? node.getNodeId() : "null", ParameterConstants.INITIAL_LOAD_USE_EXTRACT_JOB,
useExtractJob, ParameterConstants.STREAM_TO_FILE_ENABLED, streamToFile));
}
}

public String getEngineDescription(String msg) {

0 comments on commit 284b60a

Please sign in to comment.
You can’t perform that action at this time.