[nifi] branch dependabot/npm_and_yarn/nifi-registry/nifi-registry-core/nifi-registry-web-ui/src/main/engine.io-and-socket.io-3.6.1 created (now eb5b3da66d)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch dependabot/npm_and_yarn/nifi-registry/nifi-registry-core/nifi-registry-web-ui/src/main/engine.io-and-socket.io-3.6.1 in repository https://gitbox.apache.org/repos/asf/nifi.git at eb5b3da66d Bump engine.io and socket.io No new revisions were added by this update.
[nifi] branch dependabot/maven/nifi-registry/nifi-registry-core/nifi-registry-test/org.postgresql-postgresql-42.4.3 created (now 204b57c4ed)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch dependabot/maven/nifi-registry/nifi-registry-core/nifi-registry-test/org.postgresql-postgresql-42.4.3 in repository https://gitbox.apache.org/repos/asf/nifi.git at 204b57c4ed Bump postgresql in /nifi-registry/nifi-registry-core/nifi-registry-test No new revisions were added by this update.
[nifi] branch main updated: NIFI-10845 - JsonQueryElasticsearch processors are not outputting an empty flow file for a combined response with output_no_hits set to true
This is an automated email from the ASF dual-hosted git repository.
chriss pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/main by this push:
new 2ad33eea80 NIFI-10845 - JsonQueryElasticsearch processors are not
outputting an empty flow file for a combined response with output_no_hits set
to true
2ad33eea80 is described below
commit 2ad33eea8002db00b5bf80edc7b2dc30cb3d1557
Author: Ryan Van Den Bos
AuthorDate: Tue Nov 22 09:41:44 2022 +
NIFI-10845 - JsonQueryElasticsearch processors are not outputting an empty
flow file for a combined response with output_no_hits set to true
Signed-off-by: Chris Sampson
This closes #6701
---
.../AbstractJsonQueryElasticsearch.java| 8 +++--
.../AbstractPaginatedJsonQueryElasticsearch.java | 3 ++
...tractPaginatedJsonQueryElasticsearchTest.groovy | 39 ++
3 files changed, 48 insertions(+), 2 deletions(-)
diff --git
a/nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/AbstractJsonQueryElasticsearch.java
b/nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/AbstractJsonQueryElasticsearch.java
index 1ce0f7f414..f154cf2790 100644
---
a/nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/AbstractJsonQueryElasticsearch.java
+++
b/nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/AbstractJsonQueryElasticsearch.java
@@ -105,6 +105,10 @@ public abstract class AbstractJsonQueryElasticsearch clientService = new
AtomicReference<>(null);
@@ -277,8 +281,8 @@ public abstract class AbstractJsonQueryElasticsearch attributes) {
+FlowFile writeHitFlowFile(final int count, final String json, final
ProcessSession session,
+ final FlowFile hitFlowFile, final Map attributes) {
final FlowFile ff = session.write(hitFlowFile, out ->
out.write(json.getBytes()));
attributes.put("hit.count", Integer.toString(count));
diff --git
a/nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/AbstractPaginatedJsonQueryElasticsearch.java
b/nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/AbstractPaginatedJsonQueryElasticsearch.java
index 2e8eab6eeb..ec1a020ad7 100644
---
a/nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/AbstractPaginatedJsonQueryElasticsearch.java
+++
b/nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/AbstractPaginatedJsonQueryElasticsearch.java
@@ -273,6 +273,9 @@ public abstract class
AbstractPaginatedJsonQueryElasticsearch extends AbstractJs
hitsFlowFiles.add(writeCombinedHitFlowFile(paginatedJsonQueryParameters.getHitCount()
+ hits.size(),
hits, session, hitFlowFile, attributes, append));
+} else if (getOutputNoHits()) {
+final FlowFile hitFlowFile = createChildFlowFile(session, parent);
+hitsFlowFiles.add(writeHitFlowFile(0, "", session, hitFlowFile,
attributes));
}
}
diff --git
a/nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/test/groovy/org/apache/nifi/processors/elasticsearch/AbstractPaginatedJsonQueryElasticsearchTest.groovy
b/nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/test/groovy/org/apache/nifi/processors/elasticsearch/AbstractPaginatedJsonQueryElasticsearchTest.groovy
index 274e6a2fd5..0ec4470f76 100644
---
a/nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/test/groovy/org/apache/nifi/processors/elasticsearch/AbstractPaginatedJsonQueryElasticsearchTest.groovy
+++
b/nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/test/groovy/org/apache/nifi/processors/elasticsearch/AbstractPaginatedJsonQueryElasticsearchTest.groovy
@@ -268,4 +268,43 @@ abstract class AbstractPaginatedJsonQueryElasticsearchTest
extends AbstractJsonQ
assertThat(runner.getProvenanceEvents().stream().filter({ pe ->
pe.getEventType() == ProvenanceEventType.SEND}).count(), is(0L))
}
}
+
+@Test
+void testNoHitsFlowFileIsProducedForEachResultSplitSetup() {
+final TestRunner runner = createRunner(false)
+final TestElasticsearchClientService service = getService(runner)
+
[nifi] branch NIFI-10854-RC1 created (now 75e7c9e47c)
This is an automated email from the ASF dual-hosted git repository. joewitt pushed a change to branch NIFI-10854-RC1 in repository https://gitbox.apache.org/repos/asf/nifi.git at 75e7c9e47c NIFI-10854-RC1 prepare for next development iteration This branch includes the following new commits: new ec87bf93ad NIFI-10854-RC1 prepare release nifi-1.19.0-RC1 new 75e7c9e47c NIFI-10854-RC1 prepare for next development iteration The 2 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[nifi] annotated tag nifi-1.19.0-RC1 created (now 8aca09372a)
This is an automated email from the ASF dual-hosted git repository. joewitt pushed a change to annotated tag nifi-1.19.0-RC1 in repository https://gitbox.apache.org/repos/asf/nifi.git at 8aca09372a (tag) tagging ec87bf93add2f645d2ea426002e0c24db54614ff (commit) replaces rel/nifi-1.18.0 by Joe Witt on Tue Nov 22 19:22:45 2022 -0700 - Log - NIFI-10854-RC1 copy for tag nifi-1.19.0-RC1 --- No new revisions were added by this update.
svn commit: r58215 - /dev/nifi/nifi-1.19.0/
Author: joewitt Date: Wed Nov 23 15:53:30 2022 New Revision: 58215 Log: Uploading RC1 artifacts for nifi-1.19.0 Added: dev/nifi/nifi-1.19.0/ dev/nifi/nifi-1.19.0/minifi-1.19.0-bin.zip (with props) dev/nifi/nifi-1.19.0/minifi-1.19.0-bin.zip.asc dev/nifi/nifi-1.19.0/minifi-1.19.0-bin.zip.sha256 dev/nifi/nifi-1.19.0/minifi-1.19.0-bin.zip.sha512 dev/nifi/nifi-1.19.0/minifi-c2-1.19.0-bin.zip (with props) dev/nifi/nifi-1.19.0/minifi-c2-1.19.0-bin.zip.asc dev/nifi/nifi-1.19.0/minifi-c2-1.19.0-bin.zip.sha256 dev/nifi/nifi-1.19.0/minifi-c2-1.19.0-bin.zip.sha512 dev/nifi/nifi-1.19.0/minifi-toolkit-1.19.0-bin.zip (with props) dev/nifi/nifi-1.19.0/minifi-toolkit-1.19.0-bin.zip.asc dev/nifi/nifi-1.19.0/minifi-toolkit-1.19.0-bin.zip.sha256 dev/nifi/nifi-1.19.0/minifi-toolkit-1.19.0-bin.zip.sha512 dev/nifi/nifi-1.19.0/nifi-1.19.0-bin.zip (with props) dev/nifi/nifi-1.19.0/nifi-1.19.0-bin.zip.asc dev/nifi/nifi-1.19.0/nifi-1.19.0-bin.zip.sha256 dev/nifi/nifi-1.19.0/nifi-1.19.0-bin.zip.sha512 dev/nifi/nifi-1.19.0/nifi-1.19.0-source-release.zip (with props) dev/nifi/nifi-1.19.0/nifi-1.19.0-source-release.zip.asc dev/nifi/nifi-1.19.0/nifi-1.19.0-source-release.zip.sha256 dev/nifi/nifi-1.19.0/nifi-1.19.0-source-release.zip.sha512 dev/nifi/nifi-1.19.0/nifi-registry-1.19.0-bin.zip (with props) dev/nifi/nifi-1.19.0/nifi-registry-1.19.0-bin.zip.asc dev/nifi/nifi-1.19.0/nifi-registry-1.19.0-bin.zip.sha256 dev/nifi/nifi-1.19.0/nifi-registry-1.19.0-bin.zip.sha512 dev/nifi/nifi-1.19.0/nifi-registry-toolkit-1.19.0-bin.zip (with props) dev/nifi/nifi-1.19.0/nifi-registry-toolkit-1.19.0-bin.zip.asc dev/nifi/nifi-1.19.0/nifi-registry-toolkit-1.19.0-bin.zip.sha256 dev/nifi/nifi-1.19.0/nifi-registry-toolkit-1.19.0-bin.zip.sha512 dev/nifi/nifi-1.19.0/nifi-stateless-1.19.0-bin.zip (with props) dev/nifi/nifi-1.19.0/nifi-stateless-1.19.0-bin.zip.asc dev/nifi/nifi-1.19.0/nifi-stateless-1.19.0-bin.zip.sha256 dev/nifi/nifi-1.19.0/nifi-stateless-1.19.0-bin.zip.sha512 dev/nifi/nifi-1.19.0/nifi-toolkit-1.19.0-bin.zip (with props) dev/nifi/nifi-1.19.0/nifi-toolkit-1.19.0-bin.zip.asc dev/nifi/nifi-1.19.0/nifi-toolkit-1.19.0-bin.zip.sha256 dev/nifi/nifi-1.19.0/nifi-toolkit-1.19.0-bin.zip.sha512 Added: dev/nifi/nifi-1.19.0/minifi-1.19.0-bin.zip == Binary file - no diff available. Propchange: dev/nifi/nifi-1.19.0/minifi-1.19.0-bin.zip -- svn:mime-type = application/octet-stream Added: dev/nifi/nifi-1.19.0/minifi-1.19.0-bin.zip.asc == --- dev/nifi/nifi-1.19.0/minifi-1.19.0-bin.zip.asc (added) +++ dev/nifi/nifi-1.19.0/minifi-1.19.0-bin.zip.asc Wed Nov 23 15:53:30 2022 @@ -0,0 +1,11 @@ +-BEGIN PGP SIGNATURE- + +iQEzBAABCgAdFiEE0vJLgJ/6seIa6gKDkJO/hU+BGhoFAmN+QEUACgkQkJO/hU+B +GhrQkggAnJ463Oz5dwmCNM2D9NJFteX258Um773dY1dm0qjCd6RwNi2xuw5uokJD +M1dSCgwVDwuBK5B8KrH/Aqq2PnFvj5IeeEkDlJ1HQiZ6q06L5zTYAeoE9kd/GY9m +mN8aPqr+1vC0wpJY50Nm5N+FvqFy2vXnkNiQUeoxuNbksqYOm/0bFeRAlfK0L0g6 +fC7ay0h2DUD5XxpHq+DSPG0RAHsbhqGXmEsvziQE+4l0ZxyrAoyBHIpzgAb5CH0k +MwEEhObfseJ4QgIOKyWXf7sWoSm2BmKsPuBX1GpLoV7R1cPI28kqCkvihcBhAJDt +WtpFg1jlZ/hRzvBicUx9Lqoe25kZMA== +=g9ET +-END PGP SIGNATURE- Added: dev/nifi/nifi-1.19.0/minifi-1.19.0-bin.zip.sha256 == --- dev/nifi/nifi-1.19.0/minifi-1.19.0-bin.zip.sha256 (added) +++ dev/nifi/nifi-1.19.0/minifi-1.19.0-bin.zip.sha256 Wed Nov 23 15:53:30 2022 @@ -0,0 +1 @@ +7394c664fa65d2ee226d9e158bea1253569f137c8f53aa99eb4436e56c60bf2b Added: dev/nifi/nifi-1.19.0/minifi-1.19.0-bin.zip.sha512 == --- dev/nifi/nifi-1.19.0/minifi-1.19.0-bin.zip.sha512 (added) +++ dev/nifi/nifi-1.19.0/minifi-1.19.0-bin.zip.sha512 Wed Nov 23 15:53:30 2022 @@ -0,0 +1 @@ +2136890b3d3c6e6ce73cf5361eb632b556a8d8ca3eca9a9fba5329ddd5d1b231aa9f8003a3f2d16678d75c598ea6db776ef128c3b98839077df462c783679423 Added: dev/nifi/nifi-1.19.0/minifi-c2-1.19.0-bin.zip == Binary file - no diff available. Propchange: dev/nifi/nifi-1.19.0/minifi-c2-1.19.0-bin.zip -- svn:mime-type = application/octet-stream Added: dev/nifi/nifi-1.19.0/minifi-c2-1.19.0-bin.zip.asc == --- dev/nifi/nifi-1.19.0/minifi-c2-1.19.0-bin.zip.asc (added) +++ dev/nifi/nifi-1.19.0/minifi-c2-1.19.0-bin.zip.asc Wed Nov 23 15:53:30 2022 @@ -0,0 +1,11 @@ +-BEGIN PGP SIGNATURE- +
[nifi] branch main updated: NIFI-6428 Add 'inTransaction' value to state,fix bug
This is an automated email from the ASF dual-hosted git repository.
mattyb149 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/main by this push:
new 2393785765 NIFI-6428 Add 'inTransaction' value to state,fix bug
2393785765 is described below
commit 23937857654df4414ec5be5177444ac6d74d7f68
Author: sssqhai
AuthorDate: Sat May 7 16:35:08 2022 +0800
NIFI-6428 Add 'inTransaction' value to state,fix bug
Signed-off-by: Matthew Burgess
This closes #6036
---
.../cdc/mysql/processors/CaptureChangeMySQL.java | 26 +-
.../mysql/processors/CaptureChangeMySQLTest.groovy | 21 +-
.../nifi/cdc/mysql/CaptureChangeMySQLTest.java | 393 +
.../nifi/cdc/mysql/MockBinlogClientJava.java | 108 ++
4 files changed, 535 insertions(+), 13 deletions(-)
diff --git
a/nifi-nar-bundles/nifi-cdc/nifi-cdc-mysql-bundle/nifi-cdc-mysql-processors/src/main/java/org/apache/nifi/cdc/mysql/processors/CaptureChangeMySQL.java
b/nifi-nar-bundles/nifi-cdc/nifi-cdc-mysql-bundle/nifi-cdc-mysql-processors/src/main/java/org/apache/nifi/cdc/mysql/processors/CaptureChangeMySQL.java
index cc9d86137c..3e245c7ab0 100644
---
a/nifi-nar-bundles/nifi-cdc/nifi-cdc-mysql-bundle/nifi-cdc-mysql-processors/src/main/java/org/apache/nifi/cdc/mysql/processors/CaptureChangeMySQL.java
+++
b/nifi-nar-bundles/nifi-cdc/nifi-cdc-mysql-bundle/nifi-cdc-mysql-processors/src/main/java/org/apache/nifi/cdc/mysql/processors/CaptureChangeMySQL.java
@@ -130,6 +130,8 @@ import static
com.github.shyiko.mysql.binlog.event.EventType.PRE_GA_DELETE_ROWS;
import static com.github.shyiko.mysql.binlog.event.EventType.PRE_GA_WRITE_ROWS;
import static com.github.shyiko.mysql.binlog.event.EventType.ROTATE;
import static com.github.shyiko.mysql.binlog.event.EventType.WRITE_ROWS;
+import static com.github.shyiko.mysql.binlog.event.EventType.XID;
+
/**
* A processor to retrieve Change Data Capture (CDC) events and send them as
flow files.
@@ -626,6 +628,8 @@ public class CaptureChangeMySQL extends
AbstractSessionFactoryProcessor {
} else {
currentSequenceId.set(Long.parseLong(seqIdString));
}
+//get inTransaction value from state
+inTransaction = "true".equals(stateMap.get("inTransaction"));
// Get reference to Distributed Cache if one exists. If it does not,
no enrichment (resolution of column names, e.g.) will be performed
boolean createEnrichmentConnection = false;
@@ -942,6 +946,8 @@ public class CaptureChangeMySQL extends
AbstractSessionFactoryProcessor {
currentSequenceId.set(beginEventWriter.writeEvent(currentSession, transitUri,
beginEvent, currentSequenceId.get(), REL_SUCCESS));
}
inTransaction = true;
+//update inTransaction value to state
+updateState(session);
} else if ("COMMIT".equals(sql)) {
if (!inTransaction) {
throw new IOException("COMMIT event received while
not processing a transaction (i.e. no corresponding BEGIN event). "
@@ -954,12 +960,11 @@ public class CaptureChangeMySQL extends
AbstractSessionFactoryProcessor {
: new
CommitTransactionEventInfo(currentDatabase, timestamp, currentBinlogFile,
currentBinlogPosition);
currentSequenceId.set(commitEventWriter.writeEvent(currentSession, transitUri,
commitTransactionEvent, currentSequenceId.get(), REL_SUCCESS));
}
-
+//update inTransaction value to state
+inTransaction = false;
updateState(session);
-
// Commit the NiFi session
session.commitAsync();
-inTransaction = false;
currentTable = null;
} else {
// Check for DDL events (alter table, e.g.). Normalize
the query to do string matching on the type of change
@@ -1005,9 +1010,12 @@ public class CaptureChangeMySQL extends
AbstractSessionFactoryProcessor {
currentSequenceId.set(commitEventWriter.writeEvent(currentSession, transitUri,
commitTransactionEvent, currentSequenceId.get(), REL_SUCCESS));
}
// Commit the NiFi session
+// update inTransaction value and save next position
+// so when restart this processor,we will not read xid
event again
+inTransaction = false;
+currentBinlogPosition = header.getNextPosition();
updateState(session);
session.commitAsync();
-inTransaction = false;
[nifi] branch main updated: NIFI-10850: Fixed Query Parameters property in InvokeAWSGatewayApi should support FlowFile attributes in EL
This is an automated email from the ASF dual-hosted git repository.
pvillard pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/main by this push:
new 40b46b4f5d NIFI-10850: Fixed Query Parameters property in
InvokeAWSGatewayApi should support FlowFile attributes in EL
40b46b4f5d is described below
commit 40b46b4f5d385cbaaba114b7d539cff55cf4f011
Author: Peter Turcsanyi
AuthorDate: Mon Nov 21 17:27:31 2022 +0100
NIFI-10850: Fixed Query Parameters property in InvokeAWSGatewayApi should
support FlowFile attributes in EL
Signed-off-by: Pierre Villard
This closes #6692.
---
.../nifi/processors/aws/wag/AbstractAWSGatewayApiProcessor.java | 9 +
.../nifi/processors/aws/wag/TestInvokeAmazonGatewayApiMock.java | 5 +++--
2 files changed, 8 insertions(+), 6 deletions(-)
diff --git
a/nifi-nar-bundles/nifi-aws-bundle/nifi-aws-abstract-processors/src/main/java/org/apache/nifi/processors/aws/wag/AbstractAWSGatewayApiProcessor.java
b/nifi-nar-bundles/nifi-aws-bundle/nifi-aws-abstract-processors/src/main/java/org/apache/nifi/processors/aws/wag/AbstractAWSGatewayApiProcessor.java
index 7cde727fa0..66068a863e 100644
---
a/nifi-nar-bundles/nifi-aws-bundle/nifi-aws-abstract-processors/src/main/java/org/apache/nifi/processors/aws/wag/AbstractAWSGatewayApiProcessor.java
+++
b/nifi-nar-bundles/nifi-aws-bundle/nifi-aws-abstract-processors/src/main/java/org/apache/nifi/processors/aws/wag/AbstractAWSGatewayApiProcessor.java
@@ -402,7 +402,7 @@ public abstract class AbstractAWSGatewayApiProcessor extends
context.getProperty(PROP_METHOD).evaluateAttributeExpressions(requestFlowFile)
.getValue()).toUpperCase();
final HttpMethodName methodName = HttpMethodName.fromValue(method);
-return configureRequest(context, session,
resourcePath,requestFlowFile, methodName, attributes);
+return configureRequest(context, session, resourcePath,
requestFlowFile, methodName, attributes);
}
protected GenericApiGatewayRequest configureRequest(final ProcessContext
context,
@@ -414,7 +414,7 @@ public abstract class AbstractAWSGatewayApiProcessor extends
GenericApiGatewayRequestBuilder builder = new
GenericApiGatewayRequestBuilder()
.withResourcePath(resourcePath);
-final Map> parameters = getParameters(context);
+final Map> parameters = getParameters(context,
attributes);
builder = builder.withParameters(parameters);
InputStream requestBody;
@@ -522,15 +522,16 @@ public abstract class AbstractAWSGatewayApiProcessor
extends
* Returns a map of Query Parameter Name to Values
*
* @param context ProcessContext
+ * @param flowFileAttributes map of FlowFile attributes used for EL
evaluation
* @return Map of names and values
*/
-protected Map> getParameters(final ProcessContext
context) {
+protected Map> getParameters(final ProcessContext
context, Map flowFileAttributes) {
if (!context.getProperty(PROP_QUERY_PARAMS).isSet()) {
return new HashMap<>();
}
final String queryString = context.getProperty(PROP_QUERY_PARAMS)
-
.evaluateAttributeExpressions().getValue();
+
.evaluateAttributeExpressions(flowFileAttributes).getValue();
final List params = URLEncodedUtils
.parse(queryString, Charsets.toCharset("UTF-8"));
diff --git
a/nifi-nar-bundles/nifi-aws-bundle/nifi-aws-processors/src/test/java/org/apache/nifi/processors/aws/wag/TestInvokeAmazonGatewayApiMock.java
b/nifi-nar-bundles/nifi-aws-bundle/nifi-aws-processors/src/test/java/org/apache/nifi/processors/aws/wag/TestInvokeAmazonGatewayApiMock.java
index 5b7927dd31..b3a4a970e8 100644
---
a/nifi-nar-bundles/nifi-aws-bundle/nifi-aws-processors/src/test/java/org/apache/nifi/processors/aws/wag/TestInvokeAmazonGatewayApiMock.java
+++
b/nifi-nar-bundles/nifi-aws-bundle/nifi-aws-processors/src/test/java/org/apache/nifi/processors/aws/wag/TestInvokeAmazonGatewayApiMock.java
@@ -178,7 +178,7 @@ public class TestInvokeAmazonGatewayApiMock {
// add dynamic property
runner.setProperty("dynamicHeader", "yes!");
-runner.setProperty(InvokeAWSGatewayApi.PROP_QUERY_PARAMS,
"apples=oranges=cats");
+runner.setProperty(InvokeAWSGatewayApi.PROP_QUERY_PARAMS,
"apples=oranges=cats=${filename}");
// set the regex
runner.setProperty(InvokeAWSGatewayApi.PROP_ATTRIBUTES_TO_SEND, "F.*");
@@ -186,6 +186,7 @@ public class TestInvokeAmazonGatewayApiMock {
final Map attributes = new HashMap<>();
attributes.put(CoreAttributes.MIME_TYPE.key(),
"application/plain-text");
attributes.put("Foo", "Bar");
+attributes.put("filename", "testfile");
