You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by da...@apache.org on 2015/11/06 20:02:20 UTC
incubator-apex-core git commit: misc typo fix
Repository: incubator-apex-core
Updated Branches:
refs/heads/devel-3 f35522b5a -> 29a4e223e
misc typo fix
Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/commit/29a4e223
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/29a4e223
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/29a4e223
Branch: refs/heads/devel-3
Commit: 29a4e223e1944576836a4419cbd79e7e24c64cab
Parents: f35522b
Author: David Yan <da...@datatorrent.com>
Authored: Wed Nov 4 17:04:43 2015 -0800
Committer: David Yan <da...@datatorrent.com>
Committed: Fri Nov 6 10:58:55 2015 -0800
----------------------------------------------------------------------
api/src/main/java/com/datatorrent/api/AutoMetric.java | 2 +-
api/src/main/java/com/datatorrent/api/Operator.java | 2 +-
.../main/java/com/datatorrent/stram/engine/StreamingContainer.java | 2 +-
.../java/com/datatorrent/stram/webapp/LogicalOperatorInfo.java | 1 -
4 files changed, 3 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/29a4e223/api/src/main/java/com/datatorrent/api/AutoMetric.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/com/datatorrent/api/AutoMetric.java b/api/src/main/java/com/datatorrent/api/AutoMetric.java
index ddf99c6..1c1fb25 100644
--- a/api/src/main/java/com/datatorrent/api/AutoMetric.java
+++ b/api/src/main/java/com/datatorrent/api/AutoMetric.java
@@ -87,7 +87,7 @@ public @interface AutoMetric
* <li>w - week</li>
* <li>M - month</li>
* <li>q - quarter</li>
- * <li>y - year</li
+ * <li>y - year</li>
* </ul>
*
* @return time buckets.
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/29a4e223/api/src/main/java/com/datatorrent/api/Operator.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/com/datatorrent/api/Operator.java b/api/src/main/java/com/datatorrent/api/Operator.java
index c362159..eb69266 100644
--- a/api/src/main/java/com/datatorrent/api/Operator.java
+++ b/api/src/main/java/com/datatorrent/api/Operator.java
@@ -36,7 +36,7 @@ public interface Operator extends Component<OperatorContext>
* processed data. This is the default mode.
* <br />
* In AT_MOST_ONCE mode in case of failure, the operator will start with the tuples which are being sent at the time
- * the failed operator is recovered. Unlike AT_LEAST_MOST once operator, it will not try to recover the tuples which
+ * the failed operator is recovered. Unlike AT_LEAST_ONCE operator, it will not try to recover the tuples which
* may have arrived while operator was down. Typically you would want to mark operators AT_MOST_ONCE if it does not
* materially impact your computation if a few tuples are omitted from the computation and the expected throughput is
* most likely to consume all the resources available for the operator or the DAG.
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/29a4e223/engine/src/main/java/com/datatorrent/stram/engine/StreamingContainer.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/com/datatorrent/stram/engine/StreamingContainer.java b/engine/src/main/java/com/datatorrent/stram/engine/StreamingContainer.java
index 1544c16..14e00a9 100644
--- a/engine/src/main/java/com/datatorrent/stram/engine/StreamingContainer.java
+++ b/engine/src/main/java/com/datatorrent/stram/engine/StreamingContainer.java
@@ -1445,7 +1445,7 @@ public class StreamingContainer extends YarnContainerMain
try {
signal.await();
} catch (InterruptedException ex) {
- logger.debug("Activation of operators interruped.", ex);
+ logger.debug("Activation of operators interrupted.", ex);
}
for (ComponentContextPair<Stream, StreamContext> pair : newStreams.values()) {
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/29a4e223/engine/src/main/java/com/datatorrent/stram/webapp/LogicalOperatorInfo.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/com/datatorrent/stram/webapp/LogicalOperatorInfo.java b/engine/src/main/java/com/datatorrent/stram/webapp/LogicalOperatorInfo.java
index e001f5a..9d8d648 100644
--- a/engine/src/main/java/com/datatorrent/stram/webapp/LogicalOperatorInfo.java
+++ b/engine/src/main/java/com/datatorrent/stram/webapp/LogicalOperatorInfo.java
@@ -18,7 +18,6 @@
*/
package com.datatorrent.stram.webapp;
-import com.datatorrent.stram.appdata.AppDataPushAgent;
import java.util.*;
import javax.xml.bind.annotation.*;
import org.apache.commons.lang3.mutable.MutableInt;