You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by tu...@apache.org on 2017/05/05 07:12:35 UTC
[1/2] apex-core git commit: Add @since tags and update change log for
release 3.6.0
Repository: apex-core
Updated Branches:
refs/heads/release-3.6 ce0a13581 -> f78d5bd5c
Add @since tags and update change log for release 3.6.0
Project: http://git-wip-us.apache.org/repos/asf/apex-core/repo
Commit: http://git-wip-us.apache.org/repos/asf/apex-core/commit/856833c1
Tree: http://git-wip-us.apache.org/repos/asf/apex-core/tree/856833c1
Diff: http://git-wip-us.apache.org/repos/asf/apex-core/diff/856833c1
Branch: refs/heads/release-3.6
Commit: 856833c1720d56dbb5732f35e96878bef0c33ce1
Parents: ce0a135
Author: Apex Dev <de...@apex.apache.org>
Authored: Mon May 1 13:22:32 2017 +0530
Committer: Tushar R. Gosavi <tu...@apache.org>
Committed: Mon May 1 13:22:32 2017 +0530
----------------------------------------------------------------------
CHANGELOG.md | 88 ++++++++++++++++++++
.../api/ControlTupleEnabledSink.java | 2 +
.../apex/api/ControlAwareDefaultInputPort.java | 2 +
.../apex/api/ControlAwareDefaultOutputPort.java | 2 +
.../apache/apex/api/operator/ControlTuple.java | 2 +
.../apache/apex/api/plugin/DAGSetupEvent.java | 3 +
.../apache/apex/api/plugin/DAGSetupPlugin.java | 2 +
.../java/org/apache/apex/api/plugin/Event.java | 2 +
.../java/org/apache/apex/api/plugin/Plugin.java | 2 +
.../bufferserver/packet/CustomControlTuple.java | 2 +
.../apex/common/util/AsyncStorageAgent.java | 2 +
.../org/apache/apex/common/util/JarHelper.java | 3 +
.../plan/logical/DAGSetupPluginManager.java | 3 +
.../stram/tuple/CustomControlTuple.java | 2 +
.../engine/api/plugin/DAGExecutionEvent.java | 3 +
.../engine/api/plugin/DAGExecutionPlugin.java | 2 +
.../apex/engine/api/plugin/PluginLocator.java | 2 +
.../plugin/AbstractApexPluginDispatcher.java | 2 +
.../AbstractDAGExecutionPluginContext.java | 3 +
.../engine/plugin/ApexPluginDispatcher.java | 3 +
.../plugin/DefaultApexPluginDispatcher.java | 2 +
.../engine/plugin/NoOpApexPluginDispatcher.java | 3 +
.../plugin/loaders/ChainedPluginLocator.java | 3 +
.../loaders/PropertyBasedPluginLocator.java | 3 +
.../ServiceLoaderBasedPluginLocator.java | 3 +
.../plugin/loaders/StaticPluginLocator.java | 3 +
.../apex/engine/util/CascadeStorageAgent.java | 2 +
.../org/apache/apex/log/LogFileInformation.java | 3 +
28 files changed, 154 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/CHANGELOG.md
----------------------------------------------------------------------
diff --git a/CHANGELOG.md b/CHANGELOG.md
index 59e7257..ac521af 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,6 +1,94 @@
Apex Changelog
========================================================================================================================
+Version 3.6.0 - 2017-05-04
+------------------------------------------------------------------------------------------------------------------------
+
+### Bug
+* [APEXCORE-471] - Requests for container allocation are not resubmitted
+* [APEXCORE-504] - Possible race condition in StreamingContainerAgent.getStreamCodec()
+* [APEXCORE-558] - Do not use yellow color to display command strings in help output
+* [APEXCORE-583] - Buffer Server LogicalNode should not be reused by Subscribers
+* [APEXCORE-585] - Latency should be calculated only after the first window has been complete
+* [APEXCORE-590] - Failed to restart application on MapR
+* [APEXCORE-591] - SubscribeRequestTuple has wrong buffer size when mask is zero
+* [APEXCORE-593] - apex cli get-app-package-info could not retrieve properties defined in properties.xml
+* [APEXCORE-595] - Master incorrectly updates committedWindowId when all partitions are terminated.
+* [APEXCORE-596] - Committed method on operators not called when stream locality is THREAD_LOCAL
+* [APEXCORE-597] - BufferServer needs to shutdown all created execution services
+* [APEXCORE-598] - Embedded mode execution does not use APPLICATION_PATH for checkpointing
+* [APEXCORE-608] - Streaming Containers use stale RPC proxy after connection is closed
+* [APEXCORE-610] - Avoid multiple getBytes() calls in Tuple.writeString
+* [APEXCORE-616] - Application fails to start Kerberised cluster
+* [APEXCORE-617] - InputNodeTest intermittently fails with ConcurrentModificationException
+* [APEXCORE-624] - Shutdown does not work because of incorrect logic in the AppMaster
+* [APEXCORE-627] - Unit test AtMostOnceTest intermittently fails
+* [APEXCORE-634] - Unifier attributes are not set for modules in DAG
+* [APEXCORE-636] - Ability to refresh tokens using user's own kerberos credentials in a managed environment
+* [APEXCORE-641] - Subscribers/DataListeners may not be scheduled to execute even when they have data to process
+* [APEXCORE-644] - get-app-package-operators with parent option does not work
+* [APEXCORE-645] - StramLocalCluster does not wait for master thread termination
+* [APEXCORE-648] - Unnecessary byte array copy in DefaultStatefulStreamCodec.toDataStatePair()
+* [APEXCORE-654] - Recovery window is not updated when Delay Operator is used along with Partitioned Operators
+* [APEXCORE-663] - Application restart not working.
+* [APEXCORE-671] - DTConfiguration utility class ValueEntry access level was changed
+* [APEXCORE-678] - Shutdown of application should start from input nodes
+* [APEXCORE-686] - AppPackage fails when .apa contains zero length stored entry
+* [APEXCORE-690] - Embedded app launcher does not apply HEARTBEAT_MONITORING setting
+* [APEXCORE-703] - Window processing timeout for finished/undeployed container
+* [APEXCORE-709] - Refactor changes done through APEXCORE-575
+
+### Dependency upgrade
+* [APEXCORE-656] - Upgrade org.apache.httpcomponents.httpclient to 4.3.6 version
+
+### Documentation
+* [APEXCORE-687] - Update docs, change supported Hadoop version to 2.6
+* [APEXCORE-692] - Apex Dev Setup doc should reference download page
+
+### Improvement
+* [APEXCORE-294] - Graceful application shutdown
+* [APEXCORE-426] - Support work preserving AM recovery
+* [APEXCORE-456] - Explicitly limit Server.Subscriber to one way communication
+* [APEXCORE-511] - DAG.addOperator, addStream and addModule should check for null and empty names
+* [APEXCORE-522] - Promote singleton usage pattern for String2String, Long2String and other StringCodecs
+* [APEXCORE-570] - Prevent upstream operators from getting too far ahead when downstream operators are slow
+* [APEXCORE-572] - Remove dependency on hadoop-common test.jar
+* [APEXCORE-575] - Improve application relaunch time.
+* [APEXCORE-592] - Returning description field in defaultProperties during apex cli call get-app-package-info
+* [APEXCORE-605] - Suppress bootstrap compiler warning
+* [APEXCORE-611] - Stram Event Log Levels
+* [APEXCORE-655] - Support RELEASE as archetype version when creating a project
+* [APEXCORE-676] - Show description for DefaultProperties only when user requests it
+* [APEXCORE-677] - Avoid starting StramLocalCluster in StreamingContainerManagerTest.testAppDataSources
+* [APEXCORE-683] - Apex client should support application packages on HDFS
+* [APEXCORE-715] - Remove unnecessary @Evolving annotation in engine
+
+### New Feature
+* [APEXCORE-563] - Have a pointer to log file name and offset in container/operator failure events
+* [APEXCORE-579] - Custom control tuple support
+* [APEXCORE-594] - Plugin support in Apex
+
+### Task
+* [APEXCORE-480] - Change the container log name from dt.log to apex.log
+* [APEXCORE-658] - Replace dt. prefix with apex. for configuration keys
+* [APEXCORE-662] - Raise StramEvent for heartbeat miss
+* [APEXCORE-691] - Use type inference for generic instance creation
+* [APEXCORE-695] - Remove unnecessary interface modifiers
+* [APEXCORE-701] - Upgrade Malhar version in archetype to 3.7.0
+
+### Sub-task
+* [APEXCORE-577] - Plugin support to inspect DAG before launch.
+* [APEXCORE-580] - Interface for processing and emitting control tuples
+* [APEXCORE-581] - Delivery of Custom Control Tuples
+* [APEXCORE-604] - Extend DAG API to allow accessing DAG objects.
+* [APEXCORE-649] - Infrastructure for user define stram event listeners.
+* [APEXCORE-660] - Documentation for Control tuple support changes
+* [APEXCORE-674] - Change access specifier of DTConfiguration.ValueEntry to private
+* [APEXCORE-680] - Review container heartbeat timeout log level messages
+* [APEXCORE-700] - Make the plugin registration interface uniform
+* [APEXCORE-702] - Mark ApexPlugin as Evolving
+
+
Version 3.5.0 - 2016-12-09
------------------------------------------------------------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/api/src/main/java/com/datatorrent/api/ControlTupleEnabledSink.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/com/datatorrent/api/ControlTupleEnabledSink.java b/api/src/main/java/com/datatorrent/api/ControlTupleEnabledSink.java
index 40b7436..bf642ad 100644
--- a/api/src/main/java/com/datatorrent/api/ControlTupleEnabledSink.java
+++ b/api/src/main/java/com/datatorrent/api/ControlTupleEnabledSink.java
@@ -23,6 +23,8 @@ import org.apache.hadoop.classification.InterfaceStability;
/**
* A {@link Sink} which supports adding control tuples
+ *
+ * @since 3.6.0
*/
@InterfaceStability.Evolving
public interface ControlTupleEnabledSink<T> extends Sink<T>
http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/api/src/main/java/org/apache/apex/api/ControlAwareDefaultInputPort.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/org/apache/apex/api/ControlAwareDefaultInputPort.java b/api/src/main/java/org/apache/apex/api/ControlAwareDefaultInputPort.java
index 07e8343..f17d540 100644
--- a/api/src/main/java/org/apache/apex/api/ControlAwareDefaultInputPort.java
+++ b/api/src/main/java/org/apache/apex/api/ControlAwareDefaultInputPort.java
@@ -27,6 +27,8 @@ import com.datatorrent.api.DefaultInputPort;
/**
* Default abstract implementation for an input port which is capable of processing
* @{@link UserDefinedControlTuple}
+ *
+ * @since 3.6.0
*/
@InterfaceStability.Evolving
public abstract class ControlAwareDefaultInputPort<T> extends DefaultInputPort<T> implements ControlTupleEnabledSink<T>
http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/api/src/main/java/org/apache/apex/api/ControlAwareDefaultOutputPort.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/org/apache/apex/api/ControlAwareDefaultOutputPort.java b/api/src/main/java/org/apache/apex/api/ControlAwareDefaultOutputPort.java
index 77addf9..9400bbd 100644
--- a/api/src/main/java/org/apache/apex/api/ControlAwareDefaultOutputPort.java
+++ b/api/src/main/java/org/apache/apex/api/ControlAwareDefaultOutputPort.java
@@ -28,6 +28,8 @@ import com.datatorrent.api.Sink;
/**
* Default implementation for an output port which can emit a @{@link ControlTuple}.
* The {@link #emitControl(ControlTuple)} method can be used to emit control tuples onto this output port
+ *
+ * @since 3.6.0
*/
@InterfaceStability.Evolving
public class ControlAwareDefaultOutputPort<T> extends DefaultOutputPort<T>
http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/api/src/main/java/org/apache/apex/api/operator/ControlTuple.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/org/apache/apex/api/operator/ControlTuple.java b/api/src/main/java/org/apache/apex/api/operator/ControlTuple.java
index a1aa6f9..1dc9ae2 100644
--- a/api/src/main/java/org/apache/apex/api/operator/ControlTuple.java
+++ b/api/src/main/java/org/apache/apex/api/operator/ControlTuple.java
@@ -22,6 +22,8 @@ import org.apache.hadoop.classification.InterfaceStability;
/**
* Any user generated control tuple must implement {@link ControlTuple} interface
+ *
+ * @since 3.6.0
*/
@InterfaceStability.Evolving
public interface ControlTuple
http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/api/src/main/java/org/apache/apex/api/plugin/DAGSetupEvent.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/org/apache/apex/api/plugin/DAGSetupEvent.java b/api/src/main/java/org/apache/apex/api/plugin/DAGSetupEvent.java
index 95d17e2..85182de 100644
--- a/api/src/main/java/org/apache/apex/api/plugin/DAGSetupEvent.java
+++ b/api/src/main/java/org/apache/apex/api/plugin/DAGSetupEvent.java
@@ -24,6 +24,9 @@ import org.apache.hadoop.conf.Configuration;
import com.datatorrent.api.DAG;
@Evolving
+/**
+ * @since 3.6.0
+ */
public class DAGSetupEvent extends Event.BaseEvent<DAGSetupEvent.Type>
{
@Evolving
http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/api/src/main/java/org/apache/apex/api/plugin/DAGSetupPlugin.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/org/apache/apex/api/plugin/DAGSetupPlugin.java b/api/src/main/java/org/apache/apex/api/plugin/DAGSetupPlugin.java
index 31ea1f3..c2b77a0 100644
--- a/api/src/main/java/org/apache/apex/api/plugin/DAGSetupPlugin.java
+++ b/api/src/main/java/org/apache/apex/api/plugin/DAGSetupPlugin.java
@@ -35,6 +35,8 @@ import com.datatorrent.api.DAG;
* <li>Before dag is validated</li>
* <li>After dag is validated</li>
* </ul>
+ *
+ * @since 3.6.0
*/
@Evolving
public interface DAGSetupPlugin<T extends DAGSetupPlugin.Context> extends Plugin<T>
http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/api/src/main/java/org/apache/apex/api/plugin/Event.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/org/apache/apex/api/plugin/Event.java b/api/src/main/java/org/apache/apex/api/plugin/Event.java
index 9b95187..edca156 100644
--- a/api/src/main/java/org/apache/apex/api/plugin/Event.java
+++ b/api/src/main/java/org/apache/apex/api/plugin/Event.java
@@ -27,6 +27,8 @@ import org.apache.hadoop.classification.InterfaceStability.Evolving;
* Plugins express interest in receiving events by registering handlers for the event type and their handlers receive
* the events.
* @param <T> event type
+ *
+ * @since 3.6.0
*/
@Evolving
public interface Event<T extends Type>
http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/api/src/main/java/org/apache/apex/api/plugin/Plugin.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/org/apache/apex/api/plugin/Plugin.java b/api/src/main/java/org/apache/apex/api/plugin/Plugin.java
index e0a3872..dc21395 100644
--- a/api/src/main/java/org/apache/apex/api/plugin/Plugin.java
+++ b/api/src/main/java/org/apache/apex/api/plugin/Plugin.java
@@ -30,6 +30,8 @@ import com.datatorrent.api.Context;
* initialization method. They should also cleanup any additional resources created during shutdown such as helper
* threads and open files in the {@link Component#teardown()} method.
* @param <T> plugin context type
+ *
+ * @since 3.6.0
*/
@Evolving
public interface Plugin<T extends Plugin.PluginContext> extends Component<T>
http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/bufferserver/src/main/java/com/datatorrent/bufferserver/packet/CustomControlTuple.java
----------------------------------------------------------------------
diff --git a/bufferserver/src/main/java/com/datatorrent/bufferserver/packet/CustomControlTuple.java b/bufferserver/src/main/java/com/datatorrent/bufferserver/packet/CustomControlTuple.java
index 3aca31d..19a6a41 100644
--- a/bufferserver/src/main/java/com/datatorrent/bufferserver/packet/CustomControlTuple.java
+++ b/bufferserver/src/main/java/com/datatorrent/bufferserver/packet/CustomControlTuple.java
@@ -20,6 +20,8 @@ package com.datatorrent.bufferserver.packet;
/**
* Custom Control Tuple class
+ *
+ * @since 3.6.0
*/
public class CustomControlTuple extends DataTuple
{
http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/common/src/main/java/org/apache/apex/common/util/AsyncStorageAgent.java
----------------------------------------------------------------------
diff --git a/common/src/main/java/org/apache/apex/common/util/AsyncStorageAgent.java b/common/src/main/java/org/apache/apex/common/util/AsyncStorageAgent.java
index f797b92..2fb399d 100644
--- a/common/src/main/java/org/apache/apex/common/util/AsyncStorageAgent.java
+++ b/common/src/main/java/org/apache/apex/common/util/AsyncStorageAgent.java
@@ -29,6 +29,8 @@ import com.datatorrent.api.StorageAgent;
* An AsyncStorageAgent enables quick checkpoints by taking local snapshot of an operator
* and unblocking the operator to process more data, while storage engine is pushing local snapshot to
* the distributed or globally accessible location for recovery.
+ *
+ * @since 3.6.0
*/
@InterfaceStability.Evolving
public interface AsyncStorageAgent extends StorageAgent
http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/common/src/main/java/org/apache/apex/common/util/JarHelper.java
----------------------------------------------------------------------
diff --git a/common/src/main/java/org/apache/apex/common/util/JarHelper.java b/common/src/main/java/org/apache/apex/common/util/JarHelper.java
index 91ba117..d40cec8 100644
--- a/common/src/main/java/org/apache/apex/common/util/JarHelper.java
+++ b/common/src/main/java/org/apache/apex/common/util/JarHelper.java
@@ -46,6 +46,9 @@ import org.apache.hadoop.classification.InterfaceStability;
@InterfaceAudience.Public
@InterfaceStability.Evolving
+/**
+ * @since 3.6.0
+ */
public class JarHelper
{
private static final Logger logger = LoggerFactory.getLogger(JarHelper.class);
http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/engine/src/main/java/com/datatorrent/stram/plan/logical/DAGSetupPluginManager.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/com/datatorrent/stram/plan/logical/DAGSetupPluginManager.java b/engine/src/main/java/com/datatorrent/stram/plan/logical/DAGSetupPluginManager.java
index 370aaaa..03958f4 100644
--- a/engine/src/main/java/com/datatorrent/stram/plan/logical/DAGSetupPluginManager.java
+++ b/engine/src/main/java/com/datatorrent/stram/plan/logical/DAGSetupPluginManager.java
@@ -38,6 +38,9 @@ import com.datatorrent.api.DAG;
import static org.slf4j.LoggerFactory.getLogger;
+/**
+ * @since 3.6.0
+ */
public class DAGSetupPluginManager
{
private static final Logger LOG = getLogger(DAGSetupPluginManager.class);
http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/engine/src/main/java/com/datatorrent/stram/tuple/CustomControlTuple.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/com/datatorrent/stram/tuple/CustomControlTuple.java b/engine/src/main/java/com/datatorrent/stram/tuple/CustomControlTuple.java
index 810fa57..ad549c5 100644
--- a/engine/src/main/java/com/datatorrent/stram/tuple/CustomControlTuple.java
+++ b/engine/src/main/java/com/datatorrent/stram/tuple/CustomControlTuple.java
@@ -28,6 +28,8 @@ import com.datatorrent.bufferserver.packet.MessageType;
/**
* An implementation for @{@link Tuple} which can be generated by the user
* Acts as the wrapper for the user payload
+ *
+ * @since 3.6.0
*/
public class CustomControlTuple extends Tuple
{
http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/engine/src/main/java/org/apache/apex/engine/api/plugin/DAGExecutionEvent.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/org/apache/apex/engine/api/plugin/DAGExecutionEvent.java b/engine/src/main/java/org/apache/apex/engine/api/plugin/DAGExecutionEvent.java
index dfffbca..3a9a016 100644
--- a/engine/src/main/java/org/apache/apex/engine/api/plugin/DAGExecutionEvent.java
+++ b/engine/src/main/java/org/apache/apex/engine/api/plugin/DAGExecutionEvent.java
@@ -27,6 +27,9 @@ import static org.apache.apex.engine.api.plugin.DAGExecutionEvent.Type.COMMIT_EV
import static org.apache.apex.engine.api.plugin.DAGExecutionEvent.Type.HEARTBEAT_EVENT;
import static org.apache.apex.engine.api.plugin.DAGExecutionEvent.Type.STRAM_EVENT;
+/**
+ * @since 3.6.0
+ */
public class DAGExecutionEvent extends Event.BaseEvent<DAGExecutionEvent.Type>
{
public enum Type implements Event.Type
http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/engine/src/main/java/org/apache/apex/engine/api/plugin/DAGExecutionPlugin.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/org/apache/apex/engine/api/plugin/DAGExecutionPlugin.java b/engine/src/main/java/org/apache/apex/engine/api/plugin/DAGExecutionPlugin.java
index 7cfb1fa..200948d 100644
--- a/engine/src/main/java/org/apache/apex/engine/api/plugin/DAGExecutionPlugin.java
+++ b/engine/src/main/java/org/apache/apex/engine/api/plugin/DAGExecutionPlugin.java
@@ -43,6 +43,8 @@ import com.datatorrent.stram.webapp.LogicalOperatorInfo;
* <li>{@see Context.COMMIT_EVENT} When committedWindowId changes in the platform an event will be delivered to the plugin</li>
* </ul>
*
+ *
+ * @since 3.6.0
*/
public interface DAGExecutionPlugin<T extends DAGExecutionPlugin.Context> extends Plugin<T>
{
http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/engine/src/main/java/org/apache/apex/engine/api/plugin/PluginLocator.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/org/apache/apex/engine/api/plugin/PluginLocator.java b/engine/src/main/java/org/apache/apex/engine/api/plugin/PluginLocator.java
index cd9a208..ec1c92d 100644
--- a/engine/src/main/java/org/apache/apex/engine/api/plugin/PluginLocator.java
+++ b/engine/src/main/java/org/apache/apex/engine/api/plugin/PluginLocator.java
@@ -25,6 +25,8 @@ import org.apache.hadoop.conf.Configuration;
/**
* Interface to discover plugins during Apex Master initialization. This should return collection of
* objects implementing an interface of type T.
+ *
+ * @since 3.6.0
*/
public interface PluginLocator<T>
{
http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/engine/src/main/java/org/apache/apex/engine/plugin/AbstractApexPluginDispatcher.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/org/apache/apex/engine/plugin/AbstractApexPluginDispatcher.java b/engine/src/main/java/org/apache/apex/engine/plugin/AbstractApexPluginDispatcher.java
index 74ee0c8..5e468f5 100644
--- a/engine/src/main/java/org/apache/apex/engine/plugin/AbstractApexPluginDispatcher.java
+++ b/engine/src/main/java/org/apache/apex/engine/plugin/AbstractApexPluginDispatcher.java
@@ -53,6 +53,8 @@ import com.datatorrent.stram.webapp.AppInfo;
/**
* A default implementation for ApexPluginDispatcher. It handles common tasks, such as handler
* registrations. Actual dispatching is left for classes extending from it.
+ *
+ * @since 3.6.0
*/
public abstract class AbstractApexPluginDispatcher extends AbstractService implements ApexPluginDispatcher
{
http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/engine/src/main/java/org/apache/apex/engine/plugin/AbstractDAGExecutionPluginContext.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/org/apache/apex/engine/plugin/AbstractDAGExecutionPluginContext.java b/engine/src/main/java/org/apache/apex/engine/plugin/AbstractDAGExecutionPluginContext.java
index 21f29f8..e839ffc 100644
--- a/engine/src/main/java/org/apache/apex/engine/plugin/AbstractDAGExecutionPluginContext.java
+++ b/engine/src/main/java/org/apache/apex/engine/plugin/AbstractDAGExecutionPluginContext.java
@@ -38,6 +38,9 @@ import com.datatorrent.stram.util.VersionInfo;
import com.datatorrent.stram.webapp.AppInfo;
import com.datatorrent.stram.webapp.LogicalOperatorInfo;
+/**
+ * @since 3.6.0
+ */
public abstract class AbstractDAGExecutionPluginContext<E extends DAGExecutionEvent> implements DAGExecutionPlugin.Context<E>
{
private final StreamingContainerManager dnmgr;
http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/engine/src/main/java/org/apache/apex/engine/plugin/ApexPluginDispatcher.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/org/apache/apex/engine/plugin/ApexPluginDispatcher.java b/engine/src/main/java/org/apache/apex/engine/plugin/ApexPluginDispatcher.java
index 9ef2a5d..663c23a 100644
--- a/engine/src/main/java/org/apache/apex/engine/plugin/ApexPluginDispatcher.java
+++ b/engine/src/main/java/org/apache/apex/engine/plugin/ApexPluginDispatcher.java
@@ -23,6 +23,9 @@ import org.apache.hadoop.service.Service;
import com.datatorrent.api.DAG;
+/**
+ * @since 3.6.0
+ */
public interface ApexPluginDispatcher extends Service
{
http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/engine/src/main/java/org/apache/apex/engine/plugin/DefaultApexPluginDispatcher.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/org/apache/apex/engine/plugin/DefaultApexPluginDispatcher.java b/engine/src/main/java/org/apache/apex/engine/plugin/DefaultApexPluginDispatcher.java
index 1252061..b7bbc48 100644
--- a/engine/src/main/java/org/apache/apex/engine/plugin/DefaultApexPluginDispatcher.java
+++ b/engine/src/main/java/org/apache/apex/engine/plugin/DefaultApexPluginDispatcher.java
@@ -43,6 +43,8 @@ import com.datatorrent.stram.webapp.AppInfo;
* Handle dispatching of events from Stram to Plugins. This implementation creates an executor
* service to process the event asynchronously. A separate task {@link DefaultApexPluginDispatcher.ProcessEventTask}
* is created to process an event and then submitted to the executor for execution.
+ *
+ * @since 3.6.0
*/
public class DefaultApexPluginDispatcher extends AbstractApexPluginDispatcher
{
http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/engine/src/main/java/org/apache/apex/engine/plugin/NoOpApexPluginDispatcher.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/org/apache/apex/engine/plugin/NoOpApexPluginDispatcher.java b/engine/src/main/java/org/apache/apex/engine/plugin/NoOpApexPluginDispatcher.java
index a629a3f..f2be11a 100644
--- a/engine/src/main/java/org/apache/apex/engine/plugin/NoOpApexPluginDispatcher.java
+++ b/engine/src/main/java/org/apache/apex/engine/plugin/NoOpApexPluginDispatcher.java
@@ -21,6 +21,9 @@ package org.apache.apex.engine.plugin;
import org.apache.apex.api.plugin.Event;
import org.apache.hadoop.service.AbstractService;
+/**
+ * @since 3.6.0
+ */
public class NoOpApexPluginDispatcher extends AbstractService implements ApexPluginDispatcher
{
public NoOpApexPluginDispatcher()
http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/engine/src/main/java/org/apache/apex/engine/plugin/loaders/ChainedPluginLocator.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/org/apache/apex/engine/plugin/loaders/ChainedPluginLocator.java b/engine/src/main/java/org/apache/apex/engine/plugin/loaders/ChainedPluginLocator.java
index df3b50a..362928d 100644
--- a/engine/src/main/java/org/apache/apex/engine/plugin/loaders/ChainedPluginLocator.java
+++ b/engine/src/main/java/org/apache/apex/engine/plugin/loaders/ChainedPluginLocator.java
@@ -28,6 +28,9 @@ import org.slf4j.LoggerFactory;
import org.apache.apex.engine.api.plugin.PluginLocator;
import org.apache.hadoop.conf.Configuration;
+/**
+ * @since 3.6.0
+ */
public class ChainedPluginLocator<T> implements PluginLocator<T>
{
private static final Logger LOG = LoggerFactory.getLogger(ChainedPluginLocator.class);
http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/engine/src/main/java/org/apache/apex/engine/plugin/loaders/PropertyBasedPluginLocator.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/org/apache/apex/engine/plugin/loaders/PropertyBasedPluginLocator.java b/engine/src/main/java/org/apache/apex/engine/plugin/loaders/PropertyBasedPluginLocator.java
index b131109..d701199 100644
--- a/engine/src/main/java/org/apache/apex/engine/plugin/loaders/PropertyBasedPluginLocator.java
+++ b/engine/src/main/java/org/apache/apex/engine/plugin/loaders/PropertyBasedPluginLocator.java
@@ -30,6 +30,9 @@ import org.apache.hadoop.conf.Configuration;
import com.datatorrent.stram.StramUtils;
+/**
+ * @since 3.6.0
+ */
public class PropertyBasedPluginLocator<T> implements PluginLocator<T>
{
private static final Logger LOG = LoggerFactory.getLogger(PropertyBasedPluginLocator.class);
http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/engine/src/main/java/org/apache/apex/engine/plugin/loaders/ServiceLoaderBasedPluginLocator.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/org/apache/apex/engine/plugin/loaders/ServiceLoaderBasedPluginLocator.java b/engine/src/main/java/org/apache/apex/engine/plugin/loaders/ServiceLoaderBasedPluginLocator.java
index be7dfc4..33eba65 100644
--- a/engine/src/main/java/org/apache/apex/engine/plugin/loaders/ServiceLoaderBasedPluginLocator.java
+++ b/engine/src/main/java/org/apache/apex/engine/plugin/loaders/ServiceLoaderBasedPluginLocator.java
@@ -26,6 +26,9 @@ import java.util.ServiceLoader;
import org.apache.apex.engine.api.plugin.PluginLocator;
import org.apache.hadoop.conf.Configuration;
+/**
+ * @since 3.6.0
+ */
public class ServiceLoaderBasedPluginLocator<T> implements PluginLocator<T>
{
private final Class<T> klass;
http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/engine/src/main/java/org/apache/apex/engine/plugin/loaders/StaticPluginLocator.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/org/apache/apex/engine/plugin/loaders/StaticPluginLocator.java b/engine/src/main/java/org/apache/apex/engine/plugin/loaders/StaticPluginLocator.java
index 4767196..2da1665 100644
--- a/engine/src/main/java/org/apache/apex/engine/plugin/loaders/StaticPluginLocator.java
+++ b/engine/src/main/java/org/apache/apex/engine/plugin/loaders/StaticPluginLocator.java
@@ -27,6 +27,9 @@ import org.slf4j.LoggerFactory;
import org.apache.apex.engine.api.plugin.PluginLocator;
import org.apache.hadoop.conf.Configuration;
+/**
+ * @since 3.6.0
+ */
public class StaticPluginLocator<T> implements PluginLocator<T>
{
private static final Logger LOG = LoggerFactory.getLogger(StaticPluginLocator.class);
http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/engine/src/main/java/org/apache/apex/engine/util/CascadeStorageAgent.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/org/apache/apex/engine/util/CascadeStorageAgent.java b/engine/src/main/java/org/apache/apex/engine/util/CascadeStorageAgent.java
index bc3df77..918483f 100644
--- a/engine/src/main/java/org/apache/apex/engine/util/CascadeStorageAgent.java
+++ b/engine/src/main/java/org/apache/apex/engine/util/CascadeStorageAgent.java
@@ -40,6 +40,8 @@ import com.datatorrent.api.StorageAgent;
* large impacting application restart time. This storage-agent is used during application
* restart to avoiding copying checkpoints from old application directory to improve application
* restart time.
+ *
+ * @since 3.6.0
*/
public class CascadeStorageAgent implements StorageAgent, AsyncStorageAgent, Serializable
{
http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/engine/src/main/java/org/apache/apex/log/LogFileInformation.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/org/apache/apex/log/LogFileInformation.java b/engine/src/main/java/org/apache/apex/log/LogFileInformation.java
index 841d847..e4b195c 100644
--- a/engine/src/main/java/org/apache/apex/log/LogFileInformation.java
+++ b/engine/src/main/java/org/apache/apex/log/LogFileInformation.java
@@ -20,6 +20,9 @@ package org.apache.apex.log;
import com.datatorrent.stram.util.AbstractWritableAdapter;
+/**
+ * @since 3.6.0
+ */
public class LogFileInformation extends AbstractWritableAdapter
{
[2/2] apex-core git commit: Preparing for 3.6.1 development
Posted by tu...@apache.org.
Preparing for 3.6.1 development
Project: http://git-wip-us.apache.org/repos/asf/apex-core/repo
Commit: http://git-wip-us.apache.org/repos/asf/apex-core/commit/f78d5bd5
Tree: http://git-wip-us.apache.org/repos/asf/apex-core/tree/f78d5bd5
Diff: http://git-wip-us.apache.org/repos/asf/apex-core/diff/f78d5bd5
Branch: refs/heads/release-3.6
Commit: f78d5bd5cafa77ad4570c2ab31fe76c79269193c
Parents: 856833c
Author: Apex Dev <de...@apex.apache.org>
Authored: Fri May 5 12:31:45 2017 +0530
Committer: Tushar R. Gosavi <tu...@apache.org>
Committed: Fri May 5 12:31:45 2017 +0530
----------------------------------------------------------------------
apex-app-archetype/README.md | 2 +-
apex-app-archetype/pom.xml | 2 +-
apex-conf-archetype/README.md | 2 +-
apex-conf-archetype/pom.xml | 2 +-
api/pom.xml | 2 +-
bufferserver/pom.xml | 2 +-
common/pom.xml | 2 +-
engine/pom.xml | 2 +-
pom.xml | 2 +-
9 files changed, 9 insertions(+), 9 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/apex-core/blob/f78d5bd5/apex-app-archetype/README.md
----------------------------------------------------------------------
diff --git a/apex-app-archetype/README.md b/apex-app-archetype/README.md
index 5f4654b..029c79e 100644
--- a/apex-app-archetype/README.md
+++ b/apex-app-archetype/README.md
@@ -6,7 +6,7 @@ How to Generate an Apex Application Project Template
Run the following command
- mvn archetype:generate -DarchetypeGroupId=org.apache.apex -DarchetypeArtifactId=apex-app-archetype -DarchetypeVersion=3.6.0-SNAPSHOT -DgroupId=com.example -Dpackage=com.example.myapexapp -DartifactId=myapexapp -Dversion=1.0-SNAPSHOT
+ mvn archetype:generate -DarchetypeGroupId=org.apache.apex -DarchetypeArtifactId=apex-app-archetype -DarchetypeVersion=3.6.1-SNAPSHOT -DgroupId=com.example -Dpackage=com.example.myapexapp -DartifactId=myapexapp -Dversion=1.0-SNAPSHOT
Using your favorite IDE, open the project that has just been created by the above command.
Write your application code and optionally operator code
http://git-wip-us.apache.org/repos/asf/apex-core/blob/f78d5bd5/apex-app-archetype/pom.xml
----------------------------------------------------------------------
diff --git a/apex-app-archetype/pom.xml b/apex-app-archetype/pom.xml
index 892c306..f2abdb5 100644
--- a/apex-app-archetype/pom.xml
+++ b/apex-app-archetype/pom.xml
@@ -25,7 +25,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>apex</artifactId>
- <version>3.6.0-SNAPSHOT</version>
+ <version>3.6.1-SNAPSHOT</version>
</parent>
<artifactId>apex-app-archetype</artifactId>
http://git-wip-us.apache.org/repos/asf/apex-core/blob/f78d5bd5/apex-conf-archetype/README.md
----------------------------------------------------------------------
diff --git a/apex-conf-archetype/README.md b/apex-conf-archetype/README.md
index 7f24872..cbabd59 100644
--- a/apex-conf-archetype/README.md
+++ b/apex-conf-archetype/README.md
@@ -6,7 +6,7 @@ How to Generate a Apex App Configuration Project Template
Run the following command
- mvn archetype:generate -DarchetypeGroupId=org.apache.apex -DarchetypeArtifactId=apex-conf-archetype -DarchetypeVersion=3.6.0-SNAPSHOT -DgroupId=com.example -Dpackage=com.example.myapexapp -DartifactId=myapexconf -Dversion=1.0-SNAPSHOT
+ mvn archetype:generate -DarchetypeGroupId=org.apache.apex -DarchetypeArtifactId=apex-conf-archetype -DarchetypeVersion=3.6.1-SNAPSHOT -DgroupId=com.example -Dpackage=com.example.myapexapp -DartifactId=myapexconf -Dversion=1.0-SNAPSHOT
Using your favorite IDE, open the project that has just been created by the above command.
Write your application code and optionally operator code
http://git-wip-us.apache.org/repos/asf/apex-core/blob/f78d5bd5/apex-conf-archetype/pom.xml
----------------------------------------------------------------------
diff --git a/apex-conf-archetype/pom.xml b/apex-conf-archetype/pom.xml
index db46ee1..a3e4935 100644
--- a/apex-conf-archetype/pom.xml
+++ b/apex-conf-archetype/pom.xml
@@ -25,7 +25,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>apex</artifactId>
- <version>3.6.0-SNAPSHOT</version>
+ <version>3.6.1-SNAPSHOT</version>
</parent>
<artifactId>apex-conf-archetype</artifactId>
http://git-wip-us.apache.org/repos/asf/apex-core/blob/f78d5bd5/api/pom.xml
----------------------------------------------------------------------
diff --git a/api/pom.xml b/api/pom.xml
index a1236f8..2ae0924 100644
--- a/api/pom.xml
+++ b/api/pom.xml
@@ -26,7 +26,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>apex</artifactId>
- <version>3.6.0-SNAPSHOT</version>
+ <version>3.6.1-SNAPSHOT</version>
</parent>
<artifactId>apex-api</artifactId>
http://git-wip-us.apache.org/repos/asf/apex-core/blob/f78d5bd5/bufferserver/pom.xml
----------------------------------------------------------------------
diff --git a/bufferserver/pom.xml b/bufferserver/pom.xml
index c0f66f1..48a0ef1 100644
--- a/bufferserver/pom.xml
+++ b/bufferserver/pom.xml
@@ -25,7 +25,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>apex</artifactId>
- <version>3.6.0-SNAPSHOT</version>
+ <version>3.6.1-SNAPSHOT</version>
</parent>
<artifactId>apex-bufferserver</artifactId>
http://git-wip-us.apache.org/repos/asf/apex-core/blob/f78d5bd5/common/pom.xml
----------------------------------------------------------------------
diff --git a/common/pom.xml b/common/pom.xml
index 2900f5c..92bc3b9 100644
--- a/common/pom.xml
+++ b/common/pom.xml
@@ -25,7 +25,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>apex</artifactId>
- <version>3.6.0-SNAPSHOT</version>
+ <version>3.6.1-SNAPSHOT</version>
</parent>
<artifactId>apex-common</artifactId>
http://git-wip-us.apache.org/repos/asf/apex-core/blob/f78d5bd5/engine/pom.xml
----------------------------------------------------------------------
diff --git a/engine/pom.xml b/engine/pom.xml
index 68a0775..205a9ab 100644
--- a/engine/pom.xml
+++ b/engine/pom.xml
@@ -25,7 +25,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>apex</artifactId>
- <version>3.6.0-SNAPSHOT</version>
+ <version>3.6.1-SNAPSHOT</version>
</parent>
<artifactId>apex-engine</artifactId>
http://git-wip-us.apache.org/repos/asf/apex-core/blob/f78d5bd5/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index d83d0f2..0f836f6 100644
--- a/pom.xml
+++ b/pom.xml
@@ -30,7 +30,7 @@
<groupId>org.apache.apex</groupId>
<artifactId>apex</artifactId>
- <version>3.6.0-SNAPSHOT</version>
+ <version>3.6.1-SNAPSHOT</version>
<packaging>pom</packaging>
<name>Apache Apex</name>