From ef0a3a43b485a23994a004c47f42e0d0954d4ebe Mon Sep 17 00:00:00 2001 From: maxwellpettit Date: Wed, 11 Jul 2018 12:03:52 -0400 Subject: [PATCH] 0003626: Incorrect default value for stream.to.file.enabled --- .../symmetric/AbstractSymmetricEngine.java | 17 +++++++++-------- 1 file changed, 9 insertions(+), 8 deletions(-) diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/AbstractSymmetricEngine.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/AbstractSymmetricEngine.java index 4c9ee567e0..29415b8189 100644 --- a/symmetric-core/src/main/java/org/jumpmind/symmetric/AbstractSymmetricEngine.java +++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/AbstractSymmetricEngine.java @@ -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) {