[FLINK-4000] [RabbitMQ] Style cleanups in MessageAcknowledgingSourceBase

apache · Jun 8, 2016 · 6afb2b0 · 6afb2b0
1 parent ae679bb
commit 6afb2b0
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/.../java/org/apache/flink/streaming/api/functions/source/MessageAcknowledgingSourceBase.java b/.../java/org/apache/flink/streaming/api/functions/source/MessageAcknowledgingSourceBase.java
@@ -102,8 +102,6 @@ public abstract class MessageAcknowledgingSourceBase<Type, UId>
 	 */
 	private transient Set<UId> idsProcessedButNotAcknowledged;
 
-	protected int numCheckpointsToKeep = 10;
-
 	// ------------------------------------------------------------------------
 
 	/**
@@ -127,10 +125,12 @@ protected MessageAcknowledgingSourceBase(TypeInformation<UId> idTypeInfo) {
 	@Override
 	public void open(Configuration parameters) throws Exception {
 		idsForCurrentCheckpoint = new ArrayList<>(64);
-		if (pendingCheckpoints == null)
-			pendingCheckpoints = new ArrayDeque<>(numCheckpointsToKeep);
-		if (idsProcessedButNotAcknowledged == null)
+		if (pendingCheckpoints == null) {
+			pendingCheckpoints = new ArrayDeque<>();
+		}
+		if (idsProcessedButNotAcknowledged == null) {
 			idsProcessedButNotAcknowledged = new HashSet<>();
+		}
 	}
 
 	@Override