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 <[email protected]> Authored: Wed Nov 4 17:04:43 2015 -0800 Committer: David Yan <[email protected]> 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;
