This is an automated email from the ASF dual-hosted git repository.
cgivre pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/drill.git
The following commit(s) were added to refs/heads/master by this push:
new c1d29c5d18 [MINOR UPDATE]: Clear Results after Splunk Unit Tests
(#2740)
c1d29c5d18 is described below
commit c1d29c5d186705235664076b36dc4b73aa73c2e2
Author: Charles S. Givre <[email protected]>
AuthorDate: Mon Jan 16 23:49:54 2023 -0500
[MINOR UPDATE]: Clear Results after Splunk Unit Tests (#2740)
---
.../drill/exec/store/cassandra/CassandraUserTranslationTest.java | 6 +++---
.../apache/drill/exec/store/splunk/TestSplunkUserTranslation.java | 3 +++
2 files changed, 6 insertions(+), 3 deletions(-)
diff --git
a/contrib/storage-cassandra/src/test/java/org/apache/drill/exec/store/cassandra/CassandraUserTranslationTest.java
b/contrib/storage-cassandra/src/test/java/org/apache/drill/exec/store/cassandra/CassandraUserTranslationTest.java
index f52fa54d87..f925fe3b44 100644
---
a/contrib/storage-cassandra/src/test/java/org/apache/drill/exec/store/cassandra/CassandraUserTranslationTest.java
+++
b/contrib/storage-cassandra/src/test/java/org/apache/drill/exec/store/cassandra/CassandraUserTranslationTest.java
@@ -55,7 +55,7 @@ public class CassandraUserTranslationTest extends
BaseCassandraTest {
@Test
public void testInfoSchemaQueryWithValidCredentials() throws Exception {
- // This test validates that the cassandra connection with user translation
appears whne the user is
+ // This test validates that the cassandra connection with user translation
appears when the user is
// authenticated.
ClientFixture client = cluster
.clientBuilder()
@@ -71,7 +71,7 @@ public class CassandraUserTranslationTest extends
BaseCassandraTest {
}
@Test
- public void testSplunkQueryWithUserTranslation() throws Exception {
+ public void testCassandraQueryWithUserTranslation() throws Exception {
ClientFixture client = cluster
.clientBuilder()
.property(DrillProperties.USER, TEST_USER_1)
@@ -85,7 +85,7 @@ public class CassandraUserTranslationTest extends
BaseCassandraTest {
}
@Test
- public void testSplunkQueryWithUserTranslationAndInvalidCredentials() throws
Exception {
+ public void testCassandraQueryWithUserTranslationAndInvalidCredentials()
throws Exception {
ClientFixture client = cluster
.clientBuilder()
.property(DrillProperties.USER, ADMIN_USER)
diff --git
a/contrib/storage-splunk/src/test/java/org/apache/drill/exec/store/splunk/TestSplunkUserTranslation.java
b/contrib/storage-splunk/src/test/java/org/apache/drill/exec/store/splunk/TestSplunkUserTranslation.java
index 7e24e0c720..63de266e5f 100644
---
a/contrib/storage-splunk/src/test/java/org/apache/drill/exec/store/splunk/TestSplunkUserTranslation.java
+++
b/contrib/storage-splunk/src/test/java/org/apache/drill/exec/store/splunk/TestSplunkUserTranslation.java
@@ -52,6 +52,7 @@ public class TestSplunkUserTranslation extends SplunkBaseTest
{
RowSet results = client.queryBuilder().sql(sql).rowSet();
assertEquals(1, results.rowCount());
+ results.clear();
}
@Test
@@ -66,6 +67,7 @@ public class TestSplunkUserTranslation extends SplunkBaseTest
{
RowSet results = client.queryBuilder().sql(sql).rowSet();
assertEquals(2, results.rowCount());
+ results.clear();
}
@Test
@@ -79,6 +81,7 @@ public class TestSplunkUserTranslation extends SplunkBaseTest
{
String sql = "SELECT acceleration_id, action, add_offset, add_timestamp
FROM ut_splunk._audit LIMIT 2";
RowSet results = client.queryBuilder().sql(sql).rowSet();
assertEquals(2, results.rowCount());
+ results.clear();
}
@Test