sqoop-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jar...@apache.org
Subject svn commit: r1372827 - in /sqoop/branches/branch-1.4.2: ./ bin/ ivy/ src/java/org/apache/sqoop/metastore/hsqldb/ src/test/com/cloudera/sqoop/ src/test/com/cloudera/sqoop/hive/ src/test/com/cloudera/sqoop/manager/ src/test/com/cloudera/sqoop/mapreduce/d...
Date Tue, 14 Aug 2012 10:22:59 GMT
Author: jarcec
Date: Tue Aug 14 10:22:58 2012
New Revision: 1372827

URL: http://svn.apache.org/viewvc?rev=1372827&view=rev
Log:
SQOOP-571. Revert SQOOP-519 and SQOOP-524.

(Cheolsoo Park via Jarek Jarcec Cecho)

Modified:
    sqoop/branches/branch-1.4.2/bin/configure-sqoop
    sqoop/branches/branch-1.4.2/ivy.xml
    sqoop/branches/branch-1.4.2/ivy/libraries.properties
    sqoop/branches/branch-1.4.2/ivy/sqoop-test.xml
    sqoop/branches/branch-1.4.2/ivy/sqoop.xml
    sqoop/branches/branch-1.4.2/src/java/org/apache/sqoop/metastore/hsqldb/HsqldbJobStorage.java
    sqoop/branches/branch-1.4.2/src/java/org/apache/sqoop/metastore/hsqldb/HsqldbMetaStore.java
    sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/TestAvroExport.java
    sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/TestAvroImport.java
    sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/TestExport.java
    sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/TestMultiCols.java
    sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/hive/TestHiveImport.java
    sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/manager/DirectMySQLExportTest.java
    sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/manager/JdbcMySQLExportTest.java
    sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/manager/MySQLCompatTest.java
    sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/manager/OracleCompatTest.java
    sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/manager/OracleExportTest.java
    sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/mapreduce/db/TestDataDrivenDBInputFormat.java
    sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/testutil/ManagerCompatTestCase.java

Modified: sqoop/branches/branch-1.4.2/bin/configure-sqoop
URL: http://svn.apache.org/viewvc/sqoop/branches/branch-1.4.2/bin/configure-sqoop?rev=1372827&r1=1372826&r2=1372827&view=diff
==============================================================================
--- sqoop/branches/branch-1.4.2/bin/configure-sqoop (original)
+++ sqoop/branches/branch-1.4.2/bin/configure-sqoop Tue Aug 14 10:22:58 2012
@@ -113,14 +113,6 @@ if [ ! -z "$SQOOP_USER_CLASSPATH" ]; the
   export HADOOP_CLASSPATH="${SQOOP_USER_CLASSPATH}:${HADOOP_CLASSPATH}"
 fi
 
-#Sqoop execution faces Class loading issue due to conflicting hsqldb 
-#jar versions in Sqoop(hsqldb-2.2.8) and Hadoop(hsqldb-1.8.0.10). 
-#Setting HADOOP_USER_CLASSPATH_FIRST to true adds Sqoop's classpath
-#(consequently, hsqldb-2.2.8.jar) before Hadoop's and resolves the issue. 
-#Refer SQOOP-524 JIRA for more details. 
-HADOOP_USER_CLASSPATH_FIRST=true
-
-export HADOOP_USER_CLASSPATH_FIRST
 export SQOOP_CLASSPATH
 export SQOOP_CONF_DIR
 export SQOOP_JAR_DIR

Modified: sqoop/branches/branch-1.4.2/ivy.xml
URL: http://svn.apache.org/viewvc/sqoop/branches/branch-1.4.2/ivy.xml?rev=1372827&r1=1372826&r2=1372827&view=diff
==============================================================================
--- sqoop/branches/branch-1.4.2/ivy.xml (original)
+++ sqoop/branches/branch-1.4.2/ivy.xml Tue Aug 14 10:22:58 2012
@@ -124,7 +124,7 @@ under the License.
       conf="common->master" />
     <dependency org="junit" name="junit" rev="${junit.version}"
       conf="test->default"/>
-    <dependency org="org.hsqldb" name="hsqldb" rev="${hsqldb.version}"
+    <dependency org="hsqldb" name="hsqldb" rev="${hsqldb.version}"
       conf="common->default;redist->default"/>
     <dependency org="commons-io" name="commons-io" rev="${commons-io.version}"
       conf="common->default;redist->default"/>
@@ -167,7 +167,6 @@ under the License.
       <exclude org="com.cloudera.cdh" module="zookeeper-ant" />
     </dependency>
 
-    <exclude org="hsqldb" module="hsqldb"/>
     <exclude org="org.apache.hadoop" module="avro"/>
     <exclude org="commons-daemon" module="commons-daemon" />
 

Modified: sqoop/branches/branch-1.4.2/ivy/libraries.properties
URL: http://svn.apache.org/viewvc/sqoop/branches/branch-1.4.2/ivy/libraries.properties?rev=1372827&r1=1372826&r2=1372827&view=diff
==============================================================================
--- sqoop/branches/branch-1.4.2/ivy/libraries.properties (original)
+++ sqoop/branches/branch-1.4.2/ivy/libraries.properties Tue Aug 14 10:22:58 2012
@@ -28,7 +28,7 @@ commons-io.version=1.4
 commons-lang.version=2.4
 commons-logging.version=1.0.4
 
-hsqldb.version=2.2.8
+hsqldb.version=1.8.0.10
 
 ivy.version=2.1.0
 

Modified: sqoop/branches/branch-1.4.2/ivy/sqoop-test.xml
URL: http://svn.apache.org/viewvc/sqoop/branches/branch-1.4.2/ivy/sqoop-test.xml?rev=1372827&r1=1372826&r2=1372827&view=diff
==============================================================================
--- sqoop/branches/branch-1.4.2/ivy/sqoop-test.xml (original)
+++ sqoop/branches/branch-1.4.2/ivy/sqoop-test.xml Tue Aug 14 10:22:58 2012
@@ -47,7 +47,7 @@ under the License.
       rev="${hadoop-core.cloudera.version}" conf="common->default"/>
     <dependency org="junit" name="junit" rev="${junit.version}"
       conf="common->default"/>
-    <dependency org="org.hsqldb" name="hsqldb" rev="${hsqldb.version}"
+    <dependency org="hsqldb" name="hsqldb" rev="${hsqldb.version}"
       conf="common->default"/>
   </dependencies>
 </ivy-module>

Modified: sqoop/branches/branch-1.4.2/ivy/sqoop.xml
URL: http://svn.apache.org/viewvc/sqoop/branches/branch-1.4.2/ivy/sqoop.xml?rev=1372827&r1=1372826&r2=1372827&view=diff
==============================================================================
--- sqoop/branches/branch-1.4.2/ivy/sqoop.xml (original)
+++ sqoop/branches/branch-1.4.2/ivy/sqoop.xml Tue Aug 14 10:22:58 2012
@@ -42,7 +42,7 @@ under the License.
   <dependencies>
     <dependency org="org.apache.hadoop" name="hadoop-core"
       rev="${hadoop.version}" conf="common->default"/>
-    <dependency org="org.hsqldb" name="hsqldb" rev="${hsqldb.version}"
+    <dependency org="hsqldb" name="hsqldb" rev="${hsqldb.version}"
       conf="common->default"/>
     <dependency org="commons-io" name="commons-io" rev="${commons-io.version}"
       conf="common->default"/>

Modified: sqoop/branches/branch-1.4.2/src/java/org/apache/sqoop/metastore/hsqldb/HsqldbJobStorage.java
URL: http://svn.apache.org/viewvc/sqoop/branches/branch-1.4.2/src/java/org/apache/sqoop/metastore/hsqldb/HsqldbJobStorage.java?rev=1372827&r1=1372826&r2=1372827&view=diff
==============================================================================
--- sqoop/branches/branch-1.4.2/src/java/org/apache/sqoop/metastore/hsqldb/HsqldbJobStorage.java
(original)
+++ sqoop/branches/branch-1.4.2/src/java/org/apache/sqoop/metastore/hsqldb/HsqldbJobStorage.java
Tue Aug 14 10:22:58 2012
@@ -177,7 +177,7 @@ public class HsqldbJobStorage extends Jo
             metastoreUser, metastorePassword);
       }
 
-      connection.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED);
+      connection.setTransactionIsolation(Connection.TRANSACTION_SERIALIZABLE);
       connection.setAutoCommit(false);
 
       // Initialize the root schema.
@@ -596,25 +596,17 @@ public class HsqldbJobStorage extends Jo
     PreparedStatement s;
     String curVal = getRootProperty(propertyName, version);
     if (null == curVal) {
-      if (null == version) {
-          // INSERT the row with a null version.
-          s = connection.prepareStatement("INSERT INTO " + getRootTableName()
-              + " (propval, propname, version) VALUES ( ? , ? , NULL )");
-      } else {
-          // INSERT the row with a non-null version.
-          s = connection.prepareStatement("INSERT INTO " + getRootTableName()
-              + " (propval, propname, version) VALUES ( ? , ? , ? )");
-      }
+      // INSERT the row.
+      s = connection.prepareStatement("INSERT INTO " + getRootTableName()
+          + " (propval, propname, version) VALUES ( ? , ? , ? )");
+    } else if (version == null) {
+      // UPDATE an existing row with a null version
+      s = connection.prepareStatement("UPDATE " + getRootTableName()
+          + " SET propval = ? WHERE  propname = ? AND version IS NULL");
     } else {
-      if (null == version) {
-        // UPDATE an existing row with a null version.
-        s = connection.prepareStatement("UPDATE " + getRootTableName()
-            + " SET propval = ? WHERE  propname = ? AND version IS NULL");
-      } else {
-        // UPDATE an existing row with non-null version.
-        s = connection.prepareStatement("UPDATE " + getRootTableName()
-            + " SET propval = ? WHERE  propname = ? AND version = ?");
-      }
+      // UPDATE an existing row with non-null version.
+      s = connection.prepareStatement("UPDATE " + getRootTableName()
+          + " SET propval = ? WHERE  propname = ? AND version = ?");
     }
 
     try {

Modified: sqoop/branches/branch-1.4.2/src/java/org/apache/sqoop/metastore/hsqldb/HsqldbMetaStore.java
URL: http://svn.apache.org/viewvc/sqoop/branches/branch-1.4.2/src/java/org/apache/sqoop/metastore/hsqldb/HsqldbMetaStore.java?rev=1372827&r1=1372826&r2=1372827&view=diff
==============================================================================
--- sqoop/branches/branch-1.4.2/src/java/org/apache/sqoop/metastore/hsqldb/HsqldbMetaStore.java
(original)
+++ sqoop/branches/branch-1.4.2/src/java/org/apache/sqoop/metastore/hsqldb/HsqldbMetaStore.java
Tue Aug 14 10:22:58 2012
@@ -30,7 +30,7 @@ import org.apache.hadoop.conf.Configurat
 import org.apache.hadoop.util.StringUtils;
 
 import org.hsqldb.Server;
-import org.hsqldb.server.ServerConstants;
+import org.hsqldb.ServerConstants;
 
 import com.cloudera.sqoop.SqoopOptions;
 

Modified: sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/TestAvroExport.java
URL: http://svn.apache.org/viewvc/sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/TestAvroExport.java?rev=1372827&r1=1372826&r2=1372827&view=diff
==============================================================================
--- sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/TestAvroExport.java (original)
+++ sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/TestAvroExport.java Tue Aug 14
10:22:58 2012
@@ -315,7 +315,7 @@ public class TestAvroExport extends Expo
       colGenerator(100, Schema.create(Schema.Type.INT), 100, "INTEGER"),
       colGenerator(200L, Schema.create(Schema.Type.LONG), 200L, "BIGINT"),
       // HSQLDB maps REAL to double, not float:
-      colGenerator(1.0d, Schema.create(Schema.Type.DOUBLE), 1.0d, "REAL"),
+      colGenerator(1.0f, Schema.create(Schema.Type.FLOAT), 1.0d, "REAL"),
       colGenerator(2.0d, Schema.create(Schema.Type.DOUBLE), 2.0d, "DOUBLE"),
       colGenerator("s", Schema.create(Schema.Type.STRING), "s", "VARCHAR(8)"),
       colGenerator(ByteBuffer.wrap(b), Schema.create(Schema.Type.BYTES),

Modified: sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/TestAvroImport.java
URL: http://svn.apache.org/viewvc/sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/TestAvroImport.java?rev=1372827&r1=1372826&r2=1372827&view=diff
==============================================================================
--- sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/TestAvroImport.java (original)
+++ sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/TestAvroImport.java Tue Aug 14
10:22:58 2012
@@ -136,7 +136,7 @@ public class TestAvroImport extends Impo
     checkField(fields.get(0), "DATA_COL0", Schema.Type.BOOLEAN);
     checkField(fields.get(1), "DATA_COL1", Schema.Type.INT);
     checkField(fields.get(2), "DATA_COL2", Schema.Type.LONG);
-    checkField(fields.get(3), "DATA_COL3", Schema.Type.DOUBLE);
+    checkField(fields.get(3), "DATA_COL3", Schema.Type.FLOAT);
     checkField(fields.get(4), "DATA_COL4", Schema.Type.DOUBLE);
     checkField(fields.get(5), "DATA_COL5", Schema.Type.STRING);
     checkField(fields.get(6), "DATA_COL6", Schema.Type.BYTES);
@@ -145,7 +145,7 @@ public class TestAvroImport extends Impo
     assertEquals("DATA_COL0", true, record1.get("DATA_COL0"));
     assertEquals("DATA_COL1", 100, record1.get("DATA_COL1"));
     assertEquals("DATA_COL2", 200L, record1.get("DATA_COL2"));
-    assertEquals("DATA_COL3", 1.0d, record1.get("DATA_COL3"));
+    assertEquals("DATA_COL3", 1.0f, record1.get("DATA_COL3"));
     assertEquals("DATA_COL4", 2.0, record1.get("DATA_COL4"));
     assertEquals("DATA_COL5", new Utf8("s"), record1.get("DATA_COL5"));
     Object object = record1.get("DATA_COL6");

Modified: sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/TestExport.java
URL: http://svn.apache.org/viewvc/sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/TestExport.java?rev=1372827&r1=1372826&r2=1372827&view=diff
==============================================================================
--- sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/TestExport.java (original)
+++ sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/TestExport.java Tue Aug 14 10:22:58
2012
@@ -751,11 +751,6 @@ public class TestExport extends ExportJo
     assertColMinAndMax(forIdx(1), genTime);
   }
 
-  /** @return the text representation of double */
-  protected String getDoubleTextOut(double v) {
-    return Double.toString(v) + "E0";
-  }
-
   public void testNumericTypes() throws IOException, SQLException {
     final int TOTAL_RECORDS = 9;
 
@@ -763,11 +758,11 @@ public class TestExport extends ExportJo
     ColumnGenerator genFloat = new ColumnGenerator() {
       public String getExportText(int rowNum) {
         double v = 3.141 * (double) (rowNum + 1);
-        return Double.toString(v);
+        return "" + v;
       }
       public String getVerifyText(int rowNum) {
         double v = 3.141 * (double) (rowNum + 1);
-        return getDoubleTextOut(v);
+        return "" + v;
       }
       public String getType() {
         return "FLOAT";

Modified: sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/TestMultiCols.java
URL: http://svn.apache.org/viewvc/sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/TestMultiCols.java?rev=1372827&r1=1372826&r2=1372827&view=diff
==============================================================================
--- sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/TestMultiCols.java (original)
+++ sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/TestMultiCols.java Tue Aug 14
10:22:58 2012
@@ -134,7 +134,7 @@ public class TestMultiCols extends Impor
   public void testMixed4() {
     String [] types = { "NUMERIC", "INTEGER", "NUMERIC" };
     String [] insertVals = { "-42", "17", "33333333333333333333333.1714" };
-    String validateLine = "-42,17,33333333333333333333333";
+    String validateLine = "-42,17,33333333333333333333333.1714";
 
     verifyTypes(types, insertVals, validateLine);
   }
@@ -142,7 +142,7 @@ public class TestMultiCols extends Impor
   public void testMixed5() {
     String [] types = { "NUMERIC", "INTEGER", "NUMERIC" };
     String [] insertVals = { "null", "17", "33333333333333333333333.0" };
-    String validateLine = "null,17,33333333333333333333333";
+    String validateLine = "null,17,33333333333333333333333.0";
 
     verifyTypes(types, insertVals, validateLine);
   }

Modified: sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/hive/TestHiveImport.java
URL: http://svn.apache.org/viewvc/sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/hive/TestHiveImport.java?rev=1372827&r1=1372826&r2=1372827&view=diff
==============================================================================
--- sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/hive/TestHiveImport.java (original)
+++ sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/hive/TestHiveImport.java Tue Aug
14 10:22:58 2012
@@ -373,9 +373,8 @@ public class TestHiveImport extends Impo
     BufferedReader br = new BufferedReader(fr);
     try {
       // verify the output
-      assertEquals("test with  new lines " + '\01' + "42" + '\01'
-          + "oh no  field delims                                           ",
-          br.readLine());
+      assertEquals(br.readLine(), "test with  new lines " + '\01' + "42"
+          + '\01' + "oh no  field delims ");
       assertEquals(br.readLine(), null); // should only be one line
     } catch (IOException ioe) {
       fail("Unable to read files generated from hive");
@@ -424,9 +423,8 @@ public class TestHiveImport extends Impo
     BufferedReader br = new BufferedReader(fr);
     try {
       // verify the output
-      assertEquals("test with new lines " + '\01' + "42" + '\01'
-          + "oh no   field delims                                            ",
-          br.readLine());
+      assertEquals(br.readLine(), "test with new lines " + '\01' + "42"
+          + '\01' + "oh no   field delims  ");
       assertEquals(br.readLine(), null); // should only be one line
     } catch (IOException ioe) {
       fail("Unable to read files generated from hive");

Modified: sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/manager/DirectMySQLExportTest.java
URL: http://svn.apache.org/viewvc/sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/manager/DirectMySQLExportTest.java?rev=1372827&r1=1372826&r2=1372827&view=diff
==============================================================================
--- sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/manager/DirectMySQLExportTest.java
(original)
+++ sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/manager/DirectMySQLExportTest.java
Tue Aug 14 10:22:58 2012
@@ -77,11 +77,6 @@ public class DirectMySQLExportTest exten
     return "DROP TABLE IF EXISTS " + tableName;
   }
 
-  @Override
-  protected String getDoubleTextOut(double v) {
-    return Double.toString(v);
-  }
-
   @Before
   public void setUp() {
     super.setUp();

Modified: sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/manager/JdbcMySQLExportTest.java
URL: http://svn.apache.org/viewvc/sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/manager/JdbcMySQLExportTest.java?rev=1372827&r1=1372826&r2=1372827&view=diff
==============================================================================
--- sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/manager/JdbcMySQLExportTest.java
(original)
+++ sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/manager/JdbcMySQLExportTest.java
Tue Aug 14 10:22:58 2012
@@ -78,11 +78,6 @@ public class JdbcMySQLExportTest extends
     return "DROP TABLE IF EXISTS " + tableName;
   }
 
-  @Override
-  protected String getDoubleTextOut(double v) {
-    return Double.toString(v);
-  }
-
   @Before
   public void setUp() {
     super.setUp();

Modified: sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/manager/MySQLCompatTest.java
URL: http://svn.apache.org/viewvc/sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/manager/MySQLCompatTest.java?rev=1372827&r1=1372826&r2=1372827&view=diff
==============================================================================
--- sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/manager/MySQLCompatTest.java (original)
+++ sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/manager/MySQLCompatTest.java Tue
Aug 14 10:22:58 2012
@@ -162,11 +162,6 @@ public class MySQLCompatTest extends Man
     return getNumericSeqOutput(numAsInserted);
   }
 
-  @Override
-  protected String getFixedCharSeqOut(int fieldWidth, String asInserted) {
-    return asInserted;
-  }
-
   @Test
   public void testYear() {
     verifyType("YEAR", "2012", "2012");

Modified: sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/manager/OracleCompatTest.java
URL: http://svn.apache.org/viewvc/sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/manager/OracleCompatTest.java?rev=1372827&r1=1372826&r2=1372827&view=diff
==============================================================================
--- sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/manager/OracleCompatTest.java
(original)
+++ sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/manager/OracleCompatTest.java
Tue Aug 14 10:22:58 2012
@@ -164,16 +164,6 @@ public class OracleCompatTest extends Ma
   }
 
   @Override
-  protected String getNumericSeqOutput(String numAsInserted) {
-    return numAsInserted;
-  }
-
-  @Override
-  protected String getDecimalSeqOutput(String numAsInserted) {
-    return numAsInserted;
-  }
-
-  @Override
   protected String getBlobInsertStr(String blobData) {
     // Oracle wants blob data encoded as hex (e.g. '01fca3b5').
 

Modified: sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/manager/OracleExportTest.java
URL: http://svn.apache.org/viewvc/sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/manager/OracleExportTest.java?rev=1372827&r1=1372826&r2=1372827&view=diff
==============================================================================
--- sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/manager/OracleExportTest.java
(original)
+++ sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/manager/OracleExportTest.java
Tue Aug 14 10:22:58 2012
@@ -264,11 +264,6 @@ public class OracleExportTest extends Te
     }
   }
 
-  @Override
-  protected String getDoubleTextOut(double v) {
-    return Double.toString(v);
-  }
-
   /** Make sure mixed update/insert export work correctly. */
   public void testUpsertTextExport() throws IOException, SQLException {
     final int TOTAL_RECORDS = 10;

Modified: sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/mapreduce/db/TestDataDrivenDBInputFormat.java
URL: http://svn.apache.org/viewvc/sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/mapreduce/db/TestDataDrivenDBInputFormat.java?rev=1372827&r1=1372826&r2=1372827&view=diff
==============================================================================
--- sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/mapreduce/db/TestDataDrivenDBInputFormat.java
(original)
+++ sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/mapreduce/db/TestDataDrivenDBInputFormat.java
Tue Aug 14 10:22:58 2012
@@ -181,14 +181,10 @@ public class TestDataDrivenDBInputFormat
 
       // Create the table.
       s.executeUpdate("CREATE TABLE " + DATE_TABLE + "(" + COL + " TIMESTAMP)");
-      s.executeUpdate("INSERT INTO " + DATE_TABLE
-          + " VALUES('2010-04-01 00:00:00')");
-      s.executeUpdate("INSERT INTO " + DATE_TABLE
-          + " VALUES('2010-04-02 00:00:00')");
-      s.executeUpdate("INSERT INTO " + DATE_TABLE
-          + " VALUES('2010-05-01 00:00:00')");
-      s.executeUpdate("INSERT INTO " + DATE_TABLE
-          + " VALUES('2011-04-01 00:00:00')");
+      s.executeUpdate("INSERT INTO " + DATE_TABLE + " VALUES('2010-04-01')");
+      s.executeUpdate("INSERT INTO " + DATE_TABLE + " VALUES('2010-04-02')");
+      s.executeUpdate("INSERT INTO " + DATE_TABLE + " VALUES('2010-05-01')");
+      s.executeUpdate("INSERT INTO " + DATE_TABLE + " VALUES('2011-04-01')");
 
       // commit this tx.
       connection.commit();

Modified: sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/testutil/ManagerCompatTestCase.java
URL: http://svn.apache.org/viewvc/sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/testutil/ManagerCompatTestCase.java?rev=1372827&r1=1372826&r2=1372827&view=diff
==============================================================================
--- sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/testutil/ManagerCompatTestCase.java
(original)
+++ sqoop/branches/branch-1.4.2/src/test/com/cloudera/sqoop/testutil/ManagerCompatTestCase.java
Tue Aug 14 10:22:58 2012
@@ -390,27 +390,11 @@ public abstract class ManagerCompatTestC
   }
 
   protected String getNumericSeqOutput(String numAsInserted) {
-    int dotPos = numAsInserted.indexOf(".");
-    if (-1 == dotPos) {
-      // No dot in the original string; expand to add zeros after the
-      // dot.
-      return numAsInserted + ".00000";
-    } else {
-      // all other strings return as-is.
-      return numAsInserted;
-    }
+    return numAsInserted;
   }
 
   protected String getDecimalSeqOutput(String numAsInserted) {
-    int dotPos = numAsInserted.indexOf(".");
-    if (-1 == dotPos) {
-      // No dot in the original string; expand to add zeros after the
-      // dot.
-      return numAsInserted + ".00000";
-    } else {
-      // all other strings return as-is.
-      return numAsInserted;
-    }
+    return numAsInserted;
   }
 
   /**
@@ -418,7 +402,7 @@ public abstract class ManagerCompatTestC
    * sequence file
    */
   protected String getFixedCharSeqOut(int fieldWidth, String asInserted) {
-    return padString(fieldWidth, asInserted);
+    return asInserted;
   }
 
   /**



Mime
View raw message