Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
0003626: Incorrect default value for stream.to.file.enabled
  • Loading branch information
maxwellpettit committed Jul 11, 2018
1 parent 708867f commit ef0a3a4
Showing 1 changed file with 9 additions and 8 deletions.
Expand Up @@ -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) {
Expand Down

0 comments on commit ef0a3a4

Please sign in to comment.