diff --git a/subprojects/parseq/src/main/java/com/linkedin/parseq/Engine.java b/subprojects/parseq/src/main/java/com/linkedin/parseq/Engine.java
index 75222281..81cc0ec7 100644
--- a/subprojects/parseq/src/main/java/com/linkedin/parseq/Engine.java
+++ b/subprojects/parseq/src/main/java/com/linkedin/parseq/Engine.java
@@ -58,7 +58,7 @@ public class Engine {
   private static final int DEFUALT_MAX_RELATIONSHIPS_PER_TRACE = 65536;
 
   public static final String MAX_CONCURRENT_PLANS = "_MaxConcurrentPlans_";
-  private static final int DEFUALT_MAX_CONCURRENT_PLANS = Integer.MAX_VALUE;
+  private static final int DEFAULT_MAX_CONCURRENT_PLANS = Integer.MAX_VALUE;
 
   public static final String DRAIN_SERIAL_EXECUTOR_QUEUE = "_DrainSerialExecutorQueue_";
   private static final boolean DEFAULT_DRAIN_SERIAL_EXECUTOR_QUEUE = true;
@@ -158,7 +158,7 @@ private static enum StateName {
     if (_properties.containsKey(MAX_CONCURRENT_PLANS)) {
       _maxConcurrentPlans = (Integer) getProperty(MAX_CONCURRENT_PLANS);
     } else {
-      _maxConcurrentPlans = DEFUALT_MAX_CONCURRENT_PLANS;
+      _maxConcurrentPlans = DEFAULT_MAX_CONCURRENT_PLANS;
     }
     _concurrentPlans = new Semaphore(_maxConcurrentPlans);
 
@@ -290,7 +290,7 @@ private final String defaultPlanClass(final Task<?> task) {
    * Engine's capacity is specified by a {@value #MAX_CONCURRENT_PLANS} configuration property. Use
    * {@link EngineBuilder#setEngineProperty(String, Object)} to set this property.
    * For the sake of backwards compatibility default value for a {@value #MAX_CONCURRENT_PLANS} is
-   * {@value #DEFUALT_MAX_CONCURRENT_PLANS} which essentially means "unbounded capacity".
+   * {@value #DEFAULT_MAX_CONCURRENT_PLANS} which essentially means "unbounded capacity".
    *
    * @param task the task to run
    * @throws IllegalStateException
@@ -307,7 +307,7 @@ public void run(final Task<?> task) {
    * Engine's capacity is specified by a {@value #MAX_CONCURRENT_PLANS} configuration property. Use
    * {@link EngineBuilder#setEngineProperty(String, Object)} to set this property.
    * For the sake of backwards compatibility default value for a {@value #MAX_CONCURRENT_PLANS} is
-   * {@value #DEFUALT_MAX_CONCURRENT_PLANS} which essentially means "unbounded capacity".
+   * {@value #DEFAULT_MAX_CONCURRENT_PLANS} which essentially means "unbounded capacity".
    *
    * @param task the task to run
    * @param planClass string that identifies a "class" of the Plan. Plan class ends up in a ParSeq
@@ -328,7 +328,7 @@ public void run(final Task<?> task, final String planClass) {
    * specified by a {@value #MAX_CONCURRENT_PLANS} configuration property. Use
    * {@link EngineBuilder#setEngineProperty(String, Object)} to set this property.
    * For the sake of backwards compatibility default value for a {@value #MAX_CONCURRENT_PLANS} is
-   * {@value #DEFUALT_MAX_CONCURRENT_PLANS} which essentially means "unbounded capacity".
+   * {@value #DEFAULT_MAX_CONCURRENT_PLANS} which essentially means "unbounded capacity".
    *
    * @param task the task to run
    */
@@ -344,7 +344,7 @@ public void blockingRun(final Task<?> task) {
    * specified by a {@value #MAX_CONCURRENT_PLANS} configuration property. Use
    * {@link EngineBuilder#setEngineProperty(String, Object)} to set this property.
    * For the sake of backwards compatibility default value for a {@value #MAX_CONCURRENT_PLANS} is
-   * {@value #DEFUALT_MAX_CONCURRENT_PLANS} which essentially means "unbounded capacity".
+   * {@value #DEFAULT_MAX_CONCURRENT_PLANS} which essentially means "unbounded capacity".
    *
    * @param task the task to run
    * @param planClass string that identifies a "class" of the Plan. Plan class ends up in a ParSeq
@@ -363,7 +363,7 @@ public void blockingRun(final Task<?> task, final String planClass) {
    * Runs the given task if Engine has a capacity to start new plan as specified by
    * {@value #MAX_CONCURRENT_PLANS} configuration parameter.
    * For the sake of backwards compatibility default value for a {@value #MAX_CONCURRENT_PLANS} is
-   * {@value #DEFUALT_MAX_CONCURRENT_PLANS} which essentially means "unbounded capacity".
+   * {@value #DEFAULT_MAX_CONCURRENT_PLANS} which essentially means "unbounded capacity".
    * Task passed in as a parameter becomes a root on a new Plan.
    * All tasks created and started as a consequence of a root task will belong to that plan and will share a Trace.
    * This method returns immediately and does not block. It returns {@code true} if Plan was successfully started.
@@ -378,7 +378,7 @@ public boolean tryRun(final Task<?> task) {
    * Runs the given task if Engine has a capacity to start new plan as specified by
    * {@value #MAX_CONCURRENT_PLANS} configuration parameter.
    * For the sake of backwards compatibility default value for a {@value #MAX_CONCURRENT_PLANS} is
-   * {@value #DEFUALT_MAX_CONCURRENT_PLANS} which essentially means "unbounded capacity".
+   * {@value #DEFAULT_MAX_CONCURRENT_PLANS} which essentially means "unbounded capacity".
    * Task passed in as a parameter becomes a root on a new Plan.
    * All tasks created and started as a consequence of a root task will belong to that plan and will share a Trace.
    * This method returns immediately and does not block. It returns {@code true} if Plan was successfully started.
@@ -399,7 +399,7 @@ public boolean tryRun(final Task<?> task, final String planClass) {
    * Runs the given task if Engine has a capacity to start new plan as specified by
    * {@value #MAX_CONCURRENT_PLANS} configuration parameter within specified amount of time.
    * For the sake of backwards compatibility default value for a {@value #MAX_CONCURRENT_PLANS} is
-   * {@value #DEFUALT_MAX_CONCURRENT_PLANS} which essentially means "unbounded capacity".
+   * {@value #DEFAULT_MAX_CONCURRENT_PLANS} which essentially means "unbounded capacity".
    * Task passed in as a parameter becomes a root on a new Plan.
    * All tasks created and started as a consequence of a root task will belong to that plan and will share a Trace.
    * If Engine does not have capacity to start the task, this method will block up to specified amount of
@@ -419,7 +419,7 @@ public boolean tryRun(final Task<?> task, final long timeout, final TimeUnit uni
    * Runs the given task if Engine has a capacity to start new plan as specified by
    * {@value #MAX_CONCURRENT_PLANS} configuration parameter within specified amount of time.
    * For the sake of backwards compatibility default value for a {@value #MAX_CONCURRENT_PLANS} is
-   * {@value #DEFUALT_MAX_CONCURRENT_PLANS} which essentially means "unbounded capacity".
+   * {@value #DEFAULT_MAX_CONCURRENT_PLANS} which essentially means "unbounded capacity".
    * Task passed in as a parameter becomes a root on a new Plan.
    * All tasks created and started as a consequence of a root task will belong to that plan and will share a Trace.
    * If Engine does not have capacity to start the task, this method will block up to specified amount of