diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/aggregate/StreamingAggBatch.java b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/aggregate/StreamingAggBatch.java
index 25774880027..060e1067780 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/aggregate/StreamingAggBatch.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/aggregate/StreamingAggBatch.java
@@ -267,7 +267,7 @@ public IterOutcome innerNext() {
             aggregator.setup(oContext, incoming, this, maxOutputRowCount);
           } catch (SchemaChangeException e) {
             UserException.Builder exceptionBuilder = UserException.functionError(e)
-                .message("A Schema change exception occured in calling setup() in generated code.");
+                .message("A Schema change exception occurred in calling setup() in generated code.");
             throw exceptionBuilder.build(logger);
           }
         }
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/server/options/PersistedOptionValue.java b/exec/java-exec/src/main/java/org/apache/drill/exec/server/options/PersistedOptionValue.java
index f101c32a80a..247c83e7302 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/server/options/PersistedOptionValue.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/server/options/PersistedOptionValue.java
@@ -56,7 +56,7 @@
 @JsonDeserialize(using = PersistedOptionValue.Deserializer.class)
 public class PersistedOptionValue {
   /**
-   * This is present for forward compatability with Drill 1.11 and earlier
+   * This is present for forward compatibility with Drill 1.11 and earlier
    */
   public static final String SYSTEM_TYPE = "SYSTEM";
   /**
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/work/fragment/FragmentExecutor.java b/exec/java-exec/src/main/java/org/apache/drill/exec/work/fragment/FragmentExecutor.java
index e13857ade67..a61b149ffdf 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/work/fragment/FragmentExecutor.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/work/fragment/FragmentExecutor.java
@@ -603,7 +603,7 @@ protected void processEvent(FragmentEvent event) {
       if (event.type.equals(EventType.RECEIVER_FINISHED)) {
         // Finish request
         if (terminate.get()) {
-          // We have already recieved a cancellation or we have terminated the event processor. Do not process anymore finish requests.
+          // We have already received a cancellation or we have terminated the event processor. Do not process anymore finish requests.
           return;
         }
       } else {