This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/master by this push:
new 23ee74e camel-aws2-athena: fixed CI issues due to spliting
unit/integration tests (camel-16400) (#5437)
23ee74e is described below
commit 23ee74ed95ed0fc2127c39902a73ca28df7e206a
Author: Otavio Rodolfo Piske <[email protected]>
AuthorDate: Tue Apr 20 10:31:42 2021 +0200
camel-aws2-athena: fixed CI issues due to spliting unit/integration tests
(camel-16400) (#5437)
---
.../camel/component/aws2/athena/AthenaComponentTest.java | 8 ++++----
.../apache/camel/component/aws2/athena/AthenaEndpointTest.java | 10 +++++++++-
2 files changed, 13 insertions(+), 5 deletions(-)
diff --git
a/components/camel-aws/camel-aws2-athena/src/test/java/org/apache/camel/component/aws2/athena/AthenaComponentTest.java
b/components/camel-aws/camel-aws2-athena/src/test/java/org/apache/camel/component/aws2/athena/AthenaComponentTest.java
index 3a8a970..b2391e9 100644
---
a/components/camel-aws/camel-aws2-athena/src/test/java/org/apache/camel/component/aws2/athena/AthenaComponentTest.java
+++
b/components/camel-aws/camel-aws2-athena/src/test/java/org/apache/camel/component/aws2/athena/AthenaComponentTest.java
@@ -373,19 +373,19 @@ public class AthenaComponentTest extends CamelTestSupport
{
@Override
public void configure() {
from("direct:getQueryExecution")
- .to("aws2-athena://label?operation=getQueryExecution")
+
.to("aws2-athena://label?operation=getQueryExecution&accessKey=unused&secretKey=unused®ion=eu-west-1")
.to("mock:result");
from("direct:getQueryResults")
- .to("aws2-athena://label?operation=getQueryResults")
+
.to("aws2-athena://label?operation=getQueryResults&accessKey=unused&secretKey=unused®ion=eu-west-1")
.to("mock:result");
from("direct:listQueryExecutions")
-
.to("aws2-athena://label?operation=listQueryExecutions")
+
.to("aws2-athena://label?operation=listQueryExecutions&accessKey=unused&secretKey=unused®ion=eu-west-1")
.to("mock:result");
from("direct:startQueryExecution")
- .to("aws2-athena://label")
+
.to("aws2-athena://label?accessKey=unused&secretKey=unused")
.to("mock:result");
}
};
diff --git
a/components/camel-aws/camel-aws2-athena/src/test/java/org/apache/camel/component/aws2/athena/AthenaEndpointTest.java
b/components/camel-aws/camel-aws2-athena/src/test/java/org/apache/camel/component/aws2/athena/AthenaEndpointTest.java
index 100d39c..7d799a5 100644
---
a/components/camel-aws/camel-aws2-athena/src/test/java/org/apache/camel/component/aws2/athena/AthenaEndpointTest.java
+++
b/components/camel-aws/camel-aws2-athena/src/test/java/org/apache/camel/component/aws2/athena/AthenaEndpointTest.java
@@ -68,6 +68,8 @@ public class AthenaEndpointTest {
+ "&delay=3"
+ "&maxAttempts=4"
+ "&retry=always"
+
+ "&accessKey=unused"
+
+ "&secretKey=unused"
+ "&resetWaitTimeoutOnRetry=false"))
.getConfiguration();
@@ -96,7 +98,7 @@ public class AthenaEndpointTest {
@Test
public void defaultEndpointParams() {
Athena2Configuration configuration = ((Athena2Endpoint)
camelContext.getEndpoint(
- "aws2-athena://label")).getConfiguration();
+
"aws2-athena://label?accessKey=unused&secretKey=unused")).getConfiguration();
assertEquals(amazonAthenaClient,
configuration.getAmazonAthenaClient());
assertEquals(Athena2Operations.startQueryExecution,
configuration.getOperation());
@@ -125,6 +127,8 @@ public class AthenaEndpointTest {
Athena2Configuration configuration = ((Athena2Endpoint)
camelContext.getEndpoint(
"aws2-athena://label"
+ "?operation=getQueryExecution"
+
+ "&accessKey=unused"
+
+ "&secretKey=unused"
+ "&queryExecutionId=123"))
.getConfiguration();
@@ -140,6 +144,8 @@ public class AthenaEndpointTest {
+ "&queryExecutionId=123"
+ "&outputType=SelectList"
+ "&maxResults=1"
+
+ "&accessKey=unused"
+
+ "&secretKey=unused"
+ "&nextToken=nt")).getConfiguration();
assertEquals(Athena2Operations.getQueryResults,
configuration.getOperation());
@@ -156,6 +162,8 @@ public class AthenaEndpointTest {
+ "?operation=listQueryExecutions"
+ "&maxResults=1"
+ "&nextToken=nt"
+
+ "&accessKey=unused"
+
+ "&secretKey=unused"
+ "&workGroup=wg")).getConfiguration();
assertEquals(Athena2Operations.listQueryExecutions,
configuration.getOperation());
