diff options
author | Timothy Farkas <timothyfarkas@apache.org> | 2018-05-22 16:04:02 -0700 |
---|---|---|
committer | Sorabh Hamirwasia <sorabh@apache.org> | 2018-06-06 09:06:33 -0700 |
commit | f53fd1db66f19a7055dc75a43caf1da4d09b99f0 (patch) | |
tree | e7df94a05931047d13a9b32a7734681c6295f76b /contrib | |
parent | e0c39e070bb696d2bc67f60f18559e5a547208ad (diff) |
DRILL-6438: Remove excess logging form the tests.
- Removed usages of System.out and System.err from the test and replaced with loggers
closes #1284
Diffstat (limited to 'contrib')
7 files changed, 5 insertions, 46 deletions
diff --git a/contrib/format-maprdb/src/test/java/com/mapr/drill/maprdb/tests/MaprDBTestsSuite.java b/contrib/format-maprdb/src/test/java/com/mapr/drill/maprdb/tests/MaprDBTestsSuite.java index f43fc7458..0c81a1844 100644 --- a/contrib/format-maprdb/src/test/java/com/mapr/drill/maprdb/tests/MaprDBTestsSuite.java +++ b/contrib/format-maprdb/src/test/java/com/mapr/drill/maprdb/tests/MaprDBTestsSuite.java @@ -70,7 +70,6 @@ public class MaprDBTestsSuite { // Sleep to allow table data to be flushed to tables. // Without this, the row count stats to return 0, // causing the planner to reject optimized plans. - System.out.println("Sleeping for 5 seconds to allow table flushes"); Thread.sleep(5000); conf = HBaseTestsSuite.getConf(); diff --git a/contrib/format-maprdb/src/test/java/com/mapr/drill/maprdb/tests/json/BaseJsonTest.java b/contrib/format-maprdb/src/test/java/com/mapr/drill/maprdb/tests/json/BaseJsonTest.java index 4b3ec5b83..ee32aa18e 100644 --- a/contrib/format-maprdb/src/test/java/com/mapr/drill/maprdb/tests/json/BaseJsonTest.java +++ b/contrib/format-maprdb/src/test/java/com/mapr/drill/maprdb/tests/json/BaseJsonTest.java @@ -50,7 +50,6 @@ public class BaseJsonTest extends BaseTestQuery { protected List<QueryDataBatch> runHBaseSQLlWithResults(String sql) throws Exception { - System.out.println("Running query:\n" + sql); return testSqlWithResults(sql); } @@ -65,5 +64,4 @@ public class BaseJsonTest extends BaseTestQuery { Assert.assertEquals(expectedRowCount, rowCount); } } - } diff --git a/contrib/storage-hbase/src/test/java/org/apache/drill/hbase/BaseHBaseTest.java b/contrib/storage-hbase/src/test/java/org/apache/drill/hbase/BaseHBaseTest.java index 51312fc39..dd7ce674e 100644 --- a/contrib/storage-hbase/src/test/java/org/apache/drill/hbase/BaseHBaseTest.java +++ b/contrib/storage-hbase/src/test/java/org/apache/drill/hbase/BaseHBaseTest.java @@ -84,7 +84,6 @@ public class BaseHBaseTest extends BaseTestQuery { protected List<QueryDataBatch> runHBaseSQLlWithResults(String sql) throws Exception { sql = canonizeHBaseSQL(sql); - System.out.println("Running query:\n" + sql); return testSqlWithResults(sql); } diff --git a/contrib/storage-hbase/src/test/java/org/apache/drill/hbase/TestHBaseTableProvider.java b/contrib/storage-hbase/src/test/java/org/apache/drill/hbase/TestHBaseTableProvider.java index ca6856483..1a9f4ee92 100644 --- a/contrib/storage-hbase/src/test/java/org/apache/drill/hbase/TestHBaseTableProvider.java +++ b/contrib/storage-hbase/src/test/java/org/apache/drill/hbase/TestHBaseTableProvider.java @@ -21,8 +21,6 @@ import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertFalse; import static org.junit.Assert.assertTrue; -import java.util.Map.Entry; - import com.google.common.collect.Lists; import org.apache.drill.categories.HbaseStorageTest; import org.apache.drill.common.config.LogicalPlanPersistence; @@ -66,12 +64,7 @@ public class TestHBaseTableProvider extends BaseHBaseTest { assertTrue(hbaseStore.contains("")); assertFalse(hbaseStore.contains("unknown_key")); - int rowCount = 0; - for (Entry<String, String> entry : Lists.newArrayList(hbaseStore.getAll())) { - rowCount++; - System.out.println(entry.getKey() + "=" + entry.getValue()); - } - assertEquals(7, rowCount); + assertEquals(7, Lists.newArrayList(hbaseStore.getAll()).size()); PersistentStore<String> hbaseTestStore = provider.getOrCreateStore(PersistentStoreConfig.newJacksonBuilder(lp.getMapper(), String.class).name("hbase.test").build()); hbaseTestStore.put("", "v0"); @@ -84,12 +77,7 @@ public class TestHBaseTableProvider extends BaseHBaseTest { assertEquals("v0", hbaseStore.get("")); assertEquals("testValue", hbaseStore.get(".test")); - rowCount = 0; - for (Entry<String, String> entry : Lists.newArrayList(hbaseTestStore.getAll())) { - rowCount++; - System.out.println(entry.getKey() + "=" + entry.getValue()); - } - assertEquals(6, rowCount); + assertEquals(6, Lists.newArrayList(hbaseTestStore.getAll()).size()); } @AfterClass diff --git a/contrib/storage-hive/core/src/test/java/org/apache/drill/exec/fn/hive/TestHiveUDFs.java b/contrib/storage-hive/core/src/test/java/org/apache/drill/exec/fn/hive/TestHiveUDFs.java index 305d9b574..7843b3fe4 100644 --- a/contrib/storage-hive/core/src/test/java/org/apache/drill/exec/fn/hive/TestHiveUDFs.java +++ b/contrib/storage-hive/core/src/test/java/org/apache/drill/exec/fn/hive/TestHiveUDFs.java @@ -44,8 +44,6 @@ public class TestHiveUDFs extends BaseTestQuery { @Test public void testGenericUDF() throws Throwable { - - int numRecords = 0; String planString = Resources.toString(Resources.getResource("functions/hive/GenericUDF.json"), Charsets.UTF_8); List<QueryDataBatch> results = testPhysicalWithResults(planString); @@ -82,10 +80,6 @@ public class TestHiveUDFs extends BaseTestQuery { String concat = new String(concatV.getAccessor().get(i), Charsets.UTF_8); assertTrue(concat.equals(in+"-"+in)); - float flt1 = flt1V.getAccessor().get(i); - String format_number = new String(format_numberV.getAccessor().get(i), Charsets.UTF_8); - - String nullableStr1 = null; if (!nullableStr1V.getAccessor().isNull(i)) { nullableStr1 = new String(nullableStr1V.getAccessor().get(i), Charsets.UTF_8); @@ -100,23 +94,15 @@ public class TestHiveUDFs extends BaseTestQuery { if (nullableStr1 != null) { assertEquals(nullableStr1.toUpperCase(), upperNullableStr1); } - - System.out.println(in + ", " + upper + ", " + concat + ", " + - flt1 + ", " + format_number + ", " + nullableStr1 + ", " + upperNullableStr1); - - numRecords++; } result.release(); batchLoader.clear(); } - - System.out.println("Processed " + numRecords + " records"); } @Test public void testUDF() throws Throwable { - int numRecords = 0; String planString = Resources.toString(Resources.getResource("functions/hive/UDF.json"), Charsets.UTF_8); List<QueryDataBatch> results = testPhysicalWithResults(planString); @@ -146,8 +132,6 @@ public class TestHiveUDFs extends BaseTestQuery { long str1Length = str1LengthV.getAccessor().get(i); assertTrue(str1.length() == str1Length); - int str1Ascii = str1AsciiV.getAccessor().get(i); - float flt1 = flt1V.getAccessor().get(i); double pow = 0; @@ -155,16 +139,10 @@ public class TestHiveUDFs extends BaseTestQuery { pow = powV.getAccessor().get(i); assertTrue(Math.pow(flt1, 2.0) == pow); } - - System.out.println(str1 + ", " + str1Length + ", " + str1Ascii + ", " + flt1 + ", " + pow); - numRecords++; } result.release(); batchLoader.clear(); } - - System.out.println("Processed " + numRecords + " records"); } - } diff --git a/contrib/storage-hive/core/src/test/java/org/apache/drill/exec/test/Drill2130StorageHiveCoreHamcrestConfigurationTest.java b/contrib/storage-hive/core/src/test/java/org/apache/drill/exec/test/Drill2130StorageHiveCoreHamcrestConfigurationTest.java index 472891868..12adf92e5 100644 --- a/contrib/storage-hive/core/src/test/java/org/apache/drill/exec/test/Drill2130StorageHiveCoreHamcrestConfigurationTest.java +++ b/contrib/storage-hive/core/src/test/java/org/apache/drill/exec/test/Drill2130StorageHiveCoreHamcrestConfigurationTest.java @@ -24,6 +24,7 @@ import static org.junit.Assert.fail; import static org.hamcrest.CoreMatchers.equalTo; public class Drill2130StorageHiveCoreHamcrestConfigurationTest { + private static final org.slf4j.Logger logger = org.slf4j.LoggerFactory.getLogger(Drill2130StorageHiveCoreHamcrestConfigurationTest.class); @SuppressWarnings("unused") private org.hamcrest.MatcherAssert forCompileTimeCheckForNewEnoughHamcrest; @@ -38,9 +39,7 @@ public class Drill2130StorageHiveCoreHamcrestConfigurationTest { + " Got NoSuchMethodError; e: " + e ); } catch ( AssertionError e ) { - System.out.println( "Class path seems fine re new JUnit vs. old Hamcrest." - + " (Got AssertionError, not NoSuchMethodError.)" ); + logger.info("Class path seems fine re new JUnit vs. old Hamcrest. (Got AssertionError, not NoSuchMethodError.)"); } } - } diff --git a/contrib/storage-kudu/src/test/java/org/apache/drill/store/kudu/TestKuduConnect.java b/contrib/storage-kudu/src/test/java/org/apache/drill/store/kudu/TestKuduConnect.java index bf6603772..ad1e7958a 100644 --- a/contrib/storage-kudu/src/test/java/org/apache/drill/store/kudu/TestKuduConnect.java +++ b/contrib/storage-kudu/src/test/java/org/apache/drill/store/kudu/TestKuduConnect.java @@ -35,7 +35,6 @@ import org.apache.kudu.client.KuduSession; import org.apache.kudu.client.KuduTable; import org.apache.kudu.client.ListTablesResponse; import org.apache.kudu.client.PartialRow; -import org.apache.kudu.client.RowResult; import org.apache.kudu.client.RowResultIterator; import org.apache.kudu.client.SessionConfiguration; import org.junit.experimental.categories.Category; @@ -99,8 +98,7 @@ public class TestKuduConnect { while (scanner.hasMoreRows()) { RowResultIterator results = scanner.nextRows(); while (results.hasNext()) { - RowResult result = results.next(); - System.out.println(result.toStringLongFormat()); + logger.debug(results.next().toString()); } } } |