-
Notifications
You must be signed in to change notification settings - Fork 550
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Dobe/fixnlstop #4092
Dobe/fixnlstop #4092
Conversation
@@ -419,6 +419,9 @@ private Result emitRow(Row row) { | |||
if (LOGGER.isTraceEnabled() && result != Result.CONTINUE) { | |||
LOGGER.trace("phase={} side=right method=emitRow result={}", phaseId, result); | |||
} | |||
if (result==Result.STOP){ |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
white spaces around == and before {
@@ -2,3 +2,4 @@ | |||
cluster.name: dev | |||
discovery.zen.ping.multicast.enabled: false | |||
psql.enabled: true | |||
stats.enabled: true |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Do we need that?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
yes i think so, it does not hurt, and it is good for investigation
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
My consideration is that we'll have these scheduled jobs running by default that might interfere with debugging, but we can switch if off if this is the case.
b78cbd8
to
0a69328
Compare
@@ -419,6 +419,9 @@ private Result emitRow(Row row) { | |||
if (LOGGER.isTraceEnabled() && result != Result.CONTINUE) { | |||
LOGGER.trace("phase={} side=right method=emitRow result={}", phaseId, result); | |||
} | |||
if (result == Result.STOP){ |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
white space before { ?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Igtm otherwise
0a69328
to
1f0a119
Compare
No description provided.