Skip to content

Commit be3a996

Browse files
committed
[hotfix][core] Minor polish for IngestionTimeAssigner.java
1 parent 3cfc211 commit be3a996

File tree

1 file changed

+4
-5
lines changed

1 file changed

+4
-5
lines changed

flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java

+4-5
Original file line numberDiff line numberDiff line change
@@ -369,11 +369,10 @@ protected void info(String[] args) throws Exception {
369369
}
370370

371371
String description = program.getDescription();
372+
System.out.println();
372373
if (description != null) {
373-
System.out.println();
374374
System.out.println(description);
375375
} else {
376-
System.out.println();
377376
System.out.println("No description provided.");
378377
}
379378
} finally {
@@ -463,7 +462,7 @@ private <ClusterID> void listJobs(
463462
});
464463

465464
if (showRunning || showAll) {
466-
if (runningJobs.size() == 0) {
465+
if (runningJobs.isEmpty()) {
467466
System.out.println("No running jobs.");
468467
} else {
469468
System.out.println(
@@ -474,7 +473,7 @@ private <ClusterID> void listJobs(
474473
}
475474
}
476475
if (showScheduled || showAll) {
477-
if (scheduledJobs.size() == 0) {
476+
if (scheduledJobs.isEmpty()) {
478477
System.out.println("No scheduled jobs.");
479478
} else {
480479
System.out.println(
@@ -485,7 +484,7 @@ private <ClusterID> void listJobs(
485484
}
486485
}
487486
if (showAll) {
488-
if (terminatedJobs.size() != 0) {
487+
if (!terminatedJobs.isEmpty()) {
489488
System.out.println(
490489
"---------------------- Terminated Jobs -----------------------");
491490
printJobStatusMessages(terminatedJobs);

0 commit comments

Comments
 (0)