Skip to content
This repository was archived by the owner on Feb 18, 2019. It is now read-only.

Commit b95fa11

Browse files
committed
updating to the newer version of the library
1 parent 419c3f2 commit b95fa11

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

src/main/java/io/radanalytics/operator/cluster/ClusterOperator.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -63,8 +63,8 @@ protected void onModify(ClusterInfo newCluster) {
6363
}
6464

6565
if (existingCluster.getWorkerNodes() != newWorkers) {
66-
log.info("{}scaling{} from {}{}{} worker replicas to {}{}{}", ANSI_G, ANSI_RESET, ANSI_Y,
67-
existingCluster.getWorkerNodes(), ANSI_RESET, ANSI_Y, newWorkers, ANSI_RESET);
66+
log.info("{}scaling{} from {}{}{} worker replicas to {}{}{}", gr(), xx(), ye(),
67+
existingCluster.getWorkerNodes(), xx(), ye(), newWorkers, xx());
6868
client.replicationControllers().withName(name + "-w").scale(newWorkers);
6969
clusters.put(newCluster);
7070
}

src/main/java/io/radanalytics/operator/cluster/ProcessRunner.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,7 @@ public static void runCommand(String command) {
3737
}
3838
String stdOutput = sb.toString();
3939
if (!stdOutput.isEmpty()) {
40-
log.info("{}{}{}", ANSI_G, stdOutput, ANSI_RESET);
40+
log.info("{}{}{}", gr(), stdOutput, xx());
4141
}
4242
in.close();
4343

@@ -47,7 +47,7 @@ public static void runCommand(String command) {
4747
}
4848
String errOutput = sb.toString();
4949
if (!errOutput.isEmpty()) {
50-
log.error("{}{}{}", ANSI_R, stdOutput, ANSI_RESET);
50+
log.error("{}{}{}", re(), stdOutput, xx());
5151
}
5252
err.close();
5353
} catch (IOException e) {

0 commit comments

Comments
 (0)