Fixed POM files and removed some unused imports

Author: Daniel Warneke

build-tools/pom.xml

@@ -10,9 +10,7 @@
         <version>0.2</version>
     </parent>
 
-    <groupId>eu.stratosphere</groupId>
     <artifactId>build-tools</artifactId>
-    <version>0.2</version>
     <name>build-tools</name>
     <packaging>jar</packaging>
 </project>

nephele/nephele-server/src/main/java/eu/stratosphere/nephele/multicast/MulticastCluster.java

@@ -20,10 +20,6 @@
 import java.util.Iterator;
 import java.util.LinkedList;
 
-import eu.stratosphere.nephele.instance.InstanceConnectionInfo;
-import eu.stratosphere.nephele.io.channels.ChannelID;
-import eu.stratosphere.nephele.taskmanager.bytebuffered.ConnectionInfoLookupResponse;
-
 /**
  * This class represents a cluster of hosts within a multicast-tree.
  * 

nephele/nephele-server/src/main/java/eu/stratosphere/nephele/multicast/MulticastManager.java

@@ -19,19 +19,14 @@
 import java.io.DataInputStream;
 import java.io.File;
 import java.io.FileInputStream;
-import java.io.FileReader;
-import java.io.IOException;
 import java.io.InputStreamReader;
 import java.util.Collections;
 import java.util.HashMap;
-import java.util.HashSet;
 import java.util.Iterator;
 import java.util.LinkedList;
 import java.util.List;
 import java.util.Map;
 
-import javax.swing.plaf.basic.BasicTreeUI.TreeToggleAction;
-
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 

nephele/nephele-server/src/main/java/eu/stratosphere/nephele/taskmanager/runtime/EnvelopeConsumptionLog.java

@@ -240,8 +240,6 @@ private void addOutstandingEnvelope(final AbstractByteBufferedInputChannel<? ext
 
 	void showOustandingEnvelopeLog() {
 
-		int dataAvailableCounter = 0;
-
 		final int pos = this.outstandingEnvelopesAsIntBuffer.position();
 		final int limit = this.outstandingEnvelopesAsIntBuffer.limit();
 
@@ -263,9 +261,6 @@ void showOustandingEnvelopeLog() {
 
 			final int channelIndex = getInputChannel(entry);
 			final boolean dataAvailable = getDataAvailability(entry);
-			if (dataAvailable) {
-				++dataAvailableCounter;
-			}
 
 			char ch = (char) (((int) 'A') + channelIndex + (dataAvailable ? 0 : 32));
 

pact/pact-clients/pom.xml

@@ -10,9 +10,7 @@
     <version>0.2</version>
   </parent>
 
-  <groupId>eu.stratosphere</groupId>
   <artifactId>pact-clients</artifactId>
-  <version>0.2</version>
   <name>pact-clients</name>
 
   <packaging>jar</packaging>

pact/pact-common/pom.xml

@@ -9,9 +9,7 @@
     <version>0.2</version>
   </parent>
 
-  <groupId>eu.stratosphere</groupId>
   <artifactId>pact-common</artifactId>
-  <version>0.2</version>
   <name>pact-common</name>
 
   <packaging>jar</packaging>

pact/pact-common/src/main/java/eu/stratosphere/pact/common/io/FormatUtil.java

@@ -15,22 +15,16 @@
 
 package eu.stratosphere.pact.common.io;
 
-import java.io.ByteArrayInputStream;
-import java.io.ByteArrayOutputStream;
-import java.io.DataInputStream;
-import java.io.DataOutputStream;
 import java.io.IOException;
 import java.net.URI;
 import java.net.URISyntaxException;
-import java.nio.charset.Charset;
 
 import eu.stratosphere.nephele.configuration.Configuration;
 import eu.stratosphere.nephele.fs.BlockLocation;
 import eu.stratosphere.nephele.fs.FileInputSplit;
 import eu.stratosphere.nephele.fs.FileStatus;
 import eu.stratosphere.nephele.fs.FileSystem;
 import eu.stratosphere.nephele.fs.Path;
-import eu.stratosphere.nephele.io.IOReadableWritable;
 import eu.stratosphere.pact.common.util.ReflectionUtil;
 
 /**

pact/pact-common/src/test/java/eu/stratosphere/pact/common/io/SequentialFormatTest.java

@@ -33,13 +33,11 @@
 
 import eu.stratosphere.nephele.configuration.Configuration;
 import eu.stratosphere.nephele.fs.FileInputSplit;
-import eu.stratosphere.nephele.fs.FileSystem;
 import eu.stratosphere.nephele.fs.Path;
 import eu.stratosphere.pact.common.io.statistics.BaseStatistics;
 import eu.stratosphere.pact.common.type.PactRecord;
 import eu.stratosphere.pact.common.type.base.PactInteger;
 import eu.stratosphere.pact.common.type.base.PactString;
-import eu.stratosphere.pact.common.util.ReflectionUtil;
 
 /**
  * Tests {@link SequentialInputFormat} and {@link SequentialOutputFormat}.

pact/pact-common/src/test/java/eu/stratosphere/pact/common/io/type/base/parser/DecimalTextLongParserTest.java

@@ -1,6 +1,5 @@
 package eu.stratosphere.pact.common.io.type.base.parser;
 
-import static org.junit.Assert.assertFalse;
 import static org.junit.Assert.assertTrue;
 
 import org.junit.Test;
@@ -22,7 +21,7 @@ public void testGetValue() {
 	@Test
 	public void testParseField() {
 
-byte[] recBytes = "1234567890123456789|-1234567890123456789|123abc4|".getBytes();
+		byte[] recBytes = "1234567890123456789|-1234567890123456789|123abc4|".getBytes();
 
 		// check valid int
 		PactLong l = new PactLong();

pact/pact-compiler/pom.xml

@@ -10,9 +10,7 @@
     <version>0.2</version>
   </parent>
 
-  <groupId>eu.stratosphere</groupId>
   <artifactId>pact-compiler</artifactId>
-  <version>0.2</version>
   <name>pact-compiler</name>
 
   <packaging>jar</packaging>