Skip to content

Commit 6efeafc

Browse files
Implement review feedback
Signed-off-by: Lehmann_Fabian <[email protected]>
1 parent 20e6983 commit 6efeafc

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

src/main/java/cws/k8s/scheduler/publishDir/InformPublishFinishedRunnable.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,6 @@ public class InformPublishFinishedRunnable implements Runnable {
1616
@Override
1717
public void run() {
1818
execHolder.finishedOnNode( nodeLocation );
19-
currentPublishJobsPerNode.compute( nodeLocation, ( k, v ) -> v == null ? 0 : v - 1 );
19+
currentPublishJobsPerNode.compute( nodeLocation, ( k, v ) -> v == null ? 0 : Math.max(0, v - 1) );
2020
}
2121
}

src/main/java/cws/k8s/scheduler/publishDir/PublishManager.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ public class PublishManager {
3131
private final PublishExecHolder execHolder = new PublishExecHolder();
3232
private final Map<NodeLocation, Integer> currentPublishJobsPerNode = new ConcurrentHashMap<>();
3333
// Maximum number of parallel publish jobs per node
34-
private final int MAX_COPY_PER_NODE = 1;
34+
private final static int MAX_COPY_PER_NODE = 1;
3535

3636
/**
3737
* Maximum number of arguments for the publish command.

0 commit comments

Comments
 (0)