You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by th...@apache.org on 2015/10/31 06:24:31 UTC
[1/2] incubator-apex-core git commit: Add since tags for release 3.2.0
Repository: incubator-apex-core
Updated Branches:
refs/heads/devel-3 2c8639e94 -> af7179cba
Add since tags for release 3.2.0
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/5731d22c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/5731d22c
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/5731d22c
Branch: refs/heads/devel-3
Commit: 5731d22c2908231720b1e445c1e777d570547fb8
Parents: 2c8639e
Author: Thomas Weise <th...@datatorrent.com>
Authored: Tue Oct 20 18:11:36 2015 -0700
Committer: Thomas Weise <th...@datatorrent.com>
Committed: Fri Oct 30 22:04:32 2015 -0700
----------------------------------------------------------------------
api/src/main/java/com/datatorrent/api/annotation/Name.java | 5 +++++
.../main/java/com/datatorrent/bufferserver/util/VarInt.java | 5 +++++
.../com/datatorrent/common/metric/SingleMetricAggregator.java | 5 +++++
.../com/datatorrent/common/metric/sum/DoubleSumAggregator.java | 5 +++++
.../com/datatorrent/common/metric/sum/LongSumAggregator.java | 5 +++++
.../src/main/java/com/datatorrent/stram/api/AppDataSource.java | 5 +++++
engine/src/main/java/com/datatorrent/stram/engine/Slider.java | 5 +++++
.../datatorrent/stram/plan/logical/DefaultKryoStreamCodec.java | 2 ++
.../stram/plan/logical/StreamCodecWrapperForPersistance.java | 6 +++++-
.../stram/stream/PartitionAwareSinkForPersistence.java | 6 +++++-
.../main/java/com/datatorrent/stram/webapp/ContainerInfo.java | 5 +++++
.../datatorrent/stram/webapp/asm/CompactAnnotationNode.java | 5 +++++
.../com/datatorrent/stram/webapp/asm/CompactFieldNode.java | 5 +++++
.../datatorrent/stram/webapp/asm/FieldSignatureVisitor.java | 5 +++++
14 files changed, 67 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/5731d22c/api/src/main/java/com/datatorrent/api/annotation/Name.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/com/datatorrent/api/annotation/Name.java b/api/src/main/java/com/datatorrent/api/annotation/Name.java
index a93f59c..2d03a92 100644
--- a/api/src/main/java/com/datatorrent/api/annotation/Name.java
+++ b/api/src/main/java/com/datatorrent/api/annotation/Name.java
@@ -20,6 +20,11 @@ package com.datatorrent.api.annotation;
import java.lang.annotation.*;
+/**
+ * <p>Name class.</p>
+ *
+ * @since 3.2.0
+ */
@Documented
@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/5731d22c/bufferserver/src/main/java/com/datatorrent/bufferserver/util/VarInt.java
----------------------------------------------------------------------
diff --git a/bufferserver/src/main/java/com/datatorrent/bufferserver/util/VarInt.java b/bufferserver/src/main/java/com/datatorrent/bufferserver/util/VarInt.java
index 0c54429..6f12cc4 100644
--- a/bufferserver/src/main/java/com/datatorrent/bufferserver/util/VarInt.java
+++ b/bufferserver/src/main/java/com/datatorrent/bufferserver/util/VarInt.java
@@ -17,6 +17,11 @@
* under the License.
*/
package com.datatorrent.bufferserver.util;
+/**
+ * <p>VarInt class.</p>
+ *
+ * @since 3.2.0
+ */
public class VarInt extends com.datatorrent.netlet.util.VarInt
{
public static void read(SerializedData current)
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/5731d22c/common/src/main/java/com/datatorrent/common/metric/SingleMetricAggregator.java
----------------------------------------------------------------------
diff --git a/common/src/main/java/com/datatorrent/common/metric/SingleMetricAggregator.java b/common/src/main/java/com/datatorrent/common/metric/SingleMetricAggregator.java
index 468e5c6..9b568d2 100644
--- a/common/src/main/java/com/datatorrent/common/metric/SingleMetricAggregator.java
+++ b/common/src/main/java/com/datatorrent/common/metric/SingleMetricAggregator.java
@@ -19,6 +19,11 @@
package com.datatorrent.common.metric;
import java.util.Collection;
+/**
+ * <p>SingleMetricAggregator interface.</p>
+ *
+ * @since 3.2.0
+ */
public interface SingleMetricAggregator
{
Object aggregate(Collection<Object> metricValues);
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/5731d22c/common/src/main/java/com/datatorrent/common/metric/sum/DoubleSumAggregator.java
----------------------------------------------------------------------
diff --git a/common/src/main/java/com/datatorrent/common/metric/sum/DoubleSumAggregator.java b/common/src/main/java/com/datatorrent/common/metric/sum/DoubleSumAggregator.java
index ee6df6b..70e6c61 100644
--- a/common/src/main/java/com/datatorrent/common/metric/sum/DoubleSumAggregator.java
+++ b/common/src/main/java/com/datatorrent/common/metric/sum/DoubleSumAggregator.java
@@ -25,6 +25,11 @@ import com.datatorrent.api.annotation.Name;
import com.datatorrent.common.metric.SingleMetricAggregator;
+/**
+ * <p>DoubleSumAggregator class.</p>
+ *
+ * @since 3.2.0
+ */
@Name("sum")
public class DoubleSumAggregator implements SingleMetricAggregator, Serializable
{
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/5731d22c/common/src/main/java/com/datatorrent/common/metric/sum/LongSumAggregator.java
----------------------------------------------------------------------
diff --git a/common/src/main/java/com/datatorrent/common/metric/sum/LongSumAggregator.java b/common/src/main/java/com/datatorrent/common/metric/sum/LongSumAggregator.java
index e1cb869..ad88dda 100644
--- a/common/src/main/java/com/datatorrent/common/metric/sum/LongSumAggregator.java
+++ b/common/src/main/java/com/datatorrent/common/metric/sum/LongSumAggregator.java
@@ -25,6 +25,11 @@ import com.datatorrent.api.annotation.Name;
import com.datatorrent.common.metric.SingleMetricAggregator;
+/**
+ * <p>LongSumAggregator class.</p>
+ *
+ * @since 3.2.0
+ */
@Name("sum")
public class LongSumAggregator implements SingleMetricAggregator, Serializable
{
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/5731d22c/engine/src/main/java/com/datatorrent/stram/api/AppDataSource.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/com/datatorrent/stram/api/AppDataSource.java b/engine/src/main/java/com/datatorrent/stram/api/AppDataSource.java
index 1246721..e6a4606 100644
--- a/engine/src/main/java/com/datatorrent/stram/api/AppDataSource.java
+++ b/engine/src/main/java/com/datatorrent/stram/api/AppDataSource.java
@@ -21,6 +21,11 @@ package com.datatorrent.stram.api;
import java.util.Map;
import org.codehaus.jackson.map.annotate.JsonSerialize;
+/**
+ * <p>AppDataSource class.</p>
+ *
+ * @since 3.2.0
+ */
@JsonSerialize(include = JsonSerialize.Inclusion.NON_NULL)
public class AppDataSource
{
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/5731d22c/engine/src/main/java/com/datatorrent/stram/engine/Slider.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/com/datatorrent/stram/engine/Slider.java b/engine/src/main/java/com/datatorrent/stram/engine/Slider.java
index 27b77e8..d6c1b5c 100644
--- a/engine/src/main/java/com/datatorrent/stram/engine/Slider.java
+++ b/engine/src/main/java/com/datatorrent/stram/engine/Slider.java
@@ -26,6 +26,11 @@ import java.util.List;
import com.datatorrent.api.*;
import com.datatorrent.api.Context.OperatorContext;
import com.datatorrent.api.Operator.Unifier;
+/**
+ * <p>Slider class.</p>
+ *
+ * @since 3.2.0
+ */
public class Slider implements Unifier<Object>, Operator.IdleTimeHandler, Operator.ActivationListener<OperatorContext>, StatsListener, Serializable, Operator.CheckpointListener
{
private List<List<Object>> cache;
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/5731d22c/engine/src/main/java/com/datatorrent/stram/plan/logical/DefaultKryoStreamCodec.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/com/datatorrent/stram/plan/logical/DefaultKryoStreamCodec.java b/engine/src/main/java/com/datatorrent/stram/plan/logical/DefaultKryoStreamCodec.java
index 2dcb998..23009e3 100644
--- a/engine/src/main/java/com/datatorrent/stram/plan/logical/DefaultKryoStreamCodec.java
+++ b/engine/src/main/java/com/datatorrent/stram/plan/logical/DefaultKryoStreamCodec.java
@@ -36,6 +36,8 @@ import com.datatorrent.netlet.util.Slice;
/**
* This codec is used for serializing the objects of class which are Kryo
* serializable. Used for stream codec wrapper used for persistence
+ *
+ * @since 3.2.0
*/
public class DefaultKryoStreamCodec<T> extends SerializableObject implements StreamCodec<T>
{
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/5731d22c/engine/src/main/java/com/datatorrent/stram/plan/logical/StreamCodecWrapperForPersistance.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/com/datatorrent/stram/plan/logical/StreamCodecWrapperForPersistance.java b/engine/src/main/java/com/datatorrent/stram/plan/logical/StreamCodecWrapperForPersistance.java
index 17be686..c6ac5e7 100644
--- a/engine/src/main/java/com/datatorrent/stram/plan/logical/StreamCodecWrapperForPersistance.java
+++ b/engine/src/main/java/com/datatorrent/stram/plan/logical/StreamCodecWrapperForPersistance.java
@@ -29,7 +29,11 @@ import com.datatorrent.api.Partitioner.PartitionKeys;
import com.datatorrent.api.StreamCodec;
import com.datatorrent.netlet.util.Slice;
import com.datatorrent.stram.plan.logical.LogicalPlan.InputPortMeta;
-
+/**
+ * <p>StreamCodecWrapperForPersistance class.</p>
+ *
+ * @since 3.2.0
+ */
public class StreamCodecWrapperForPersistance<T> implements StreamCodec<T>, Serializable
{
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/5731d22c/engine/src/main/java/com/datatorrent/stram/stream/PartitionAwareSinkForPersistence.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/com/datatorrent/stram/stream/PartitionAwareSinkForPersistence.java b/engine/src/main/java/com/datatorrent/stram/stream/PartitionAwareSinkForPersistence.java
index e5a2b77..b6fdbe9 100644
--- a/engine/src/main/java/com/datatorrent/stram/stream/PartitionAwareSinkForPersistence.java
+++ b/engine/src/main/java/com/datatorrent/stram/stream/PartitionAwareSinkForPersistence.java
@@ -23,7 +23,11 @@ import java.util.Set;
import com.datatorrent.api.Sink;
import com.datatorrent.stram.plan.logical.StreamCodecWrapperForPersistance;
-
+/**
+ * <p>PartitionAwareSinkForPersistence class.</p>
+ *
+ * @since 3.2.0
+ */
public class PartitionAwareSinkForPersistence extends PartitionAwareSink<Object>
{
StreamCodecWrapperForPersistance<Object> serdeForPersistence;
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/5731d22c/engine/src/main/java/com/datatorrent/stram/webapp/ContainerInfo.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/com/datatorrent/stram/webapp/ContainerInfo.java b/engine/src/main/java/com/datatorrent/stram/webapp/ContainerInfo.java
index b3e15c3..06300ce 100644
--- a/engine/src/main/java/com/datatorrent/stram/webapp/ContainerInfo.java
+++ b/engine/src/main/java/com/datatorrent/stram/webapp/ContainerInfo.java
@@ -24,6 +24,11 @@ import javax.xml.bind.annotation.XmlRootElement;
import com.datatorrent.api.annotation.RecordField;
+/**
+ * <p>ContainerInfo class.</p>
+ *
+ * @since 3.2.0
+ */
@XmlRootElement(name = "container")
@XmlAccessorType(XmlAccessType.FIELD)
public class ContainerInfo {
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/5731d22c/engine/src/main/java/com/datatorrent/stram/webapp/asm/CompactAnnotationNode.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/com/datatorrent/stram/webapp/asm/CompactAnnotationNode.java b/engine/src/main/java/com/datatorrent/stram/webapp/asm/CompactAnnotationNode.java
index 99ddd75..7860378 100644
--- a/engine/src/main/java/com/datatorrent/stram/webapp/asm/CompactAnnotationNode.java
+++ b/engine/src/main/java/com/datatorrent/stram/webapp/asm/CompactAnnotationNode.java
@@ -19,6 +19,11 @@
package com.datatorrent.stram.webapp.asm;
import java.util.Map;
+/**
+ * <p>CompactAnnotationNode class.</p>
+ *
+ * @since 3.2.0
+ */
public class CompactAnnotationNode {
private String desc;
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/5731d22c/engine/src/main/java/com/datatorrent/stram/webapp/asm/CompactFieldNode.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/com/datatorrent/stram/webapp/asm/CompactFieldNode.java b/engine/src/main/java/com/datatorrent/stram/webapp/asm/CompactFieldNode.java
index bd5991e..778fc41 100644
--- a/engine/src/main/java/com/datatorrent/stram/webapp/asm/CompactFieldNode.java
+++ b/engine/src/main/java/com/datatorrent/stram/webapp/asm/CompactFieldNode.java
@@ -23,6 +23,11 @@ import java.util.List;
import org.apache.xbean.asm5.tree.AnnotationNode;
import org.apache.xbean.asm5.tree.FieldNode;
+/**
+ * <p>CompactFieldNode class.</p>
+ *
+ * @since 3.2.0
+ */
public class CompactFieldNode {
private String name;
private String desc;
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/5731d22c/engine/src/main/java/com/datatorrent/stram/webapp/asm/FieldSignatureVisitor.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/com/datatorrent/stram/webapp/asm/FieldSignatureVisitor.java b/engine/src/main/java/com/datatorrent/stram/webapp/asm/FieldSignatureVisitor.java
index c58fe7b..24b71d9 100644
--- a/engine/src/main/java/com/datatorrent/stram/webapp/asm/FieldSignatureVisitor.java
+++ b/engine/src/main/java/com/datatorrent/stram/webapp/asm/FieldSignatureVisitor.java
@@ -20,6 +20,11 @@ package com.datatorrent.stram.webapp.asm;
import org.apache.xbean.asm5.signature.SignatureVisitor;
+/**
+ * <p>FieldSignatureVisitor class.</p>
+ *
+ * @since 3.2.0
+ */
public class FieldSignatureVisitor extends BaseSignatureVisitor{
private Type fieldType;
[2/2] incubator-apex-core git commit: Update CHANGELOG for v3.2.0
Posted by th...@apache.org.
Update CHANGELOG for v3.2.0
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/af7179cb
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/af7179cb
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/af7179cb
Branch: refs/heads/devel-3
Commit: af7179cba6290926e782f65466f4efabb3e89a34
Parents: 5731d22
Author: Thomas Weise <th...@datatorrent.com>
Authored: Fri Oct 30 22:10:02 2015 -0700
Committer: Thomas Weise <th...@datatorrent.com>
Committed: Fri Oct 30 22:10:02 2015 -0700
----------------------------------------------------------------------
CHANGELOG.md | 44 ++++++++++++++++++++++++++++++++++++++++++--
1 file changed, 42 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/af7179cb/CHANGELOG.md
----------------------------------------------------------------------
diff --git a/CHANGELOG.md b/CHANGELOG.md
index af1ca53..2d23dd7 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -2,19 +2,59 @@ Apex Changelog
========================================================================================================================
-Version 3.1.0
+Version 3.2.0-incubating - 2015-10-23
------------------------------------------------------------------------------------------------------------------------
+### Bug
+* [APEX-56] - Controlled plan modification on operator shutdown
+* [APEX-88] - Stray directories under working directory when running tests using StramLocalCluster
+* [APEX-89] - Javascript error when launching app on CDH 5.2 (hadoop 2.5.0)
+* [APEX-93] - Persist operators need a re-deploy after a sink being persisted is dynamically partitioned
+* [APEX-96] - AsyncFSStorageAgent loses synccheckpoint flag value during serialization/deserialization
+* [APEX-97] - syncCheckpoint property on AsyncFSStorageAgent not working
+* [APEX-98] - WindowGenerator.getWindowMillis loses precisions
+* [APEX-100] - StreamingContainerManagerTest.testAppDataPush uses hardcoded port
+* [APEX-101] - Negative Memory reported for Application Master
+* [APEX-102] - AppDataPushAgent Not Adding timeBuckets and dimensionsAggregators
+* [APEX-111] - dtcli: show-logical-plan with app package does not list the applications in the app package
+* [APEX-112] - Property change on logical operator converts from null to "null"(string)
+* [APEX-113] - Application Master not setting correct temp location
+* [APEX-114] - Stateful Stream Codec Exception
+* [APEX-117] - When Using Double Max Aggregator Data Stops Being Pushed By AppDataPushAgent
+* [APEX-118] - Sometimes the collection of metric values passed to an AutoMetric aggregator is empty
+* [APEX-120] - AsyncFSStorageAgentTest unit tests fail
+* [APEX-121] - Making sure that state is transferred to client for Statefull Codec
+* [APEX-126] - handleIdleTime Called Outside Of The Space Between beginWindow and endWindow
+* [APEX-149] - In secure mode non-HA setup STRAM web service calls are failing
+* [APEX-159] - StramMiniClusterTest.testOperatorFailureRecovery succeeds with unexpected error condition
+* [APEX-184] - When There Are 8 Or More Subscribers Buffer Server Can Become Blocked
+* [APEX-198] - Unit tests created remnant directories outside of target directory
+* [APEX-212] - Null pointer exception after all physical operators are removed.
+
+### Task
+* [APEX-16] - Configure Checkstyle plugin
+* [APEX-124] - Set the default temp location in pom
+
### Improvement
-* [APEX-12] - Fix Base Operator To Not Show Name Property In App Builder
+* [APEX-22] - Ability to re-declare ports
+* [APEX-68] - Buffer server should use a separate thread to spool blocks to disk
+* [APEX-115] - Use containers set temp location
+
+
+
+Version 3.1.0
+------------------------------------------------------------------------------------------------------------------------
### Bug
+* [APEX-12] - Fix Base Operator To Not Show Name Property In App Builder
* [APEX-35] - Test exceptions due to missing directory in saveMetaInfo
* [APEX-36] - FSStorageAgent to account for HDFS lease when writing checkpoint files
* [APEX-37] - Container and operator json line file in StreamingContainerManager should not be appended from previous app attempt
* [APEX-43] - SchemaSupport: TUPLE_CLASS attribute should use Class2String StringCodec
* [APEX-56] - Controlled plan modification on operator shutdown
+### Improvement
+* [APEX-13] - Unblock operator thread from checkpoint writes
Version 3.0.0