typo fix

Author: zstan

modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ExecutionContext.java

@@ -146,7 +146,7 @@ public class ExecutionContext<Row> extends AbstractQueryContext implements DataC
     private Object[] correlations = new Object[16];
 
     /** Modified entries holder. */
-    @Nullable private final TxAwareModifiedEntriesHolder mofiedEntriesHolder;
+    @Nullable private final TxAwareModifiedEntriesHolder modifiedEntriesHolder;
 
     /**
      * @param qctx Parent base query context.
@@ -188,7 +188,7 @@ public ExecutionContext(
         this.params = params;
         this.timeout = timeout;
         this.qryTxEntries = qryTxEntries;
-        this.mofiedEntriesHolder = mofiedEntriesHolder;
+        this.modifiedEntriesHolder = mofiedEntriesHolder;
 
         startTs = U.currentTimeMillis();
 
@@ -427,8 +427,8 @@ public void execute(RunnableX task, Consumer<Throwable> onError) {
 
         executor.execute(qryId, fragmentId(), () -> {
             try {
-                if (mofiedEntriesHolder != null)
-                    mofiedEntriesHolder.store(qryTxEntries);
+                if (modifiedEntriesHolder != null)
+                    modifiedEntriesHolder.store(qryTxEntries);
 
                 if (!isCancelled())
                     task.run();
@@ -437,8 +437,8 @@ public void execute(RunnableX task, Consumer<Throwable> onError) {
                 onError.accept(e);
             }
             finally {
-                if (mofiedEntriesHolder != null)
-                    mofiedEntriesHolder.detach();
+                if (modifiedEntriesHolder != null)
+                    modifiedEntriesHolder.detach();
             }
         });
     }

modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ExecutionServiceImpl.java

@@ -213,7 +213,7 @@ public class ExecutionServiceImpl<Row> extends AbstractService implements Execut
      *
      * @see TransactionConfiguration#isTxAwareQueriesEnabled()
      */
-    private TxAwareModifiedEntriesHolder mofiedEntriesHolder;
+    private TxAwareModifiedEntriesHolder modifiedEntriesHolder;
 
     /**
      * @param ctx Kernal.
@@ -487,15 +487,15 @@ public void injectService(InjectResourcesService injectSvc) {
         eventManager().addDiscoveryEventListener(discoLsnr, EventType.EVT_NODE_FAILED, EventType.EVT_NODE_LEFT);
 
         iteratorsHolder().init();
-        mofiedEntriesHolder = new TxAwareModifiedEntriesHolder(U.isTxAwareQueriesEnabled(ctx));
+        modifiedEntriesHolder = new TxAwareModifiedEntriesHolder(U.isTxAwareQueriesEnabled(ctx));
     }
 
     /** {@inheritDoc} */
     @Override public void tearDown() {
         eventManager().removeDiscoveryEventListener(discoLsnr, EventType.EVT_NODE_FAILED, EventType.EVT_NODE_LEFT);
 
         iteratorsHolder().tearDown();
-        mofiedEntriesHolder = null;
+        modifiedEntriesHolder = null;
     }
 
     /** */
@@ -528,7 +528,7 @@ private FragmentPlan prepareFragment(BaseQueryContext ctx, String jsonFragment)
                 ListFieldsQueryCursor<?> cur = mapAndExecutePlan(
                     qry,
                     (MultiStepPlan)plan,
-                    mofiedEntriesHolder
+                    modifiedEntriesHolder
                 );
 
                 cur.iterator().hasNext();
@@ -539,7 +539,7 @@ private FragmentPlan prepareFragment(BaseQueryContext ctx, String jsonFragment)
                 return mapAndExecutePlan(
                     qry,
                     (MultiStepPlan)plan,
-                    mofiedEntriesHolder
+                    modifiedEntriesHolder
                 );
 
             case EXPLAIN:
@@ -641,7 +641,7 @@ private ListFieldsQueryCursor<?> mapAndExecutePlan(
         MemoryTracker qryMemoryTracker = qry.createMemoryTracker(memoryTracker, cfg.getQueryMemoryQuota());
 
         final GridNearTxLocal userTx = Commons.queryTransaction(qry.context(), ctx.cache().context());
-        final Collection<QueryTxEntry> writeEntrs = userTx == null ?
+        final @Nullable Collection<QueryTxEntry> writeEntries = userTx == null ?
             mofiedEntriesHolder.retrieve() : ExecutionContext.transactionChanges(userTx.writeEntries());
 
         ExecutionContext<Row> ectx = new ExecutionContext<>(
@@ -658,7 +658,7 @@ private ListFieldsQueryCursor<?> mapAndExecutePlan(
             createIoTracker(locNodeId, qry.localQueryId()),
             timeout,
             qryParams,
-            writeEntrs,
+            writeEntries,
             mofiedEntriesHolder);
 
         Node<Row> node = new LogicalRelImplementor<>(ectx, partitionService(), mailboxRegistry(),

modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/TxAwareModifiedEntriesHolder.java

@@ -40,8 +40,8 @@ public void store(Collection<QueryTxEntry> items) {
             holder.set(items);
     }
 
-    /** Retirieve entries if applicable. */
-    public Collection<QueryTxEntry> retrieve() {
+    /** Retrieve entries if applicable. */
+    @Nullable public Collection<QueryTxEntry> retrieve() {
         if (holder != null)
             return holder.get();
         else