You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by vr...@apache.org on 2015/11/02 16:49:48 UTC
[01/11] incubator-apex-core git commit: APEX-223 #resolve Send
response to purge/reset requestor on the same thread (defaultEventLoop). Do
not explicitly disconnect,
wait for the client to decide whether to send more requests or to disconnect.
Repository: incubator-apex-core
Updated Branches:
refs/heads/feature-module 4ce1b365e -> 013ccbeee
APEX-223 #resolve Send response to purge/reset requestor on the same thread (defaultEventLoop). Do not explicitly disconnect, wait for the client to decide whether to send more requests or to disconnect.
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/aa288871
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/aa288871
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/aa288871
Branch: refs/heads/feature-module
Commit: aa288871c9e8cc0313becf63a9be129b3e42e083
Parents: 7f1f81f
Author: Vlad Rozov <v....@datatorrent.com>
Authored: Sun Oct 25 09:30:24 2015 -0700
Committer: Vlad Rozov <v....@datatorrent.com>
Committed: Sun Oct 25 09:30:24 2015 -0700
----------------------------------------------------------------------
.../datatorrent/bufferserver/server/Server.java | 24 +++-----------------
1 file changed, 3 insertions(+), 21 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/aa288871/bufferserver/src/main/java/com/datatorrent/bufferserver/server/Server.java
----------------------------------------------------------------------
diff --git a/bufferserver/src/main/java/com/datatorrent/bufferserver/server/Server.java b/bufferserver/src/main/java/com/datatorrent/bufferserver/server/Server.java
index cd45738..c4cdf5b 100644
--- a/bufferserver/src/main/java/com/datatorrent/bufferserver/server/Server.java
+++ b/bufferserver/src/main/java/com/datatorrent/bufferserver/server/Server.java
@@ -173,7 +173,7 @@ public class Server implements ServerListener
private final int blockSize;
private final int numberOfCacheBlocks;
- public void handlePurgeRequest(PurgeRequestTuple request, final AbstractLengthPrependerClient ctx) throws IOException
+ private void handlePurgeRequest(PurgeRequestTuple request, final AbstractLengthPrependerClient ctx) throws IOException
{
DataList dl;
dl = publisherBuffers.get(request.getIdentifier());
@@ -188,16 +188,7 @@ public class Server implements ServerListener
final byte[] tuple = PayloadTuple.getSerializedTuple(0, message.length);
System.arraycopy(message, 0, tuple, tuple.length - message.length, message.length);
- serverHelperExecutor.submit(new Runnable()
- {
- @Override
- public void run()
- {
- ctx.write(tuple);
- eventloop.disconnect(ctx);
- }
-
- });
+ ctx.write(tuple);
}
private void handleResetRequest(ResetRequestTuple request, final AbstractLengthPrependerClient ctx) throws IOException
@@ -219,16 +210,7 @@ public class Server implements ServerListener
final byte[] tuple = PayloadTuple.getSerializedTuple(0, message.length);
System.arraycopy(message, 0, tuple, tuple.length - message.length, message.length);
- serverHelperExecutor.submit(new Runnable()
- {
- @Override
- public void run()
- {
- ctx.write(tuple);
- eventloop.disconnect(ctx);
- }
-
- });
+ ctx.write(tuple);
}
/**
[03/11] incubator-apex-core git commit: - APEX-225 #resolve Adds
isConnected to DefaultInputPort
Posted by vr...@apache.org.
- APEX-225 #resolve Adds isConnected to DefaultInputPort
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/eb7d721f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/eb7d721f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/eb7d721f
Branch: refs/heads/feature-module
Commit: eb7d721f66b5a22840678c55602eeb82e03a2aba
Parents: aa28887
Author: Timothy Farkas <ti...@datatorrent.com>
Authored: Mon Oct 26 22:28:03 2015 -0700
Committer: Timothy Farkas <ti...@datatorrent.com>
Committed: Tue Oct 27 17:57:58 2015 -0700
----------------------------------------------------------------------
api/src/main/java/com/datatorrent/api/DefaultInputPort.java | 9 +++++++++
1 file changed, 9 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/eb7d721f/api/src/main/java/com/datatorrent/api/DefaultInputPort.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/com/datatorrent/api/DefaultInputPort.java b/api/src/main/java/com/datatorrent/api/DefaultInputPort.java
index e3998f0..2ed871d 100644
--- a/api/src/main/java/com/datatorrent/api/DefaultInputPort.java
+++ b/api/src/main/java/com/datatorrent/api/DefaultInputPort.java
@@ -55,6 +55,15 @@ public abstract class DefaultInputPort<T> implements InputPort<T>, Sink<T>
this.connected = connected;
}
+ /**
+ * Returns true if this port is connected and false otherwise.
+ * @return true if this port is connected and false otherwise.
+ */
+ public boolean isConnected()
+ {
+ return connected;
+ }
+
/** {@inheritDoc} */
@Override
public StreamCodec<T> getStreamCodec()
[06/11] incubator-apex-core git commit: APEX-229 #resolve upgraded
checkstyle maven plugin to 2.17 and checkstyle to 6.11.2 APEX-228 #resolve
added maven 3.0.5 as prerequisite.
Posted by vr...@apache.org.
APEX-229 #resolve upgraded checkstyle maven plugin to 2.17 and checkstyle to 6.11.2
APEX-228 #resolve added maven 3.0.5 as prerequisite.
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/8a960152
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/8a960152
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/8a960152
Branch: refs/heads/feature-module
Commit: 8a960152d4a290c547affff00e0227d5e3753e1a
Parents: 9049be7
Author: Vlad Rozov <v....@datatorrent.com>
Authored: Wed Oct 28 16:13:51 2015 -0700
Committer: Vlad Rozov <v....@datatorrent.com>
Committed: Wed Oct 28 16:13:51 2015 -0700
----------------------------------------------------------------------
pom.xml | 8 ++++++--
1 file changed, 6 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/8a960152/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index cbb6a81..d4ef633 100644
--- a/pom.xml
+++ b/pom.xml
@@ -48,6 +48,10 @@
</license>
</licenses>
+ <prerequisites>
+ <maven>3.0.5</maven>
+ </prerequisites>
+
<repositories>
<!-- added for semantic versioning check, won't be needed once we publish to central -->
<repository>
@@ -307,12 +311,12 @@
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-checkstyle-plugin</artifactId>
- <version>2.16</version>
+ <version>2.17</version>
<dependencies>
<dependency>
<groupId>com.puppycrawl.tools</groupId>
<artifactId>checkstyle</artifactId>
- <version>6.11</version>
+ <version>6.11.2</version>
</dependency>
</dependencies>
<executions>
[08/11] incubator-apex-core git commit: Add since tags for release
3.2.0
Posted by vr...@apache.org.
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/feature-module
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;
[11/11] incubator-apex-core git commit: Merge branch 'devel-3' of
https://github.com/apache/incubator-apex-core into feature-module
Posted by vr...@apache.org.
Merge branch 'devel-3' of https://github.com/apache/incubator-apex-core into feature-module
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/013ccbee
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/013ccbee
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/013ccbee
Branch: refs/heads/feature-module
Commit: 013ccbeee54879aea9cb0eda1e76642a17ee3c54
Parents: 4ce1b36 b4b7c07
Author: Vlad Rozov <v....@datatorrent.com>
Authored: Mon Nov 2 07:48:03 2015 -0800
Committer: Vlad Rozov <v....@datatorrent.com>
Committed: Mon Nov 2 07:48:03 2015 -0800
----------------------------------------------------------------------
.idea/codeStyleSettings.xml | 6 ++-
CHANGELOG.md | 44 ++++++++++++++++++-
apex_checks.xml | 1 +
api/pom.xml | 6 +--
.../com/datatorrent/api/DefaultInputPort.java | 9 ++++
.../com/datatorrent/api/annotation/Name.java | 5 +++
bufferserver/pom.xml | 2 +-
.../datatorrent/bufferserver/server/Server.java | 24 ++--------
.../datatorrent/bufferserver/util/VarInt.java | 5 +++
common/pom.xml | 8 ++--
.../common/metric/SingleMetricAggregator.java | 5 +++
.../common/metric/sum/DoubleSumAggregator.java | 5 +++
.../common/metric/sum/LongSumAggregator.java | 5 +++
engine/pom.xml | 2 +-
.../datatorrent/stram/api/AppDataSource.java | 5 +++
.../java/com/datatorrent/stram/cli/DTCli.java | 2 +-
.../com/datatorrent/stram/engine/Slider.java | 5 +++
.../plan/logical/DefaultKryoStreamCodec.java | 2 +
.../StreamCodecWrapperForPersistance.java | 6 ++-
.../PartitionAwareSinkForPersistence.java | 6 ++-
.../datatorrent/stram/webapp/ContainerInfo.java | 5 +++
.../stram/webapp/asm/CompactAnnotationNode.java | 5 +++
.../stram/webapp/asm/CompactFieldNode.java | 5 +++
.../stram/webapp/asm/FieldSignatureVisitor.java | 5 +++
.../stram/client/AppPackageTest.java | 2 +-
.../resources/testAppPackage/mydtapp/pom.xml | 22 +---------
misc/ide-templates/intellij/apex-style.jar | Bin 1515 -> 1459 bytes
pom.xml | 20 +++------
28 files changed, 145 insertions(+), 72 deletions(-)
----------------------------------------------------------------------
[07/11] incubator-apex-core git commit: APEX-217 #comment Consistent
NOTICE generation per feedback from RC2
Posted by vr...@apache.org.
APEX-217 #comment Consistent NOTICE generation per feedback from RC2
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/2c8639e9
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/2c8639e9
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/2c8639e9
Branch: refs/heads/feature-module
Commit: 2c8639e944a26e48aae420a1d80c31e954c942b1
Parents: 8a96015
Author: Thomas Weise <th...@datatorrent.com>
Authored: Fri Oct 30 10:45:37 2015 -0700
Committer: Thomas Weise <th...@datatorrent.com>
Committed: Fri Oct 30 10:45:37 2015 -0700
----------------------------------------------------------------------
pom.xml | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/2c8639e9/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index d4ef633..2cc0c9b 100644
--- a/pom.xml
+++ b/pom.xml
@@ -76,6 +76,7 @@
<jetty.version>8.1.10.v20130312</jetty.version>
<license.skip>true</license.skip>
<checkstyle.console>false</checkstyle.console>
+ <postNoticeText>The initial developer of the original code is
DataTorrent, Inc. (http://www.datatorrent.com)
Copyright (c) 2012 - 2015. All Rights Reserved.</postNoticeText>
</properties>
<dependencies>
@@ -368,7 +369,6 @@
<sourceReleaseAssemblyDescriptor>source-release-zip-tar</sourceReleaseAssemblyDescriptor>
<package.prefix>/opt/datatorrent</package.prefix>
<package.groupname>dtorrent</package.groupname>
- <postNoticeText>The initial developer of the original code is
DataTorrent, Inc. (http://www.datatorrent.com)
Copyright (c) 2012 - 2015. All Rights Reserved.</postNoticeText>
</properties>
<distributionManagement>
<repository>
[05/11] incubator-apex-core git commit: APEX-226 #resolve #comment
strictly enforce wrapping indentation
Posted by vr...@apache.org.
APEX-226 #resolve #comment strictly enforce wrapping indentation
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/9049be71
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/9049be71
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/9049be71
Branch: refs/heads/feature-module
Commit: 9049be71697897fb6fa136e443cd4ffbfc089b26
Parents: ec51e8b
Author: Chandni Singh <cs...@apache.org>
Authored: Tue Oct 27 22:01:41 2015 -0700
Committer: Chandni Singh <cs...@apache.org>
Committed: Tue Oct 27 22:06:16 2015 -0700
----------------------------------------------------------------------
.idea/codeStyleSettings.xml | 6 +++++-
apex_checks.xml | 1 +
bufferserver/pom.xml | 2 +-
common/pom.xml | 2 +-
engine/pom.xml | 2 +-
misc/ide-templates/intellij/apex-style.jar | Bin 1515 -> 1459 bytes
6 files changed, 9 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/9049be71/.idea/codeStyleSettings.xml
----------------------------------------------------------------------
diff --git a/.idea/codeStyleSettings.xml b/.idea/codeStyleSettings.xml
index d469013..3143cfb 100644
--- a/.idea/codeStyleSettings.xml
+++ b/.idea/codeStyleSettings.xml
@@ -68,6 +68,9 @@
<option name="KEEP_BLANK_LINES_BEFORE_RBRACE" value="1" />
<option name="CLASS_BRACE_STYLE" value="2" />
<option name="METHOD_BRACE_STYLE" value="2" />
+ <option name="ALIGN_MULTILINE_PARAMETERS" value="false" />
+ <option name="ALIGN_MULTILINE_RESOURCES" value="false" />
+ <option name="ALIGN_MULTILINE_FOR" value="false" />
<option name="SPACE_AFTER_TYPE_CAST" value="false" />
<option name="IF_BRACE_FORCE" value="3" />
<option name="DOWHILE_BRACE_FORCE" value="3" />
@@ -99,4 +102,5 @@
</option>
<option name="USE_PER_PROJECT_SETTINGS" value="true" />
</component>
-</project>
\ No newline at end of file
+</project>
+
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/9049be71/apex_checks.xml
----------------------------------------------------------------------
diff --git a/apex_checks.xml b/apex_checks.xml
index bc17e64..81fa09d 100644
--- a/apex_checks.xml
+++ b/apex_checks.xml
@@ -141,6 +141,7 @@
<property name="throwsIndent" value="2"/>
<property name="arrayInitIndent" value="2"/>
<property name="lineWrappingIndentation" value="2"/>
+ <property name="forceStrictCondition" value="true"/>
</module>
<module name="ImportOrder">
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/9049be71/bufferserver/pom.xml
----------------------------------------------------------------------
diff --git a/bufferserver/pom.xml b/bufferserver/pom.xml
index acb93c9..bb631b5 100644
--- a/bufferserver/pom.xml
+++ b/bufferserver/pom.xml
@@ -51,7 +51,7 @@
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-checkstyle-plugin</artifactId>
<configuration>
- <maxAllowedViolations>60</maxAllowedViolations>
+ <maxAllowedViolations>83</maxAllowedViolations>
</configuration>
</plugin>
</plugins>
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/9049be71/common/pom.xml
----------------------------------------------------------------------
diff --git a/common/pom.xml b/common/pom.xml
index 6fb4852..9c42370 100644
--- a/common/pom.xml
+++ b/common/pom.xml
@@ -74,7 +74,7 @@
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-checkstyle-plugin</artifactId>
<configuration>
- <maxAllowedViolations>80</maxAllowedViolations>
+ <maxAllowedViolations>84</maxAllowedViolations>
</configuration>
</plugin>
</plugins>
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/9049be71/engine/pom.xml
----------------------------------------------------------------------
diff --git a/engine/pom.xml b/engine/pom.xml
index 5545e27..a915ff2 100644
--- a/engine/pom.xml
+++ b/engine/pom.xml
@@ -145,7 +145,7 @@
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-checkstyle-plugin</artifactId>
<configuration>
- <maxAllowedViolations>2063</maxAllowedViolations>
+ <maxAllowedViolations>2159</maxAllowedViolations>
</configuration>
</plugin>
</plugins>
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/9049be71/misc/ide-templates/intellij/apex-style.jar
----------------------------------------------------------------------
diff --git a/misc/ide-templates/intellij/apex-style.jar b/misc/ide-templates/intellij/apex-style.jar
index dc71b06..23ac4a7 100644
Binary files a/misc/ide-templates/intellij/apex-style.jar and b/misc/ide-templates/intellij/apex-style.jar differ
[10/11] incubator-apex-core git commit: APEX-40 APEX-224 Depend on
released version in Maven central for semver check and test app package.
Posted by vr...@apache.org.
APEX-40 APEX-224 Depend on released version in Maven central for semver check and test app package.
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/b4b7c071
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/b4b7c071
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/b4b7c071
Branch: refs/heads/feature-module
Commit: b4b7c071736031ff2cbe32134e6eaf2c6738c1c8
Parents: af7179c
Author: Thomas Weise <th...@datatorrent.com>
Authored: Sat Oct 31 21:39:27 2015 -0700
Committer: Thomas Weise <th...@datatorrent.com>
Committed: Sat Oct 31 21:39:27 2015 -0700
----------------------------------------------------------------------
api/pom.xml | 6 +++---
common/pom.xml | 6 +++---
.../stram/client/AppPackageTest.java | 2 +-
.../resources/testAppPackage/mydtapp/pom.xml | 22 +-------------------
pom.xml | 12 -----------
5 files changed, 8 insertions(+), 40 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/b4b7c071/api/pom.xml
----------------------------------------------------------------------
diff --git a/api/pom.xml b/api/pom.xml
index 9447c78..2e357b2 100644
--- a/api/pom.xml
+++ b/api/pom.xml
@@ -56,9 +56,9 @@
<configuration>
<oldVersion>
<dependency>
- <groupId>com.datatorrent</groupId>
- <artifactId>dt-api</artifactId>
- <version>3.0.0</version>
+ <groupId>org.apache.apex</groupId>
+ <artifactId>apex-api</artifactId>
+ <version>3.2.0-incubating</version>
</dependency>
</oldVersion>
<newVersion>
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/b4b7c071/common/pom.xml
----------------------------------------------------------------------
diff --git a/common/pom.xml b/common/pom.xml
index 9c42370..6d5c415 100644
--- a/common/pom.xml
+++ b/common/pom.xml
@@ -41,9 +41,9 @@
<configuration>
<oldVersion>
<dependency>
- <groupId>com.datatorrent</groupId>
- <artifactId>dt-common</artifactId>
- <version>3.0.0</version>
+ <groupId>org.apache.apex</groupId>
+ <artifactId>apex-common</artifactId>
+ <version>3.2.0-incubating</version>
</dependency>
</oldVersion>
<newVersion>
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/b4b7c071/engine/src/test/java/com/datatorrent/stram/client/AppPackageTest.java
----------------------------------------------------------------------
diff --git a/engine/src/test/java/com/datatorrent/stram/client/AppPackageTest.java b/engine/src/test/java/com/datatorrent/stram/client/AppPackageTest.java
index 5a6c417..0d284cf 100644
--- a/engine/src/test/java/com/datatorrent/stram/client/AppPackageTest.java
+++ b/engine/src/test/java/com/datatorrent/stram/client/AppPackageTest.java
@@ -84,7 +84,7 @@ public class AppPackageTest
{
Assert.assertEquals("mydtapp", json.getString("appPackageName"));
Assert.assertEquals("1.0-SNAPSHOT", json.getString("appPackageVersion"));
- Assert.assertEquals("3.3.0-incubating-SNAPSHOT", json.getString("dtEngineVersion"));
+ Assert.assertEquals("3.2.0-incubating", json.getString("dtEngineVersion"));
Assert.assertEquals("lib/*.jar", json.getJSONArray("classPath").getString(0));
JSONObject application = json.getJSONArray("applications").getJSONObject(0);
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/b4b7c071/engine/src/test/resources/testAppPackage/mydtapp/pom.xml
----------------------------------------------------------------------
diff --git a/engine/src/test/resources/testAppPackage/mydtapp/pom.xml b/engine/src/test/resources/testAppPackage/mydtapp/pom.xml
index d8f61e4..d1efa48 100644
--- a/engine/src/test/resources/testAppPackage/mydtapp/pom.xml
+++ b/engine/src/test/resources/testAppPackage/mydtapp/pom.xml
@@ -33,30 +33,10 @@
<properties>
<!-- change this if you desire to use a different version of DataTorrent -->
- <datatorrent.version>3.3.0-incubating-SNAPSHOT</datatorrent.version>
+ <datatorrent.version>3.2.0-incubating</datatorrent.version>
<datatorrent.apppackage.classpath>lib/*.jar</datatorrent.apppackage.classpath>
</properties>
- <!-- repository to provide the DataTorrent artifacts -->
- <repositories>
- <repository>
- <snapshots>
- <enabled>false</enabled>
- </snapshots>
- <id>Datatorrent-Releases</id>
- <name>DataTorrent Release Repository</name>
- <url>https://www.datatorrent.com/maven/content/repositories/releases/</url>
- </repository>
- <repository>
- <releases>
- <enabled>false</enabled>
- </releases>
- <id>DataTorrent-Snapshots</id>
- <name>DataTorrent Early Access Program Snapshot Repository</name>
- <url>https://www.datatorrent.com/maven/content/repositories/snapshots/</url>
- </repository>
- </repositories>
-
<build>
<plugins>
<plugin>
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/b4b7c071/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index 2cc0c9b..ff917ff 100644
--- a/pom.xml
+++ b/pom.xml
@@ -52,18 +52,6 @@
<maven>3.0.5</maven>
</prerequisites>
- <repositories>
- <!-- added for semantic versioning check, won't be needed once we publish to central -->
- <repository>
- <snapshots>
- <enabled>false</enabled>
- </snapshots>
- <id>datatorrent</id>
- <name>DataTorrent Release Repository</name>
- <url>https://www.datatorrent.com/maven/content/repositories/releases/</url>
- </repository>
- </repositories>
-
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<maven.compiler.optimize>false</maven.compiler.optimize>
[02/11] incubator-apex-core git commit: APEX-199 #resolve Fixed bug
where CLI returns false incompatibility error message
Posted by vr...@apache.org.
APEX-199 #resolve Fixed bug where CLI returns false incompatibility error message
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/8d9aa4b3
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/8d9aa4b3
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/8d9aa4b3
Branch: refs/heads/feature-module
Commit: 8d9aa4b32ec253721c92b3d2590f6f39085d42d2
Parents: aa28887
Author: David Yan <da...@datatorrent.com>
Authored: Tue Oct 27 12:42:15 2015 -0700
Committer: David Yan <da...@datatorrent.com>
Committed: Tue Oct 27 12:42:15 2015 -0700
----------------------------------------------------------------------
engine/src/main/java/com/datatorrent/stram/cli/DTCli.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/8d9aa4b3/engine/src/main/java/com/datatorrent/stram/cli/DTCli.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/com/datatorrent/stram/cli/DTCli.java b/engine/src/main/java/com/datatorrent/stram/cli/DTCli.java
index 89f92f0..deb0967 100644
--- a/engine/src/main/java/com/datatorrent/stram/cli/DTCli.java
+++ b/engine/src/main/java/com/datatorrent/stram/cli/DTCli.java
@@ -3451,7 +3451,7 @@ public class DTCli
private void checkPlatformCompatible(AppPackage ap)
{
String apVersion = ap.getDtEngineVersion();
- if (!VersionInfo.isCompatible(apVersion, VersionInfo.getVersion())) {
+ if (!VersionInfo.isCompatible(VersionInfo.getVersion(), apVersion)) {
throw new CliException("This App Package is compiled with Apache Apex Core API version " + apVersion + ", which is incompatible with this Apex Core version " + VersionInfo.getVersion());
}
}
[04/11] incubator-apex-core git commit: Merge branch 'APEX-225' into
devel-3
Posted by vr...@apache.org.
Merge branch 'APEX-225' into devel-3
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/ec51e8b6
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/ec51e8b6
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/ec51e8b6
Branch: refs/heads/feature-module
Commit: ec51e8b639cc1a53ef8748c86955f157dab272a4
Parents: 8d9aa4b eb7d721
Author: Chandni Singh <cs...@apache.org>
Authored: Tue Oct 27 18:05:20 2015 -0700
Committer: Chandni Singh <cs...@apache.org>
Committed: Tue Oct 27 18:05:20 2015 -0700
----------------------------------------------------------------------
api/src/main/java/com/datatorrent/api/DefaultInputPort.java | 9 +++++++++
1 file changed, 9 insertions(+)
----------------------------------------------------------------------
[09/11] incubator-apex-core git commit: Update CHANGELOG for v3.2.0
Posted by vr...@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/feature-module
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