Skip to content

NIFI-6653 Change bootstrap port command handling #3722

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.

Sign up for GitHub

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

Closed
kevdoran wants to merge 1 commit into from
Closed

NIFI-6653 Change bootstrap port command handling #3722

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
10 changes: 9 additions & 1 deletion nifi-bootstrap/src/main/java/org/apache/nifi/bootstrap/RunNiFi.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -114,8 +114,10 @@ public class RunNiFi {
public static final String PING_CMD = "PING";
public static final String DUMP_CMD = "DUMP";

private static final int UNINITIALIZED_CC_PORT = -1;

private volatile boolean autoRestartNiFi = true;
private volatile int ccPort = -1;
private volatile int ccPort = UNINITIALIZED_CC_PORT;
private volatile long nifiPid = -1L;
private volatile String secretKey;
private volatile ShutdownHook shutdownHook;
Expand Down Expand Up @@ -1337,6 +1339,12 @@ void setAutoRestartNiFi(final boolean restart) {
}

void setNiFiCommandControlPort(final int port, final String secretKey) throws IOException {

if (this.secretKey != null && this.ccPort != UNINITIALIZED_CC_PORT) {
defaultLogger.warn("Blocking attempt to change NiFi command port and secret after they have already been initialized. requestedPort={}", port);
return;
}

this.ccPort = port;
this.secretKey = secretKey;

Expand Down