From d3b376a757f55eae9b156aa5cc432b92a3189721 Mon Sep 17 00:00:00 2001
From: Jan Lolling <jan.lolling@gmail.com>
Date: Thu, 8 Oct 2020 14:31:32 +0200
Subject: [PATCH] Java version updated Code comment added

---
 pom.xml                                             | 13 ++-----------
 .../jlo/talendcomp/tabletransfer/TableTransfer.java |  7 +++++--
 2 files changed, 7 insertions(+), 13 deletions(-)

diff --git a/pom.xml b/pom.xml
index 77ac2e5..8e7dbd3 100644
--- a/pom.xml
+++ b/pom.xml
@@ -13,8 +13,8 @@
 				<groupId>org.apache.maven.plugins</groupId>
 				<artifactId>maven-compiler-plugin</artifactId>
 				<configuration>
-					<source>1.7</source>
-					<target>1.7</target>
+					<source>1.8</source>
+					<target>1.8</target>
 				</configuration>
 			</plugin>
 			<plugin>
@@ -100,15 +100,6 @@
 		    <version>9.4.1212.jre7</version>
 			<scope>provided</scope>
 		</dependency>
-<!-- 
-		<dependency>
-			<groupId>sqlrunner</groupId>
-			<artifactId>sqlrunner</artifactId>
-			<version>18.2</version>
-			<scope>system</scope>
-			<systemPath>${project.basedir}/lib/sqlrunner-18.2.jar</systemPath>
-		</dependency>
--->
 	</dependencies>
 	<version>9.4</version>
 </project>
\ No newline at end of file
diff --git a/src/main/java/de/jlo/talendcomp/tabletransfer/TableTransfer.java b/src/main/java/de/jlo/talendcomp/tabletransfer/TableTransfer.java
index 2036f02..6c8c654 100644
--- a/src/main/java/de/jlo/talendcomp/tabletransfer/TableTransfer.java
+++ b/src/main/java/de/jlo/talendcomp/tabletransfer/TableTransfer.java
@@ -542,9 +542,12 @@ private final void writeTable() {
 					if (one == null) {
 						continue;
 					} else {
+						// because poll removes already the one object
+						// we have to add it here
 						queueObjects.add(one);
 					}
 					// drain never waits! Thats why we have to use poll before!
+					// here we get the rest of all objects from the queue
 					tableQueue.drainTo(queueObjects, batchSize); // pull elements from queue to this given list
 //					debug("Got " + queueObjects.size() + " records from queue.");
 					for (Object item : queueObjects) {
@@ -809,8 +812,8 @@ public final void setup() throws Exception {
 		if (outputToTable) {
 			createTargetInsertStatement();
 		}
-		final int batchSize = Integer.parseInt(properties.getProperty(TARGET_BATCHSIZE, "100"));
-		final int fetchSize = Integer.parseInt(properties.getProperty(SOURCE_FETCHSIZE, "100"));
+		final int batchSize = Integer.parseInt(properties.getProperty(TARGET_BATCHSIZE, "1000"));
+		final int fetchSize = Integer.parseInt(properties.getProperty(SOURCE_FETCHSIZE, "1000"));
 		final int queueSize = Math.max(batchSize, fetchSize);
 		if (outputToTable) {
 			tableQueue = new ArrayBlockingQueue<Object>(queueSize);