diff --git a/examples/java/src/main/java/org/apache/beam/examples/subprocess/kernel/SubProcessKernel.java b/examples/java/src/main/java/org/apache/beam/examples/subprocess/kernel/SubProcessKernel.java
index e45bf5bf2eee3..8b9f3c13113e0 100644
--- a/examples/java/src/main/java/org/apache/beam/examples/subprocess/kernel/SubProcessKernel.java
+++ b/examples/java/src/main/java/org/apache/beam/examples/subprocess/kernel/SubProcessKernel.java
@@ -117,10 +117,8 @@ private ProcessBuilder prepareBuilder(ProcessBuilder builder, SubProcessCommandL
     builder.command().add(1, outPutFiles.resultFile.toString());
 
     // Shift commands by 2 ordinal positions and load into the builder
-    if (commands != null) {
-      for (SubProcessCommandLineArgs.Command s : commands.getParameters()) {
-        builder.command().add(s.ordinalPosition + 2, s.value);
-      }
+    for (SubProcessCommandLineArgs.Command s : commands.getParameters()) {
+      builder.command().add(s.ordinalPosition + 2, s.value);
     }
 
     builder.redirectError(Redirect.appendTo(outPutFiles.errFile.toFile()));
diff --git a/runners/core-java/src/main/java/org/apache/beam/runners/core/MergingActiveWindowSet.java b/runners/core-java/src/main/java/org/apache/beam/runners/core/MergingActiveWindowSet.java
index 907fbaa449c94..e8b41b09570f1 100644
--- a/runners/core-java/src/main/java/org/apache/beam/runners/core/MergingActiveWindowSet.java
+++ b/runners/core-java/src/main/java/org/apache/beam/runners/core/MergingActiveWindowSet.java
@@ -255,12 +255,10 @@ private void recordMerge(Collection<W> toBeMerged, W mergeResult) throws Excepti
       checkState(otherStateAddressWindows != null,
                                "Window %s is not ACTIVE or NEW", other);
 
-      if (otherStateAddressWindows != null) {
-        for (W otherStateAddressWindow : otherStateAddressWindows) {
-          // Since otherTarget equiv other AND other equiv mergeResult
-          // THEN otherTarget equiv mergeResult.
-          newStateAddressWindows.add(otherStateAddressWindow);
-        }
+      for (W otherStateAddressWindow : otherStateAddressWindows) {
+        // Since otherTarget equiv other AND other equiv mergeResult
+        // THEN otherTarget equiv mergeResult.
+        newStateAddressWindows.add(otherStateAddressWindow);
       }
       activeWindowToStateAddressWindows.remove(other);
 
diff --git a/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/interpreter/BeamSqlFnExecutor.java b/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/interpreter/BeamSqlFnExecutor.java
index 5a3ef4066da59..846c7205f21b4 100644
--- a/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/interpreter/BeamSqlFnExecutor.java
+++ b/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/interpreter/BeamSqlFnExecutor.java
@@ -502,7 +502,7 @@ static BeamSqlExpression buildExpression(RexNode rexNode) {
           String.format("%s is not supported yet", rexNode.getClass().toString()));
     }
 
-    if (ret != null && !ret.accept()) {
+    if (!ret.accept()) {
       throw new IllegalStateException(
           ret.getClass().getSimpleName() + " does not accept the operands.(" + rexNode + ")");
     }
diff --git a/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamAggregationRule.java b/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamAggregationRule.java
index 9521070ae5b12..429949fe335d5 100644
--- a/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamAggregationRule.java
+++ b/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamAggregationRule.java
@@ -49,9 +49,7 @@ public void onMatch(RelOptRuleCall call) {
     final Aggregate aggregate = call.rel(0);
     final Project project = call.rel(1);
     RelNode x = updateWindow(call, aggregate, project);
-    if (x != null) {
-      call.transformTo(x);
-    }
+    call.transformTo(x);
   }
 
   private static RelNode updateWindow(RelOptRuleCall call, Aggregate aggregate, Project project) {