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 2016/12/10 18:36:21 UTC
[1/2] apex-core git commit: Bump japicmp compare version.
Repository: apex-core
Updated Branches:
refs/heads/master 93f790aa7 -> cc79b0c02
Bump japicmp compare version.
Project: http://git-wip-us.apache.org/repos/asf/apex-core/repo
Commit: http://git-wip-us.apache.org/repos/asf/apex-core/commit/cc79b0c0
Tree: http://git-wip-us.apache.org/repos/asf/apex-core/tree/cc79b0c0
Diff: http://git-wip-us.apache.org/repos/asf/apex-core/diff/cc79b0c0
Branch: refs/heads/master
Commit: cc79b0c02f072ac2ce3c5ac49373232b82f40e3e
Parents: 4106745
Author: Apex Dev <de...@apex.apache.org>
Authored: Sat Dec 10 10:34:05 2016 -0800
Committer: Thomas Weise <th...@apache.org>
Committed: Sat Dec 10 10:36:15 2016 -0800
----------------------------------------------------------------------
pom.xml | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/apex-core/blob/cc79b0c0/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index 6142895..fec5cec 100644
--- a/pom.xml
+++ b/pom.xml
@@ -63,7 +63,7 @@
<jersey.version>1.9</jersey.version>
<!-- do not change jetty version as later versions have problems with DefaultServlet -->
<jetty.version>8.1.10.v20130312</jetty.version>
- <project.old.version>3.4.0</project.old.version>
+ <project.old.version>3.5.0</project.old.version>
<license.skip>true</license.skip>
<findbugs.xmlOutput>true</findbugs.xmlOutput>
<findbugs.failOnError>false</findbugs.failOnError>
[2/2] apex-core git commit: Add @since tags and update change log for
release 3.5.0
Posted by th...@apache.org.
Add @since tags and update change log for release 3.5.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/41067454
Tree: http://git-wip-us.apache.org/repos/asf/apex-core/tree/41067454
Diff: http://git-wip-us.apache.org/repos/asf/apex-core/diff/41067454
Branch: refs/heads/master
Commit: 410674548d12834300e0713ade9c276ed0dce1cb
Parents: 93f790a
Author: Apex Dev <de...@apex.apache.org>
Authored: Tue Dec 6 21:36:38 2016 -0800
Committer: Thomas Weise <th...@apache.org>
Committed: Sat Dec 10 10:36:15 2016 -0800
----------------------------------------------------------------------
CHANGELOG.md | 64 ++++++++++++++++++++
.../apache/apex/api/EmbeddedAppLauncher.java | 2 +
.../main/java/org/apache/apex/api/Launcher.java | 2 +
.../org/apache/apex/api/YarnAppLauncher.java | 2 +
.../datatorrent/stram/security/AuthScheme.java | 2 +
.../com/datatorrent/stram/util/LoggerUtil.java | 3 +
.../apache/apex/engine/YarnAppLauncherImpl.java | 2 +
.../apex/engine/util/StreamingAppFactory.java | 2 +
8 files changed, 79 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/apex-core/blob/41067454/CHANGELOG.md
----------------------------------------------------------------------
diff --git a/CHANGELOG.md b/CHANGELOG.md
index 1a5f460..59e7257 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,6 +1,70 @@
Apex Changelog
========================================================================================================================
+Version 3.5.0 - 2016-12-09
+------------------------------------------------------------------------------------------------------------------------
+
+### Bug
+* [APEXCORE-169] - instantiating DTLoggerFactory during test causes incorrect logging behavior
+* [APEXCORE-453] - Intermittent failure of DelayOperatorTest.testFibonacci test case
+* [APEXCORE-458] - Web service authentication failing in HA cases when yarn.resourcemanager.webapps.address.<rmId> is unavailable
+* [APEXCORE-459] - AbstractReservoirTest.performanceTest intermittently fail on slow platforms
+* [APEXCORE-461] - Hidden ports in extended operators appear in the application package
+* [APEXCORE-463] - get-app-package-operators in ApexCLI not listing certain modules
+* [APEXCORE-476] - Window Id calculation in ToString method in SubscribeRequestTuple & GenericRequestTuple is wrong
+* [APEXCORE-488] - Issues in SSL communication with StrAM
+* [APEXCORE-494] - Window id of downstream operator is not moving after dynamic partition of upstream operator.
+* [APEXCORE-505] - setup and activate calls in operator block heartbeat loop in container
+* [APEXCORE-512] - Launching application using "-exactMatch" option in CLI is failing
+* [APEXCORE-515] - Refresh tokens failing in some scenarios with a login failure message
+* [APEXCORE-528] - Output Ports Not Optional by Default During Validation
+* [APEXCORE-532] - New dynamically added operator does not start with correct windowId.
+* [APEXCORE-533] - Layering of AppPackage properties & configPackage properties in case of ConfigApps is not working.
+* [APEXCORE-540] - Exclude hadoop dependencies from app packages
+* [APEXCORE-542] - Fix debug level verbose option for apex cli
+* [APEXCORE-544] - Latency values are out of whack immediately after app is launched
+* [APEXCORE-562] - RecordingsAgent: returns records for offset beyond number of tuples
+
+### Improvement
+* [APEXCORE-222] - Delegate Buffer Server purge to StreamingContainer
+* [APEXCORE-310] - apex cli - support to kill the app by appname
+* [APEXCORE-379] - Latency is stuck when an operator is stuck (before the 1000 window threshold)
+* [APEXCORE-386] - Upgrade to Jackson 1.9.13
+* [APEXCORE-405] - Provide an API to launch DAG on the cluster
+* [APEXCORE-448] - Make operator name available in OperatorContext
+* [APEXCORE-466] - Improve logging from the *Agent.java files
+* [APEXCORE-470] - New Api for setting the attribute on the operator ( setOperatorAttribute )
+* [APEXCORE-474] - Unifier placement during M*1 deployment
+* [APEXCORE-475] - change the YARN_APPLICATION_TYPE from DataTorrent to ApacheApex
+* [APEXCORE-495] - Enhancing the configuration package to store apps
+* [APEXCORE-502] - Unnecessary byte array copy in DefaultKryoStreamCodec.toByteArray
+* [APEXCORE-506] - Add trailing whitespace check to Apex checkstyle
+* [APEXCORE-510] - Enforce DefaultOutputPort.emit() or Sink.put() thread affinity
+* [APEXCORE-513] - Reduce the log level in updateNodeReports
+* [APEXCORE-516] - StramLocalCluster should always use loopback address for buffer server location
+* [APEXCORE-517] - ApexCli is not working with Hadoop web services when BASIC authentication is enabled
+* [APEXCORE-519] - Add support for DIGEST enabled hadoop web services environment
+* [APEXCORE-524] - Add support for custom maven repository to ClassPathResolverTest.testManifestClassPathResolver
+* [APEXCORE-525] - Subclass aware DefaultStatefulStreamCodec.newInstance() implementation
+* [APEXCORE-527] - Minor changes in LocalStramChildLauncher to help with unit test failures
+* [APEXCORE-535] - Node.teardown() should try to gracefully shutdown exectutor service
+* [APEXCORE-536] - Upgrade Hadoop dependency
+* [APEXCORE-538] - Log raw data when RPC message fails to de-serialize
+* [APEXCORE-543] - Enhance the ContainerInfo to contain operator id and name.
+
+### New Feature
+* [APEXCORE-451] - get-app-package-operators in ApexCLI to contain "type" property to indicate operator or module
+* [APEXCORE-552] - Support application tags when launching application
+
+### Task
+* [APEXCORE-251] - Journal output stream is null error message
+* [APEXCORE-484] - Increase JVM PermGen size while running engine Unit test
+* [APEXCORE-485] - Upgrade maven surefire plugin to the latest version
+* [APEXCORE-487] - Upgrade apex and malhar dependencies in the archtype
+* [APEXCORE-521] - Upgrade Apex core pom.xml to the latest Apache pom parent
+* [APEXCORE-531] - Enable System.out/System.err check for *Test
+* [APEXCORE-557] - Upgrade netlet dependency to 1.3.0
+
Version 3.4.0 - 2016-05-09
------------------------------------------------------------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/apex-core/blob/41067454/api/src/main/java/org/apache/apex/api/EmbeddedAppLauncher.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/org/apache/apex/api/EmbeddedAppLauncher.java b/api/src/main/java/org/apache/apex/api/EmbeddedAppLauncher.java
index 860926c..ebe7efa 100644
--- a/api/src/main/java/org/apache/apex/api/EmbeddedAppLauncher.java
+++ b/api/src/main/java/org/apache/apex/api/EmbeddedAppLauncher.java
@@ -27,6 +27,8 @@ import com.datatorrent.api.StreamingApplication;
/**
* Launcher for running the application directly in the current Java VM. For basic operations such as launching or
* stopping the application, {@link Launcher} can be used directly.
+ *
+ * @since 3.5.0
*/
public abstract class EmbeddedAppLauncher<H extends EmbeddedAppLauncher.EmbeddedAppHandle> extends Launcher<H>
{
http://git-wip-us.apache.org/repos/asf/apex-core/blob/41067454/api/src/main/java/org/apache/apex/api/Launcher.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/org/apache/apex/api/Launcher.java b/api/src/main/java/org/apache/apex/api/Launcher.java
index 0291ab0..22980c5 100644
--- a/api/src/main/java/org/apache/apex/api/Launcher.java
+++ b/api/src/main/java/org/apache/apex/api/Launcher.java
@@ -33,6 +33,8 @@ import com.datatorrent.api.StreamingApplication;
/**
* A class that provides an entry point for functionality to run applications in different environments such as current
* Java VM, Hadoop YARN etc.
+ *
+ * @since 3.5.0
*/
public abstract class Launcher<H extends Launcher.AppHandle>
{
http://git-wip-us.apache.org/repos/asf/apex-core/blob/41067454/api/src/main/java/org/apache/apex/api/YarnAppLauncher.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/org/apache/apex/api/YarnAppLauncher.java b/api/src/main/java/org/apache/apex/api/YarnAppLauncher.java
index e3b36db..82cf50e 100644
--- a/api/src/main/java/org/apache/apex/api/YarnAppLauncher.java
+++ b/api/src/main/java/org/apache/apex/api/YarnAppLauncher.java
@@ -27,6 +27,8 @@ import com.datatorrent.api.StringCodec;
/**
* Launcher for running the application on Hadoop YARN. For basic operations such as launching or stopping the
* application, {@link Launcher} can be used directly.
+ *
+ * @since 3.5.0
*/
public abstract class YarnAppLauncher<H extends YarnAppLauncher.YarnAppHandle> extends Launcher<H>
{
http://git-wip-us.apache.org/repos/asf/apex-core/blob/41067454/engine/src/main/java/com/datatorrent/stram/security/AuthScheme.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/com/datatorrent/stram/security/AuthScheme.java b/engine/src/main/java/com/datatorrent/stram/security/AuthScheme.java
index 4545458..fa390eb 100644
--- a/engine/src/main/java/com/datatorrent/stram/security/AuthScheme.java
+++ b/engine/src/main/java/com/datatorrent/stram/security/AuthScheme.java
@@ -24,6 +24,8 @@ package com.datatorrent.stram.security;
* BASIC: BASIC HTTP authentication - RFC 2617
* SPNEGO: Kerberos based SPNEGO authentication - RFC 4559
* KERBEROS: Kerberos authentication - RFC 4120
+ *
+ * @since 3.5.0
*/
public enum AuthScheme
{
http://git-wip-us.apache.org/repos/asf/apex-core/blob/41067454/engine/src/main/java/com/datatorrent/stram/util/LoggerUtil.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/com/datatorrent/stram/util/LoggerUtil.java b/engine/src/main/java/com/datatorrent/stram/util/LoggerUtil.java
index e774bea..d30958c 100644
--- a/engine/src/main/java/com/datatorrent/stram/util/LoggerUtil.java
+++ b/engine/src/main/java/com/datatorrent/stram/util/LoggerUtil.java
@@ -40,6 +40,9 @@ import com.google.common.base.Function;
import com.google.common.collect.ImmutableMap;
import com.google.common.collect.Maps;
+/**
+ * @since 3.5.0
+ */
public class LoggerUtil
{
http://git-wip-us.apache.org/repos/asf/apex-core/blob/41067454/engine/src/main/java/org/apache/apex/engine/YarnAppLauncherImpl.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/org/apache/apex/engine/YarnAppLauncherImpl.java b/engine/src/main/java/org/apache/apex/engine/YarnAppLauncherImpl.java
index d7a6dc8..3c49a71 100644
--- a/engine/src/main/java/org/apache/apex/engine/YarnAppLauncherImpl.java
+++ b/engine/src/main/java/org/apache/apex/engine/YarnAppLauncherImpl.java
@@ -42,6 +42,8 @@ import com.datatorrent.stram.plan.logical.LogicalPlanConfiguration;
/**
* An implementation of {@link YarnAppLauncher} to launch applications on Hadoop YARN.
+ *
+ * @since 3.5.0
*/
public class YarnAppLauncherImpl extends YarnAppLauncher<YarnAppLauncherImpl.YarnAppHandleImpl>
{
http://git-wip-us.apache.org/repos/asf/apex-core/blob/41067454/engine/src/main/java/org/apache/apex/engine/util/StreamingAppFactory.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/org/apache/apex/engine/util/StreamingAppFactory.java b/engine/src/main/java/org/apache/apex/engine/util/StreamingAppFactory.java
index 6c943fc..96edc8d 100644
--- a/engine/src/main/java/org/apache/apex/engine/util/StreamingAppFactory.java
+++ b/engine/src/main/java/org/apache/apex/engine/util/StreamingAppFactory.java
@@ -26,6 +26,8 @@ import com.datatorrent.stram.plan.logical.LogicalPlanConfiguration;
/**
*
+ *
+ * @since 3.5.0
*/
public abstract class StreamingAppFactory implements StramAppLauncher.AppFactory
{