apex-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From che...@apache.org
Subject [34/50] [abbrv] incubator-apex-malhar git commit: Added default NOOP instance for idempotency manager
Date Wed, 09 Sep 2015 22:32:22 GMT
Added default NOOP instance for idempotency manager


Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/commit/4dc4788f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/4dc4788f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/4dc4788f

Branch: refs/heads/master
Commit: 4dc4788f74178509eb01cc1d4402522601095dcd
Parents: 13a3fbe
Author: ishark <isha@datatorrent.com>
Authored: Tue Aug 11 15:10:01 2015 -0700
Committer: ishark <isha@datatorrent.com>
Committed: Tue Aug 11 15:10:01 2015 -0700

----------------------------------------------------------------------
 contrib/pom.xml                                                | 6 ------
 .../contrib/rabbitmq/AbstractRabbitMQInputOperator.java        | 1 +
 2 files changed, 1 insertion(+), 6 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/4dc4788f/contrib/pom.xml
----------------------------------------------------------------------
diff --git a/contrib/pom.xml b/contrib/pom.xml
index 76e8144..9776e2f 100755
--- a/contrib/pom.xml
+++ b/contrib/pom.xml
@@ -565,11 +565,5 @@
       <version>${dt.framework.version}</version>
       <type>jar</type>
     </dependency>
-    <dependency>
-      <groupId>com.datatorrent</groupId>
-      <artifactId>dt-engine</artifactId>
-      <version>${dt.framework.version}</version>
-      <scope>test</scope>
-    </dependency>
   </dependencies>
 </project>

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/4dc4788f/contrib/src/main/java/com/datatorrent/contrib/rabbitmq/AbstractRabbitMQInputOperator.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/rabbitmq/AbstractRabbitMQInputOperator.java
b/contrib/src/main/java/com/datatorrent/contrib/rabbitmq/AbstractRabbitMQInputOperator.java
index e408f5e..955a2c8 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/rabbitmq/AbstractRabbitMQInputOperator.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/rabbitmq/AbstractRabbitMQInputOperator.java
@@ -111,6 +111,7 @@ public abstract class AbstractRabbitMQInputOperator<T> implements
     currentWindowRecoveryState = new HashMap<Long, byte[]>();
     pendingAck = new HashSet<Long>();
     recoveredTags = new HashSet<Long>();
+    idempotentStorageManager = new IdempotentStorageManager.NoopIdempotentStorageManager();
   }
 
   


Mime
View raw message