diff --git a/connector/connector-generic-jdbc/src/test/java/org/apache/sqoop/connector/jdbc/TestToInitializer.java b/connector/connector-generic-jdbc/src/test/java/org/apache/sqoop/connector/jdbc/TestToInitializer.java index 7e366666..870ce98a 100644 --- a/connector/connector-generic-jdbc/src/test/java/org/apache/sqoop/connector/jdbc/TestToInitializer.java +++ b/connector/connector-generic-jdbc/src/test/java/org/apache/sqoop/connector/jdbc/TestToInitializer.java @@ -190,27 +190,6 @@ public void testTableNameWithTableColumnsWithSchema() throws Exception { verifyResult(context, "INSERT INTO " + fullTableName + " (" + tableColumns + ") VALUES (?,?)"); } - @Test - @SuppressWarnings("unchecked") - public void testTableSqlWithSchema() throws Exception { - LinkConfiguration linkConfig = new LinkConfiguration(); - ToJobConfiguration jobConfig = new ToJobConfiguration(); - - linkConfig.linkConfig.jdbcDriver = GenericJdbcTestConstants.DRIVER; - linkConfig.linkConfig.connectionString = GenericJdbcTestConstants.URL; - jobConfig.toJobConfig.schemaName = schemaName; - jobConfig.toJobConfig.sql = tableSql; - - MutableContext context = new MutableMapContext(); - InitializerContext initializerContext = new InitializerContext(context); - - @SuppressWarnings("rawtypes") - Initializer initializer = new GenericJdbcToInitializer(); - initializer.initialize(initializerContext, linkConfig, jobConfig); - - verifyResult(context, tableSql); - } - private void verifyResult(MutableContext context, String dataSql) { assertEquals(dataSql, context.getString( GenericJdbcConnectorConstants.CONNECTOR_JDBC_TO_DATA_SQL));